X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fagent-thread.c;h=ddc6c7e62aeab3c5e058b0ddd0225eb76ffc1d1d;hp=2439b3e28ec0fe73c54c08be3d32b3c7c70af005;hb=7eac7803;hpb=427392b43cfe21d440808494f87564fc0224dd70 diff --git a/src/bin/lttng-sessiond/agent-thread.c b/src/bin/lttng-sessiond/agent-thread.c index 2439b3e28..ddc6c7e62 100644 --- a/src/bin/lttng-sessiond/agent-thread.c +++ b/src/bin/lttng-sessiond/agent-thread.c @@ -88,8 +88,8 @@ static struct lttcomm_sock *init_tcp_socket(void) */ ret = uri_parse(default_reg_uri, &uri); assert(ret); - assert(agent_tcp_port); - uri->port = agent_tcp_port; + assert(config.agent_tcp_port); + uri->port = config.agent_tcp_port; sock = lttcomm_alloc_sock_from_uri(uri); uri_free(uri); @@ -116,7 +116,7 @@ static struct lttcomm_sock *init_tcp_socket(void) } DBG("[agent-thread] Listening on TCP port %u and socket %d", - agent_tcp_port, sock->fd); + config.agent_tcp_port, sock->fd); return sock; @@ -134,7 +134,7 @@ static void destroy_tcp_socket(struct lttcomm_sock *sock) { assert(sock); - DBG3("[agent-thread] Destroy TCP socket on port %u", agent_tcp_port); + DBG3("[agent-thread] Destroy TCP socket on port %u", config.agent_tcp_port); /* This will return gracefully if fd is invalid. */ sock->ops->close(sock); @@ -248,6 +248,7 @@ void *agent_thread_manage_registration(void *data) } reg_sock = init_tcp_socket(); + sessiond_notify_ready(); if (!reg_sock) { goto error_tcp_socket; }