projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: consumer should await for initial streams
[lttng-tools.git]
/
src
/
common
/
consumer.h
diff --git
a/src/common/consumer.h
b/src/common/consumer.h
index dba7765772859bd703adb5ba9e0889759d5fb757..0f82a10865f18b2960900db6e937b3768618d1d0 100644
(file)
--- a/
src/common/consumer.h
+++ b/
src/common/consumer.h
@@
-77,6
+77,12
@@
struct lttng_consumer_channel {
int key;
uint64_t max_sb_size; /* the subbuffer size for this channel */
int refcount; /* Number of streams referencing this channel */
int key;
uint64_t max_sb_size; /* the subbuffer size for this channel */
int refcount; /* Number of streams referencing this channel */
+ /*
+ * The number of streams to receive initially. Used to guarantee that we do
+ * not destroy a channel before receiving all its associated streams.
+ */
+ unsigned int nb_init_streams;
+
/* For UST */
int shm_fd;
int wait_fd;
/* For UST */
int shm_fd;
int wait_fd;
@@
-342,7
+348,8
@@
extern struct lttng_consumer_channel *consumer_allocate_channel(
int channel_key,
int shm_fd, int wait_fd,
uint64_t mmap_len,
int channel_key,
int shm_fd, int wait_fd,
uint64_t mmap_len,
- uint64_t max_sb_size);
+ uint64_t max_sb_size,
+ unsigned int nb_init_streams);
int consumer_add_channel(struct lttng_consumer_channel *channel);
/* lttng-relayd consumer command */
int consumer_add_channel(struct lttng_consumer_channel *channel);
/* lttng-relayd consumer command */
This page took
0.024448 seconds
and
4
git commands to generate.