X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fnotification-thread-internal.h;h=9e7059acf0708749828891870765448ba35e199a;hb=ca806b0b247f89c62ac628a7779ae84049a8c2d7;hp=0403527dca1f4f5b67d0f25cbe0cb91efee27eda;hpb=b9a8d78fefbc856370939d9eb553d6e9c1fcc86a;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/notification-thread-internal.h b/src/bin/lttng-sessiond/notification-thread-internal.h index 0403527dc..9e7059acf 100644 --- a/src/bin/lttng-sessiond/notification-thread-internal.h +++ b/src/bin/lttng-sessiond/notification-thread-internal.h @@ -82,6 +82,8 @@ struct channel_info { struct lttng_event_notifier_notification { uint64_t tracer_token; enum lttng_domain_type type; + size_t capture_buf_size; + char *capture_buffer; }; struct notification_client_list_element { @@ -111,8 +113,10 @@ struct notification_client_list_element { struct notification_client_list { pthread_mutex_t lock; struct urcu_ref ref; - const struct lttng_trigger *trigger; - struct cds_list_head list; + struct lttng_condition *condition; + /* List of triggers that have an identical condition than `condition`. */ + struct cds_list_head triggers_list; + struct cds_list_head clients_list; /* Weak reference to container. */ struct cds_lfht *notification_trigger_clients_ht; struct cds_lfht_node notification_trigger_clients_ht_node; @@ -138,6 +142,7 @@ struct notification_client { uint8_t major, minor; uid_t uid; gid_t gid; + bool is_sessiond; /* * Indicates if the credentials and versions of the client have been * checked. @@ -220,10 +225,8 @@ enum client_transmission_status { CLIENT_TRANSMISSION_STATUS_ERROR, }; -LTTNG_HIDDEN bool notification_client_list_get(struct notification_client_list *list); -LTTNG_HIDDEN void notification_client_list_put(struct notification_client_list *list); /* Only returns a non-zero value if a fatal error occurred. */ @@ -232,28 +235,28 @@ typedef int (*report_client_transmission_result_cb)( enum client_transmission_status status, void *user_data); -LTTNG_HIDDEN int notification_client_list_send_evaluation( struct notification_client_list *list, - const struct lttng_condition *condition, + const struct lttng_trigger *trigger, const struct lttng_evaluation *evaluation, - const struct lttng_credentials *trigger_creds, const struct lttng_credentials *source_object_creds, report_client_transmission_result_cb client_report, void *user_data); -LTTNG_HIDDEN int notification_thread_client_communication_update( struct notification_thread_handle *handle, notification_client_id id, enum client_transmission_status transmission_status); -LTTNG_HIDDEN +/* + * Takes ownership of the payload if present. + */ struct lttng_event_notifier_notification *lttng_event_notifier_notification_create( uint64_t tracer_token, - enum lttng_domain_type domain); + enum lttng_domain_type domain, + char *payload, + size_t payload_size); -LTTNG_HIDDEN void lttng_event_notifier_notification_destroy( struct lttng_event_notifier_notification *event_notifier_notification);