X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Fconsumer%2Fconsumer.hpp;h=9de8d05a3cb188b98c12e8c0c5ac1a476500591a;hb=75f62e5383c6ea1f62fb488a94f4a8f98400db71;hp=1efbc4eeeec33e6a57ebeb9748cf3d51f2e28907;hpb=28f23191dcbf047429d51950a337a57d7a3f866a;p=lttng-tools.git

diff --git a/src/common/consumer/consumer.hpp b/src/common/consumer/consumer.hpp
index 1efbc4eee..9de8d05a3 100644
--- a/src/common/consumer/consumer.hpp
+++ b/src/common/consumer/consumer.hpp
@@ -12,7 +12,6 @@
 #define LIB_CONSUMER_H
 
 #include <common/buffer-view.hpp>
-#include <common/compat/fcntl.hpp>
 #include <common/credentials.hpp>
 #include <common/dynamic-array.hpp>
 #include <common/hashtable/hashtable.hpp>
@@ -21,6 +20,7 @@
 #include <common/sessiond-comm/sessiond-comm.hpp>
 #include <common/trace-chunk-registry.hpp>
 #include <common/uuid.hpp>
+#include <common/waiter.hpp>
 
 #include <lttng/lttng.h>
 
@@ -185,6 +185,11 @@ struct lttng_consumer_channel {
 	/* Metadata cache is metadata channel */
 	struct consumer_metadata_cache *metadata_cache;
 
+	/*
+	 * Wait queue awaiting updates to metadata stream's flushed position.
+	 */
+	struct lttng_wait_queue metadata_pushed_wait_queue;
+
 	/* For UST metadata periodical flush */
 	int switch_timer_enabled;
 	timer_t switch_timer;