X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fconsumer-metadata-cache.h;h=aaf9f24d2a5a978b4c0024d290be86910a1ae0df;hp=164f9eaae0689d68262e007278bbfc82a3a7d6ac;hb=24bc0841bdd3fb38b76a9244d21f28000d653fcf;hpb=331744e34f56a5aec69b05d356d6901e67926acc diff --git a/src/common/consumer-metadata-cache.h b/src/common/consumer-metadata-cache.h index 164f9eaae..aaf9f24d2 100644 --- a/src/common/consumer-metadata-cache.h +++ b/src/common/consumer-metadata-cache.h @@ -25,9 +25,9 @@ struct consumer_metadata_cache { char *data; uint64_t cache_alloc_size; /* - * How many bytes from the cache were already sent to the ring buffer. + * How many bytes from the cache are written contiguously. */ - uint64_t rb_pushed; + uint64_t contiguous; /* * How many bytes are written in the buffer (excluding the wholes). */ @@ -43,6 +43,8 @@ struct consumer_metadata_cache { /* * Lock to update the metadata cache and push into the ring_buffer * (ustctl_write_metadata_to_channel). + * + * This is nested INSIDE the consumer_data lock. */ pthread_mutex_t lock; }; @@ -52,6 +54,6 @@ int consumer_metadata_cache_write(struct lttng_consumer_channel *channel, 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); + uint64_t offset, int timer); #endif /* CONSUMER_METADATA_CACHE_H */