projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add consumer socket object and relayd commands
[lttng-tools.git]
/
src
/
common
/
sessiond-comm
/
relayd.h
diff --git
a/src/common/sessiond-comm/relayd.h
b/src/common/sessiond-comm/relayd.h
index 67b06371f2d6d47de10b58724699e3a86810e922..c025fcdd926a21eef1032a72c4f5cd9a8461e99a 100644
(file)
--- a/
src/common/sessiond-comm/relayd.h
+++ b/
src/common/sessiond-comm/relayd.h
@@
-44,20
+44,10
@@
struct lttcomm_relayd_data_hdr {
/* Circuit ID not used for now so always ignored */
uint64_t circuit_id;
uint64_t stream_id; /* Stream ID known by the relayd */
/* Circuit ID not used for now so always ignored */
uint64_t circuit_id;
uint64_t stream_id; /* Stream ID known by the relayd */
- uint64_t net_seq_num; /* Network seq
. number for UDP
. */
+ uint64_t net_seq_num; /* Network seq
uence number, per stream
. */
uint32_t data_size; /* data size following this header */
} __attribute__ ((__packed__));
uint32_t data_size; /* data size following this header */
} __attribute__ ((__packed__));
-#if 0
-/*
- * Used to create a session between the relay and the sessiond.
- */
-struct lttcomm_relayd_create_session {
- char hostname[LTTNG_MAX_DNNAME];
- char session_name[NAME_MAX];
-};
-#endif
-
/*
* Used to add a stream on the relay daemon.
*/
/*
* Used to add a stream on the relay daemon.
*/
@@
-85,7
+75,7
@@
struct lttcomm_relayd_generic_reply {
* Used to update synchronization information.
*/
struct lttcomm_relayd_update_sync_info {
* Used to update synchronization information.
*/
struct lttcomm_relayd_update_sync_info {
- /* TODO: fill the structure */
+ /* TODO: fill the structure
. Feature not implemented yet
*/
} __attribute__ ((__packed__));
/*
} __attribute__ ((__packed__));
/*
@@
-104,4
+94,12
@@
struct lttcomm_relayd_metadata_payload {
char payload[];
} __attribute__ ((__packed__));
char payload[];
} __attribute__ ((__packed__));
+/*
+ * Used to indicate that a specific stream id can now be closed.
+ */
+struct lttcomm_relayd_close_stream {
+ uint64_t stream_id;
+ uint64_t last_net_seq_num; /* sequence number of last packet */
+} __attribute__ ((__packed__));
+
#endif /* _RELAYD_COMM */
#endif /* _RELAYD_COMM */
This page took
0.028571 seconds
and
4
git commands to generate.