Fix: handle new streams in live mode in relayd

[lttng-tools.git] / src / bin / lttng-relayd / lttng-relayd.h

diff --git a/src/bin/lttng-relayd/lttng-relayd.h b/src/bin/lttng-relayd/lttng-relayd.h
index ab1ccd410e06773686f2bf6f3aefcc9c15ccb362..b5e7c75fdd4b901140c9ec91088791cd1b9f599b 100644 (file)
--- 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;
 };
 
 /*