src/common/sessiond-comm/relayd.h

   1 /*
   2  * Copyright (C) 2012 - David Goulet <dgoulet@efficios.com>
   3  *                      Julien Desfossez <julien.desfossez@efficios.com>
   4  *
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License, version 2 only,
   7  * as published by the Free Software Foundation.
   8  *
   9  * This program is distributed in the hope that it will be useful, but WITHOUT
  10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  11  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
  12  * more details.
  13  *
  14  * You should have received a copy of the GNU General Public License along
  15  * with this program; if not, write to the Free Software Foundation, Inc.,
  16  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  17  */
  18
  19 #ifndef _RELAYD_COMM
  20 #define _RELAYD_COMM
  21
  22 #define _GNU_SOURCE
  23
  24 #include <limits.h>
  25 #include <stdint.h>
  26
  27 #include <lttng/lttng.h>
  28
  29 /*
  30  * lttng-relayd communication header.
  31  */
  32 struct lttcomm_relayd_hdr {
  33         /* Circuit ID not used for now so always ignored */
  34         uint64_t circuit_id;
  35         uint64_t data_size;             /* data size following this header */
  36         uint32_t cmd;                   /* enum lttcomm_sessiond_command */
  37         uint32_t cmd_version;   /* command version */
  38 } __attribute__ ((__packed__));
  39
  40 /*
  41  * lttng-relayd data header.
  42  */
  43 struct lttcomm_relayd_data_hdr {
  44         /* Circuit ID not used for now so always ignored */
  45         uint64_t circuit_id;
  46         uint64_t stream_id;     /* Stream ID known by the relayd */
  47         uint64_t net_seq_num;   /* Network sequence number, per stream. */
  48         uint32_t data_size;     /* data size following this header */
  49 } __attribute__ ((__packed__));
  50
  51 /*
  52  * Used to add a stream on the relay daemon.
  53  */
  54 struct lttcomm_relayd_add_stream {
  55         char channel_name[LTTNG_SYMBOL_NAME_LEN];
  56         char pathname[PATH_MAX];
  57 } __attribute__ ((__packed__));
  58
  59 /*
  60  * Answer from an add stream command.
  61  */
  62 struct lttcomm_relayd_status_stream {
  63         uint64_t handle;
  64         uint32_t ret_code;
  65 } __attribute__ ((__packed__));
  66
  67 /*
  68  * Used to return command code for command not needing special data.
  69  */
  70 struct lttcomm_relayd_generic_reply {
  71         uint32_t ret_code;
  72 } __attribute__ ((__packed__));
  73
  74 /*
  75  * Used to update synchronization information.
  76  */
  77 struct lttcomm_relayd_update_sync_info {
  78         /* TODO: fill the structure. Feature not implemented yet */
  79 } __attribute__ ((__packed__));
  80
  81 /*
  82  * Version command.
  83  */
  84 struct lttcomm_relayd_version {
  85         uint32_t major;
  86         uint32_t minor;
  87 } __attribute__ ((__packed__));
  88
  89 /*
  90  * Metadata payload used when metadata command is sent.
  91  */
  92 struct lttcomm_relayd_metadata_payload {
  93         uint64_t stream_id;
  94         char payload[];
  95 } __attribute__ ((__packed__));
  96
  97 /*
  98  * Used to indicate that a specific stream id can now be closed.
  99  */
 100 struct lttcomm_relayd_close_stream {
 101         uint64_t stream_id;
 102         uint64_t last_net_seq_num;      /* sequence number of last packet */
 103 } __attribute__ ((__packed__));
 104
 105 #endif  /* _RELAYD_COMM */