X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fagent.h;h=6564b88c84f6e260d1f875074d6bb313fa4b73aa;hb=a9ad0c8fb50ac8cf9e9812dd9c9b4f949bac19a8;hp=404365e0a5e4051e595788e1a72a71952c419c2a;hpb=022d91ba14053d6093a6d6a1af02a345c6fd42d2;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/agent.h b/src/bin/lttng-sessiond/agent.h index 404365e0a..6564b88c8 100644 --- a/src/bin/lttng-sessiond/agent.h +++ b/src/bin/lttng-sessiond/agent.h @@ -24,6 +24,10 @@ #include #include +/* Agent protocol version that is verified during the agent registration. */ +#define AGENT_MAJOR_VERSION 1 +#define AGENT_MINOR_VERSION 0 + /* * Hash table that contains the agent app created upon registration indexed by * socket. @@ -40,7 +44,11 @@ struct agent_ht_key { * find back the corresponding UST app object so both socket can be linked. */ struct agent_register_msg { + /* This maps to a lttng_domain_type. */ + uint32_t domain; uint32_t pid; + uint32_t major_version; + uint32_t minor_version; }; /* @@ -54,6 +62,9 @@ struct agent_app { */ pid_t pid; + /* Domain of the application. */ + enum lttng_domain_type domain; + /* * AGENT TCP socket that was created upon registration. */ @@ -95,8 +106,15 @@ struct agent { * actually enabled. */ unsigned int being_used:1; + + /* What domain this agent is. */ + enum lttng_domain_type domain; + /* Contains event indexed by name. */ struct lttng_ht *events; + + /* Node used for the hash table indexed by domain type. */ + struct lttng_ht_node_u64 node; }; /* Setup agent subsystem. */ @@ -104,7 +122,9 @@ int agent_setup(void); /* Initialize an already allocated agent domain. */ int agent_init(struct agent *agt); +struct agent *agent_create(enum lttng_domain_type domain); void agent_destroy(struct agent *agt); +void agent_add(struct agent *agt, struct lttng_ht *ht); /* Agent event API. */ struct agent_event *agent_create_event(const char *name, @@ -119,7 +139,8 @@ void agent_delete_event(struct agent_event *event, struct agent *agt); void agent_destroy_event(struct agent_event *event); /* Agent app API. */ -struct agent_app *agent_create_app(pid_t pid, struct lttcomm_sock *sock); +struct agent_app *agent_create_app(pid_t pid, enum lttng_domain_type domain, + struct lttcomm_sock *sock); void agent_add_app(struct agent_app *app); void agent_delete_app(struct agent_app *app); struct agent_app *agent_find_app_by_sock(int sock); @@ -127,9 +148,12 @@ void agent_destroy_app(struct agent_app *app); int agent_send_registration_done(struct agent_app *app); /* Agent action API */ -int agent_enable_event(struct agent_event *event); -int agent_disable_event(struct agent_event *event); +int agent_enable_event(struct agent_event *event, + enum lttng_domain_type domain); +int agent_disable_event(struct agent_event *event, + enum lttng_domain_type domain); void agent_update(struct agent *agt, int sock); -int agent_list_events(struct lttng_event **events); +int agent_list_events(struct lttng_event **events, + enum lttng_domain_type domain); #endif /* LTTNG_SESSIOND_AGENT_H */