X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fust-app.hpp;h=3200b654986596fb2eda518f96da35e2bccb097e;hp=c48e2b9e25b97f95e745b4cbd47d667583c0eb26;hb=9fdee7baa566d3424e0d4474d5b78aac08f4456d;hpb=11bcbf894cf92b99a2d885cad117db6811f164cb diff --git a/src/bin/lttng-sessiond/ust-app.hpp b/src/bin/lttng-sessiond/ust-app.hpp index c48e2b9e2..3200b6549 100644 --- a/src/bin/lttng-sessiond/ust-app.hpp +++ b/src/bin/lttng-sessiond/ust-app.hpp @@ -19,6 +19,7 @@ #include "ust-registry.hpp" #include "ust-registry-session.hpp" #include "session.hpp" +#include "ust-field-convert.hpp" #define UST_APP_EVENT_LIST_SIZE 32 @@ -105,7 +106,7 @@ struct ust_app_ctx { }; struct ust_app_event { - int enabled; + bool enabled; int handle; struct lttng_ust_abi_object_data *obj; struct lttng_ust_abi_event attr; @@ -116,7 +117,7 @@ struct ust_app_event { }; struct ust_app_event_notifier_rule { - int enabled; + bool enabled; uint64_t error_counter_index; int handle; struct lttng_ust_abi_object_data *obj; @@ -144,7 +145,7 @@ struct ust_app_stream { }; struct ust_app_channel { - int enabled; + bool enabled; int handle; /* * Unique key used to identify the channel on the consumer side. @@ -195,9 +196,9 @@ struct ust_app_session { */ pthread_mutex_t lock; - int enabled; + bool enabled; /* started: has the session been in started state at any time ? */ - int started; /* allows detection of start vs restart. */ + bool 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. */ @@ -248,9 +249,11 @@ struct ust_app_session { * and a linked list is kept of all running traceable app. */ struct ust_app { + /* Traffic initiated from the session daemon to the application. */ int sock; pthread_mutex_t sock_lock; /* Protects sock protocol. */ + /* Traffic initiated from the application to the session daemon. */ int notify_sock; pid_t pid; pid_t ppid; @@ -324,6 +327,8 @@ struct ust_app { * (ust_app_event_notifier_rule) by their token's value. */ struct lttng_ht *token_to_event_notifier_rule_ht; + + lttng::sessiond::ust::ctl_field_quirks ctl_field_quirks() const; }; /* @@ -333,8 +338,8 @@ struct ust_app { namespace fmt { template <> struct formatter : formatter { - template - typename FormatCtx::iterator format(const ust_app& app, FormatCtx& ctx) + template + typename FormatContextType::iterator format(const ust_app& app, FormatContextType& ctx) { return format_to(ctx.out(), "{{ procname = `{}`, ppid = {}, pid = {}, uid = {}, gid = {}, version = {}.{}, registration time = {} }}", @@ -371,12 +376,12 @@ int ust_app_add_ctx_channel_glb(struct ltt_ust_session *usess, void ust_app_global_update(struct ltt_ust_session *usess, struct ust_app *app); void ust_app_global_update_all(struct ltt_ust_session *usess); void ust_app_global_update_event_notifier_rules(struct ust_app *app); -void ust_app_global_update_all_event_notifier_rules(void); +void ust_app_global_update_all_event_notifier_rules(); -void ust_app_clean_list(void); -int ust_app_ht_alloc(void); +void ust_app_clean_list(); +int ust_app_ht_alloc(); struct ust_app *ust_app_find_by_pid(pid_t pid); -struct ust_app_stream *ust_app_alloc_stream(void); +struct ust_app_stream *ust_app_alloc_stream(); int ust_app_recv_registration(int sock, struct ust_register_msg *msg); int ust_app_recv_notify(int sock); void ust_app_add(struct ust_app *app); @@ -413,7 +418,7 @@ enum lttng_error_code ust_app_open_packets(struct ltt_session *session); int ust_app_setup_event_notifier_group(struct ust_app *app); static inline -int ust_app_supported(void) +int ust_app_supported() { return 1; }