X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fust-app.h;h=78381dd6c2b247730f9f5cc9fb88b757eedaad16;hb=45f862caefe6a5401f7d5989c38ccd51abdcf488;hp=f83e857cfae0f36b17e8fe4159a6e538cbbf9af9;hpb=68808f4e0bbb3adccff72ff9dab6ec9f3a9e6866;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/ust-app.h b/src/bin/lttng-sessiond/ust-app.h index f83e857cf..78381dd6c 100644 --- a/src/bin/lttng-sessiond/ust-app.h +++ b/src/bin/lttng-sessiond/ust-app.h @@ -22,7 +22,7 @@ #include -#include "jul.h" +#include "agent.h" #include "trace-ust.h" #include "ust-registry.h" @@ -183,6 +183,8 @@ struct ust_app_session { int started; /* allows detection of start vs restart. */ int handle; /* used has unique identifier for app session */ + bool deleted; /* Session deleted flag. Check with lock held. */ + /* * Tracing session ID. Multiple ust app session can have the same tracing * session id making this value NOT unique to the object. @@ -266,13 +268,14 @@ struct ust_app { * Hash table containing ust_app_channel indexed by channel objd. */ struct lttng_ht *ust_objd; + /* - * If this application is of the JUL domain and this is non negative then a - * lookup MUST be done to acquire a read side reference to the - * corresponding JUL app object. If the lookup fails, this should be set to - * a negative value indicating that the JUL application is gone. + * If this application is of the agent domain and this is non negative then + * a lookup MUST be done to acquire a read side reference to the + * corresponding agent app object. If the lookup fails, this should be set + * to a negative value indicating that the agent application is gone. */ - int jul_app_sock; + int agent_app_sock; }; #ifdef HAVE_LIBLTTNG_UST_CTL @@ -325,8 +328,10 @@ ssize_t ust_app_push_metadata(struct ust_registry_session *registry, struct consumer_socket *socket, int send_zero_data); void ust_app_destroy(struct ust_app *app); int ust_app_snapshot_record(struct ltt_ust_session *usess, - struct snapshot_output *output, int wait, uint64_t max_stream_size); -unsigned int ust_app_get_nb_stream(struct ltt_ust_session *usess); + struct snapshot_output *output, int wait, + uint64_t nb_packets_per_stream); +uint64_t ust_app_get_size_one_more_packet_per_stream( + struct ltt_ust_session *usess, uint64_t cur_nr_packets); struct ust_app *ust_app_find_by_sock(int sock); static inline @@ -535,6 +540,11 @@ struct ust_app *ust_app_find_by_pid(pid_t pid) { return NULL; } +static inline +uint64_t ust_app_get_size_one_more_packet_per_stream( + struct ltt_ust_session *usess, uint64_t cur_nr_packets) { + return 0; +} #endif /* HAVE_LIBLTTNG_UST_CTL */