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 #include <common/defaults.h>
  29
  30 #define RELAYD_VERSION_COMM_MAJOR             2
  31 #define RELAYD_VERSION_COMM_MINOR             1
  32
  33 /*
  34  * lttng-relayd communication header.
  35  */
  36 struct lttcomm_relayd_hdr {
  37         /* Circuit ID not used for now so always ignored */
  38         uint64_t circuit_id;
  39         uint64_t data_size;             /* data size following this header */
  40         uint32_t cmd;                   /* enum lttcomm_relayd_command */
  41         uint32_t cmd_version;   /* command version */
  42 } LTTNG_PACKED;
  43
  44 /*
  45  * lttng-relayd data header.
  46  */
  47 struct lttcomm_relayd_data_hdr {
  48         /* Circuit ID not used for now so always ignored */
  49         uint64_t circuit_id;
  50         uint64_t stream_id;     /* Stream ID known by the relayd */
  51         uint64_t net_seq_num;   /* Network sequence number, per stream. */
  52         uint32_t data_size;     /* data size following this header */
  53         uint32_t padding_size;  /* Size of 0 padding the data */
  54 } LTTNG_PACKED;
  55
  56 /*
  57  * Reply from a create session command.
  58  */
  59 struct lttcomm_relayd_status_session {
  60         uint64_t session_id;
  61         uint32_t ret_code;
  62 } LTTNG_PACKED;
  63
  64 /*
  65  * Used to add a stream on the relay daemon.
  66  */
  67 struct lttcomm_relayd_add_stream {
  68         char channel_name[DEFAULT_STREAM_NAME_LEN];
  69         char pathname[PATH_MAX];
  70 } LTTNG_PACKED;
  71
  72 /*
  73  * Answer from an add stream command.
  74  */
  75 struct lttcomm_relayd_status_stream {
  76         uint64_t handle;
  77         uint32_t ret_code;
  78 } LTTNG_PACKED;
  79
  80 /*
  81  * Used to return command code for command not needing special data.
  82  */
  83 struct lttcomm_relayd_generic_reply {
  84         uint32_t ret_code;
  85 } LTTNG_PACKED;
  86
  87 /*
  88  * Used to update synchronization information.
  89  */
  90 struct lttcomm_relayd_update_sync_info {
  91         /* TODO: fill the structure. Feature not implemented yet */
  92 } LTTNG_PACKED;
  93
  94 /*
  95  * Version command.
  96  */
  97 struct lttcomm_relayd_version {
  98         uint32_t major;
  99         uint32_t minor;
 100 } LTTNG_PACKED;
 101
 102 /*
 103  * Metadata payload used when metadata command is sent.
 104  */
 105 struct lttcomm_relayd_metadata_payload {
 106         uint64_t stream_id;
 107         uint32_t padding_size;
 108         char payload[];
 109 } LTTNG_PACKED;
 110
 111 /*
 112  * Used to indicate that a specific stream id can now be closed.
 113  */
 114 struct lttcomm_relayd_close_stream {
 115         uint64_t stream_id;
 116         uint64_t last_net_seq_num;      /* sequence number of last packet */
 117 } LTTNG_PACKED;
 118
 119 /*
 120  * Used to test if for a given stream id the data is pending on the relayd side
 121  * for reading.
 122  */
 123 struct lttcomm_relayd_data_pending {
 124         uint64_t stream_id;
 125         uint64_t last_net_seq_num; /* Sequence number of the last packet */
 126 } LTTNG_PACKED;
 127
 128 struct lttcomm_relayd_begin_data_pending {
 129         uint64_t session_id;
 130 } LTTNG_PACKED;
 131
 132 struct lttcomm_relayd_end_data_pending {
 133         uint64_t session_id;
 134 } LTTNG_PACKED;
 135
 136 struct lttcomm_relayd_quiescent_control {
 137         uint64_t stream_id;
 138 } LTTNG_PACKED;
 139
 140 #endif  /* _RELAYD_COMM */