*/
#define _LGPL_SOURCE
-#include <common/common.h>
+#include <common/common.hpp>
#include <urcu/rculist.h>
-#include "connection.h"
-#include "stream.h"
-#include "viewer-session.h"
+#include "connection.hpp"
+#include "stream.hpp"
+#include "viewer-session.hpp"
bool connection_get(struct relay_connection *conn)
{
DBG2("Relay connection by sock %d not found", sock);
goto end;
}
- conn = caa_container_of(node, struct relay_connection, sock_n);
+ conn = lttng::utils::container_of(node, &relay_connection::sock_n);
if (!connection_get(conn)) {
conn = NULL;
}
{
struct relay_connection *conn;
- conn = (relay_connection *) zmalloc(sizeof(*conn));
+ conn = zmalloc<relay_connection>();
if (!conn) {
PERROR("zmalloc relay connection");
goto end;
static void rcu_free_connection(struct rcu_head *head)
{
struct relay_connection *conn =
- caa_container_of(head, struct relay_connection, rcu_node);
+ lttng::utils::container_of(head, &relay_connection::rcu_node);
lttcomm_destroy_sock(conn->sock);
if (conn->viewer_session) {
static void connection_release(struct urcu_ref *ref)
{
struct relay_connection *conn =
- caa_container_of(ref, struct relay_connection, ref);
+ lttng::utils::container_of(ref, &relay_connection::ref);
if (conn->in_socket_ht) {
struct lttng_ht_iter iter;