X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer.c;h=f47d8de1b2669665a4a138a8b0fcbcdb65dc3b3d;hp=341f8a7fe4ecf29a570b0d577156385242d64012;hb=a4baae1b0463bc4ce65c2a458c4a941e7fabc594;hpb=8966b2b03f62a03e132f504853e9699152e9399b

diff --git a/src/common/consumer.c b/src/common/consumer.c
index 341f8a7fe..f47d8de1b 100644
--- a/src/common/consumer.c
+++ b/src/common/consumer.c
@@ -768,6 +768,44 @@ end:
 	return ret;
 }
 
+/*
+ * Find a relayd and send the streams sent message
+ *
+ * Returns 0 on success, < 0 on error
+ */
+int consumer_send_relayd_streams_sent(uint64_t net_seq_idx)
+{
+	int ret = 0;
+	struct consumer_relayd_sock_pair *relayd;
+
+	assert(net_seq_idx != -1ULL);
+
+	/* The stream is not metadata. Get relayd reference if exists. */
+	rcu_read_lock();
+	relayd = consumer_find_relayd(net_seq_idx);
+	if (relayd != NULL) {
+		/* Add stream on the relayd */
+		pthread_mutex_lock(&relayd->ctrl_sock_mutex);
+		ret = relayd_streams_sent(&relayd->control_sock);
+		pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
+		if (ret < 0) {
+			goto end;
+		}
+	} else {
+		ERR("Relayd ID %" PRIu64 " unknown. Can't send streams_sent.",
+				net_seq_idx);
+		ret = -1;
+		goto end;
+	}
+
+	ret = 0;
+	DBG("All streams sent relayd id %" PRIu64, net_seq_idx);
+
+end:
+	rcu_read_unlock();
+	return ret;
+}
+
 /*
  * Find a relayd and close the stream
  */