struct consumer_metadata_cache {
char *data;
uint64_t cache_alloc_size;
+ /*
+ * Current version of the metadata cache.
+ */
+ uint64_t version;
/*
* The upper-limit of data written inside the buffer.
*
};
int consumer_metadata_cache_write(struct lttng_consumer_channel *channel,
- unsigned int offset, unsigned int len, char *data);
+ unsigned int offset, unsigned int len, uint64_t version,
+ char *data);
int consumer_metadata_cache_allocate(struct lttng_consumer_channel *channel);
void consumer_metadata_cache_destroy(struct lttng_consumer_channel *channel);
int consumer_metadata_cache_flushed(struct lttng_consumer_channel *channel,
uint64_t offset, int timer);
+int consumer_metadata_wakeup_pipe(const struct lttng_consumer_channel *channel);
#endif /* CONSUMER_METADATA_CACHE_H */