#include <inttypes.h>
#include <pthread.h>
#include <urcu.h>
-#include <urcu/wfqueue.h>
+#include <urcu/wfcqueue.h>
#include <urcu/list.h>
#include <common/hashtable/hashtable.h>
struct lttcomm_sock *sock;
struct relay_session *session;
struct relay_viewer_session *viewer_session;
- struct cds_wfq_node qnode;
+ struct cds_wfcq_node qnode;
struct lttng_ht_node_ulong sock_n;
struct rcu_head rcu_node;
enum connection_type type;
uint32_t major;
uint32_t minor;
uint64_t session_id;
+
+ /*
+ * This contains streams that are received on that connection. It's used to
+ * store them until we get the streams sent command where they are removed
+ * and flagged ready for the viewer. This is ONLY used by the control
+ * thread thus any action on it should happen in that thread.
+ */
struct cds_list_head recv_head;
unsigned int version_check_done:1;