X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fust-registry.h;h=0cba8a334e54609df98d5e615662d68a73654c70;hb=dc2bbdaea73908117fdccc5e8247b613bd3b8600;hp=3c46984a30f024a27df1d8d04a60d69aa4b44a03;hpb=36b588eddce05ef840bd247f6a58316925b9a0a2;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/ust-registry.h b/src/bin/lttng-sessiond/ust-registry.h index 3c46984a3..0cba8a334 100644 --- a/src/bin/lttng-sessiond/ust-registry.h +++ b/src/bin/lttng-sessiond/ust-registry.h @@ -33,8 +33,12 @@ struct ust_app; struct ust_registry_session { /* - * With multiple writers and readers, use this lock to access the registry. - * Can nest within the ust app session lock. + * With multiple writers and readers, use this lock to access + * the registry. Can nest within the ust app session lock. + * Also acts as a registry serialization lock. Used by registry + * readers to serialize the registry information sent from the + * sessiond to the consumerd. + * The consumer socket lock nests within this lock. */ pthread_mutex_t lock; /* Next channel ID available for a newly registered channel. */ @@ -63,11 +67,13 @@ struct ust_registry_session { /* Length of bytes sent to the consumer. */ size_t metadata_len_sent; /* - * Hash table containing channels sent by the UST tracer. MUST be accessed - * with a RCU read side lock acquired. + * Hash table containing channels sent by the UST tracer. MUST + * be accessed with a RCU read side lock acquired. */ struct lttng_ht *channels; - /* Unique key to identify the metadata on the consumer side. */ + /* + * Unique key to identify the metadata on the consumer side. + */ uint64_t metadata_key; /* * Indicates if the metadata is closed on the consumer side. This is to @@ -127,7 +133,6 @@ struct ust_registry_event { size_t nr_fields; struct ustctl_field *fields; char *model_emf_uri; - struct lttng_ust_object_data *obj; /* * Flag for this channel if the metadata was dumped once during * registration. 0 means no, 1 yes. @@ -226,7 +231,8 @@ void ust_registry_session_destroy(struct ust_registry_session *session); int ust_registry_create_event(struct ust_registry_session *session, uint64_t chan_key, int session_objd, int channel_objd, char *name, char *sig, size_t nr_fields, struct ustctl_field *fields, int loglevel, - char *model_emf_uri, int buffer_type, uint32_t *event_id_p); + char *model_emf_uri, int buffer_type, uint32_t *event_id_p, + struct ust_app *app); struct ust_registry_event *ust_registry_find_event( struct ust_registry_channel *chan, char *name, char *sig); void ust_registry_destroy_event(struct ust_registry_channel *chan,