#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>
#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>
/* 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;