X-Git-Url: http://git.lttng.org/?a=blobdiff_plain;f=include%2Flttng%2Fust-events.h;h=b930a3495d073c4c5e9cf640419cd72561810db8;hb=9e0e41bf1e9f61e8c30a6e45391596a5ac6c2ceb;hp=95af893a6f5e73adc5810adff62e1c8181c2a9fc;hpb=4318ae1be57eb7983ab4857a7a8eeb4a030a8216;p=lttng-ust.git diff --git a/include/lttng/ust-events.h b/include/lttng/ust-events.h index 95af893a..b930a349 100644 --- a/include/lttng/ust-events.h +++ b/include/lttng/ust-events.h @@ -1,8 +1,8 @@ -#ifndef _UST_LTTNG_EVENTS_H -#define _UST_LTTNG_EVENTS_H +#ifndef _LTTNG_UST_EVENTS_H +#define _LTTNG_UST_EVENTS_H /* - * ust/lttng-events.h + * lttng/ust-events.h * * Copyright 2010 (c) - Mathieu Desnoyers * @@ -18,11 +18,23 @@ #include #include #include +#include struct ltt_channel; struct ltt_session; struct lttng_ust_lib_ring_buffer_ctx; +/* + * LTTng client type enumeration. Used by the consumer to map the + * callbacks from its own address space. + */ +enum lttng_client_types { + LTTNG_CLIENT_METADATA = 0, + LTTNG_CLIENT_DISCARD = 1, + LTTNG_CLIENT_OVERWRITE = 2, + LTTNG_NR_CLIENT_TYPES, +}; + /* Type description */ /* Update the astract_types name table in lttng-types.c along with this enum */ @@ -205,13 +217,13 @@ struct lttng_ust_shm_handle; struct ltt_channel_ops { struct ltt_channel *(*channel_create)(const char *name, - struct ltt_channel *ltt_chan, void *buf_addr, size_t subbuf_size, size_t num_subbuf, unsigned int switch_timer_interval, unsigned int read_timer_interval, int *shm_fd, int *wait_fd, - uint64_t *memory_map_size); + uint64_t *memory_map_size, + struct ltt_channel *chan_priv_init); void (*channel_destroy)(struct ltt_channel *ltt_chan); struct lttng_ust_lib_ring_buffer *(*buffer_read_open)(struct channel *chan, struct lttng_ust_shm_handle *handle, @@ -239,7 +251,12 @@ struct ltt_channel_ops { }; struct ltt_channel { - unsigned int id; + /* + * The pointers located in this private data are NOT safe to be + * dereferenced by the consumer. The only operations the + * consumer process is designed to be allowed to do is to read + * and perform subbuffer flush. + */ struct channel *chan; /* Channel buffers */ int enabled; struct lttng_ctx *ctx; @@ -253,6 +270,11 @@ struct ltt_channel { int header_type; /* 0: unset, 1: compact, 2: large */ struct lttng_ust_shm_handle *handle; /* shared-memory handle */ int metadata_dumped:1; + + /* Channel ID, available for consumer too */ + unsigned int id; + /* Copy of session UUID for consumer (availability through shm) */ + uuid_t uuid; /* Trace session unique ID */ }; struct ltt_session { @@ -274,6 +296,11 @@ struct ltt_transport { struct ltt_channel_ops ops; }; +struct ltt_tracepoint_list { + struct tracepoint_iter iter; + int got_first; +}; + struct ltt_session *ltt_session_create(void); int ltt_session_enable(struct ltt_session *session); int ltt_session_disable(struct ltt_session *session); @@ -286,7 +313,8 @@ struct ltt_channel *ltt_channel_create(struct ltt_session *session, unsigned int switch_timer_interval, unsigned int read_timer_interval, int *shm_fd, int *wait_fd, - uint64_t *memory_map_size); + uint64_t *memory_map_size, + struct ltt_channel *chan_priv_init); struct ltt_channel *ltt_global_channel_create(struct ltt_session *session, int overwrite, void *buf_addr, size_t subbuf_size, size_t num_subbuf, @@ -328,4 +356,10 @@ int lttng_add_procname_to_ctx(struct lttng_ctx **ctx); void lttng_context_vtid_reset(void); void lttng_context_vpid_reset(void); -#endif /* _UST_LTTNG_EVENTS_H */ +const struct lttng_ust_lib_ring_buffer_client_cb *lttng_client_callbacks_metadata; +const struct lttng_ust_lib_ring_buffer_client_cb *lttng_client_callbacks_discard; +const struct lttng_ust_lib_ring_buffer_client_cb *lttng_client_callbacks_overwrite; + +struct ltt_transport *ltt_transport_find(const char *name); + +#endif /* _LTTNG_UST_EVENTS_H */