newsock = accept_relayd_sock(data_sock,
"Data socket to relayd");
} else {
newsock = accept_relayd_sock(data_sock,
"Data socket to relayd");
} else {
type = RELAY_CONTROL;
newsock = accept_relayd_sock(control_sock,
"Control socket to relayd");
type = RELAY_CONTROL;
newsock = accept_relayd_sock(control_sock,
"Control socket to relayd");
chunk_status = lttng_trace_chunk_set_as_owner(chunk,
conn->session->output_directory);
if (chunk_status != LTTNG_TRACE_CHUNK_STATUS_OK) {
chunk_status = lttng_trace_chunk_set_as_owner(chunk,
conn->session->output_directory);
if (chunk_status != LTTNG_TRACE_CHUNK_STATUS_OK) {
ret = conn->sock->ops->recvmsg(conn->sock,
reception_buffer->data + state->received,
ret = conn->sock->ops->recvmsg(conn->sock,
reception_buffer->data + state->received,
ret = conn->sock->ops->recvmsg(conn->sock,
state->header_reception_buffer + state->received,
ret = conn->sock->ops->recvmsg(conn->sock,
state->header_reception_buffer + state->received,
ctrl_conn = connection_get_by_sock(relay_connections_ht, pollfd);
/* If not found, there is a synchronization issue. */
ctrl_conn = connection_get_by_sock(relay_connections_ht, pollfd);
/* If not found, there is a synchronization issue. */