Remove LTTNG_EVENT_RULE_TYPE_KERNEL_FUNCTION
[lttng-tools.git] / src / bin / lttng-relayd / connection.c
CommitLineData
58eb9381 1/*
ab5be9fa
MJ
2 * Copyright (C) 2013 Julien Desfossez <jdesfossez@efficios.com>
3 * Copyright (C) 2013 David Goulet <dgoulet@efficios.com>
4 * Copyright (C) 2015 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
58eb9381 5 *
ab5be9fa 6 * SPDX-License-Identifier: GPL-2.0-only
58eb9381 7 *
58eb9381
DG
8 */
9
6c1c0768 10#define _LGPL_SOURCE
58eb9381 11#include <common/common.h>
7591bab1 12#include <urcu/rculist.h>
58eb9381
DG
13
14#include "connection.h"
15#include "stream.h"
7591bab1 16#include "viewer-session.h"
58eb9381 17
7591bab1 18bool connection_get(struct relay_connection *conn)
58eb9381 19{
ce4d4083 20 return urcu_ref_get_unless_zero(&conn->ref);
58eb9381
DG
21}
22
7591bab1
MD
23struct relay_connection *connection_get_by_sock(struct lttng_ht *relay_connections_ht,
24 int sock)
58eb9381
DG
25{
26 struct lttng_ht_node_ulong *node;
27 struct lttng_ht_iter iter;
28 struct relay_connection *conn = NULL;
29
58eb9381
DG
30 assert(sock >= 0);
31
7591bab1
MD
32 rcu_read_lock();
33 lttng_ht_lookup(relay_connections_ht, (void *)((unsigned long) sock),
34 &iter);
58eb9381
DG
35 node = lttng_ht_iter_get_node_ulong(&iter);
36 if (!node) {
37 DBG2("Relay connection by sock %d not found", sock);
38 goto end;
39 }
40 conn = caa_container_of(node, struct relay_connection, sock_n);
7591bab1
MD
41 if (!connection_get(conn)) {
42 conn = NULL;
43 }
58eb9381 44end:
7591bab1 45 rcu_read_unlock();
58eb9381
DG
46 return conn;
47}
48
5312a3ed
JG
49int connection_reset_protocol_state(struct relay_connection *connection)
50{
51 int ret = 0;
52
53 switch (connection->type) {
54 case RELAY_DATA:
55 connection->protocol.data.state_id =
56 DATA_CONNECTION_STATE_RECEIVE_HEADER;
57 memset(&connection->protocol.data.state.receive_header,
58 0,
59 sizeof(connection->protocol.data.state.receive_header));
60 connection->protocol.data.state.receive_header.left_to_receive =
61 sizeof(struct lttcomm_relayd_data_hdr);
62 break;
63 case RELAY_CONTROL:
64 connection->protocol.ctrl.state_id =
65 CTRL_CONNECTION_STATE_RECEIVE_HEADER;
66 memset(&connection->protocol.ctrl.state.receive_header,
67 0,
68 sizeof(connection->protocol.ctrl.state.receive_header));
69 connection->protocol.data.state.receive_header.left_to_receive =
70 sizeof(struct lttcomm_relayd_hdr);
71 ret = lttng_dynamic_buffer_set_size(
72 &connection->protocol.ctrl.reception_buffer,
73 sizeof(struct lttcomm_relayd_hdr));
74 if (ret) {
75 ERR("Failed to reinitialize control connection reception buffer size to %zu bytes.", sizeof(struct lttcomm_relayd_hdr));
76 goto end;
77 }
78 break;
79 default:
80 goto end;
81 }
82 DBG("Reset communication state of relay connection (fd = %i)",
83 connection->sock->fd);
84end:
85 return ret;
86}
87
7591bab1
MD
88struct relay_connection *connection_create(struct lttcomm_sock *sock,
89 enum connection_type type)
58eb9381 90{
7591bab1 91 struct relay_connection *conn;
58eb9381 92
7591bab1
MD
93 conn = zmalloc(sizeof(*conn));
94 if (!conn) {
95 PERROR("zmalloc relay connection");
96 goto end;
97 }
7591bab1
MD
98 urcu_ref_init(&conn->ref);
99 conn->type = type;
100 conn->sock = sock;
101 lttng_ht_node_init_ulong(&conn->sock_n, (unsigned long) conn->sock->fd);
5312a3ed
JG
102 if (conn->type == RELAY_CONTROL) {
103 lttng_dynamic_buffer_init(&conn->protocol.ctrl.reception_buffer);
104 }
105 connection_reset_protocol_state(conn);
7591bab1
MD
106end:
107 return conn;
58eb9381
DG
108}
109
7591bab1 110static void rcu_free_connection(struct rcu_head *head)
58eb9381 111{
7591bab1
MD
112 struct relay_connection *conn =
113 caa_container_of(head, struct relay_connection, rcu_node);
58eb9381 114
7591bab1
MD
115 lttcomm_destroy_sock(conn->sock);
116 if (conn->viewer_session) {
117 viewer_session_destroy(conn->viewer_session);
118 conn->viewer_session = NULL;
119 }
35be817a
JG
120 if (conn->type == RELAY_CONTROL) {
121 lttng_dynamic_buffer_reset(
122 &conn->protocol.ctrl.reception_buffer);
123 }
7591bab1
MD
124 free(conn);
125}
126
127static void destroy_connection(struct relay_connection *conn)
128{
58eb9381
DG
129 call_rcu(&conn->rcu_node, rcu_free_connection);
130}
131
7591bab1 132static void connection_release(struct urcu_ref *ref)
58eb9381 133{
7591bab1
MD
134 struct relay_connection *conn =
135 caa_container_of(ref, struct relay_connection, ref);
58eb9381 136
7591bab1
MD
137 if (conn->in_socket_ht) {
138 struct lttng_ht_iter iter;
139 int ret;
140
141 iter.iter.node = &conn->sock_n.node;
142 ret = lttng_ht_del(conn->socket_ht, &iter);
143 assert(!ret);
58eb9381
DG
144 }
145
7591bab1
MD
146 if (conn->session) {
147 if (session_close(conn->session)) {
148 ERR("session_close");
149 }
150 conn->session = NULL;
151 }
152 if (conn->viewer_session) {
153 viewer_session_close(conn->viewer_session);
154 }
155 destroy_connection(conn);
58eb9381
DG
156}
157
7591bab1 158void connection_put(struct relay_connection *conn)
58eb9381 159{
7591bab1 160 rcu_read_lock();
7591bab1 161 urcu_ref_put(&conn->ref, connection_release);
7591bab1 162 rcu_read_unlock();
58eb9381
DG
163}
164
7591bab1
MD
165void connection_ht_add(struct lttng_ht *relay_connections_ht,
166 struct relay_connection *conn)
58eb9381 167{
7591bab1
MD
168 assert(!conn->in_socket_ht);
169 lttng_ht_add_unique_ulong(relay_connections_ht, &conn->sock_n);
170 conn->in_socket_ht = 1;
171 conn->socket_ht = relay_connections_ht;
58eb9381 172}
fd0f1e3e
JR
173
174int connection_set_session(struct relay_connection *conn,
175 struct relay_session *session)
176{
177 int ret = 0;
178
179 assert(conn);
180 assert(session);
181 assert(!conn->session);
182
183 if (connection_get(conn)) {
184 if (session_get(session)) {
185 conn->session = session;
186 } else {
187 ERR("Failed to get session reference in connection_set_session()");
188 ret = -1;
189 }
190 connection_put(conn);
191 } else {
192 ERR("Failed to get connection reference in connection_set_session()");
193 ret = -1;
194 }
195 return ret;
196}
This page took 0.05267 seconds and 4 git commands to generate.