X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fagent.h;h=3dbf7179aa8547e28a3c7d5351896a5ced24b17b;hp=404365e0a5e4051e595788e1a72a71952c419c2a;hb=fefd409b002735b415c5f653cdb2587be454f145;hpb=022d91ba14053d6093a6d6a1af02a345c6fd42d2 diff --git a/src/bin/lttng-sessiond/agent.h b/src/bin/lttng-sessiond/agent.h index 404365e0a..3dbf7179a 100644 --- a/src/bin/lttng-sessiond/agent.h +++ b/src/bin/lttng-sessiond/agent.h @@ -40,6 +40,8 @@ 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; }; @@ -54,6 +56,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 +100,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 +116,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 +133,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,8 +142,10 @@ 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);