X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fsession.h;h=b8c7890810ab966d23860805cabfff5be62426e9;hb=36e6632013ee40eabfbe50db19ebd8e606ba0204;hp=3c9bc182489cdcb8537e7c5d9af31fe6c59d4233;hpb=d68c9a04537b683991a7355b812b0af954008cf1;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/session.h b/src/bin/lttng-sessiond/session.h index 3c9bc1824..b8c789081 100644 --- a/src/bin/lttng-sessiond/session.h +++ b/src/bin/lttng-sessiond/session.h @@ -27,6 +27,7 @@ #include "snapshot.h" #include "trace-kernel.h" +#include "consumer.h" struct ltt_ust_session; @@ -173,6 +174,12 @@ struct ltt_session { */ bool rotate_relay_pending_timer_enabled; timer_t rotate_relay_pending_timer; + /* Timer to periodically rotate a session. */ + bool rotate_timer_enabled; + timer_t rotate_timer; + uint64_t rotate_timer_period; + /* Value for size-based rotation, 0 if disabled. */ + uint64_t rotate_size; /* * Keep a state if this session was rotated after the last stop command. * We only allow one rotation after a stop. At destroy, we also need to @@ -180,6 +187,11 @@ struct ltt_session { * chunk. */ bool rotated_after_last_stop; + /* + * Condition and trigger for size-based rotations. + */ + struct lttng_condition *rotate_condition; + struct lttng_trigger *rotate_trigger; }; /* Prototypes */ @@ -191,6 +203,14 @@ void session_lock_list(void); void session_unlock(struct ltt_session *session); void session_unlock_list(void); +enum consumer_dst_type session_get_consumer_destination_type( + const struct ltt_session *session); +const char *session_get_net_consumer_hostname( + const struct ltt_session *session); +void session_get_net_consumer_ports( + const struct ltt_session *session, + uint16_t *control_port, uint16_t *data_port); + struct ltt_session *session_find_by_name(const char *name); struct ltt_session *session_find_by_id(uint64_t id); struct ltt_session_list *session_get_list(void);