summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
03550b5)
Signed-off-by: Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
struct lttng_consumer_stream *stream;
DBG("Updating poll fd array");
struct lttng_consumer_stream *stream;
DBG("Updating poll fd array");
cds_lfht_for_each_entry(consumer_data.stream_ht->ht, &iter.iter, stream,
node.node) {
if (stream->state != LTTNG_CONSUMER_ACTIVE_STREAM) {
cds_lfht_for_each_entry(consumer_data.stream_ht->ht, &iter.iter, stream,
node.node) {
if (stream->state != LTTNG_CONSUMER_ACTIVE_STREAM) {
local_stream[i] = stream;
i++;
}
local_stream[i] = stream;
i++;
}
/*
* Insert the consumer_poll_pipe at the end of the array and don't
/*
* Insert the consumer_poll_pipe at the end of the array and don't