X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=formats%2Flttng-live%2Flttng-live.h;h=4ab641d59609dceb6d53d2a9cfa4f12f9835d467;hb=5ea98697b9f786ac73fd5152d96aebe02906a10d;hp=071f288183564e95ceb69346d094e490952a1a02;hpb=150595c4f9f664a183289c0f7147eeb663ff40bb;p=babeltrace.git diff --git a/formats/lttng-live/lttng-live.h b/formats/lttng-live/lttng-live.h index 071f2881..4ab641d5 100644 --- a/formats/lttng-live/lttng-live.h +++ b/formats/lttng-live/lttng-live.h @@ -25,19 +25,22 @@ */ #include +#include "lttng-viewer-abi.h" -#define LTTNG_METADATA_PATH_TEMPLATE "/tmp/lttng-live-XXXXXX" #define LTTNG_DEFAULT_NETWORK_VIEWER_PORT 5344 #define LTTNG_LIVE_MAJOR 2 #define LTTNG_LIVE_MINOR 4 struct lttng_live_ctx { - char traced_hostname[NAME_MAX]; - char session_name[NAME_MAX]; - char relay_hostname[NAME_MAX]; + char traced_hostname[MAXNAMLEN]; + char session_name[MAXNAMLEN]; + char relay_hostname[MAXNAMLEN]; int control_sock; int port; + /* Protocol version to use for this connection. */ + uint32_t major; + uint32_t minor; struct lttng_live_session *session; struct bt_context *bt_ctx; GArray *session_ids; @@ -46,11 +49,14 @@ struct lttng_live_ctx { struct lttng_live_viewer_stream { uint64_t id; uint64_t mmap_size; - int fd; + uint64_t ctf_stream_id; + FILE *metadata_fp_write; + ssize_t metadata_len; int metadata_flag; - int first_read; + int data_pending; struct lttng_live_session *session; struct lttng_live_ctf_trace *ctf_trace; + struct lttng_viewer_index current_index; char path[PATH_MAX]; }; @@ -85,7 +91,8 @@ int lttng_live_connect_viewer(struct lttng_live_ctx *ctx); int lttng_live_establish_connection(struct lttng_live_ctx *ctx); int lttng_live_list_sessions(struct lttng_live_ctx *ctx, const char *path); int lttng_live_attach_session(struct lttng_live_ctx *ctx, uint64_t id); -void lttng_live_read(struct lttng_live_ctx *ctx); +int lttng_live_read(struct lttng_live_ctx *ctx); int lttng_live_get_new_streams(struct lttng_live_ctx *ctx, uint64_t id); +int lttng_live_should_quit(void); #endif /* _LTTNG_LIVE_H */