X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Flttng-relayd.h;fp=src%2Fbin%2Flttng-relayd%2Flttng-relayd.h;h=b5e7c75fdd4b901140c9ec91088791cd1b9f599b;hp=ab1ccd410e06773686f2bf6f3aefcc9c15ccb362;hb=80e8027abb847655ebe43b2b5aec1a5141bb9668;hpb=4a9daf1745ccbd2aab029206a664f39fcbd640ce

diff --git a/src/bin/lttng-relayd/lttng-relayd.h b/src/bin/lttng-relayd/lttng-relayd.h
index ab1ccd410..b5e7c75fd 100644
--- a/src/bin/lttng-relayd/lttng-relayd.h
+++ b/src/bin/lttng-relayd/lttng-relayd.h
@@ -88,6 +88,13 @@ struct relay_session {
 	 * viewer-side if new streams got added since the last check.
 	 */
 	unsigned long new_streams;
+
+	/*
+	 * Used to synchronize the process where we flag every streams readiness
+	 * for the viewer when the streams_sent message is received and the viewer
+	 * process of sending those streams.
+	 */
+	pthread_mutex_t viewer_ready_lock;
 };
 
 /*
@@ -208,6 +215,8 @@ struct relay_viewer_stream {
 	 * it sets this flag to inform that it is a normal error.
 	 */
 	unsigned int abort_flag:1;
+	/* Indicates if this stream has been sent to a viewer client. */
+	unsigned int sent_flag:1;
 };
 
 /*