X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fcommon%2Fust-consumer%2Fust-consumer.c;h=5bcca4e17a3d94622f423d8a30e410e05473d741;hp=4f374f030a9ed1f061a021b8836c4c1c250488ff;hb=b8086166dbf40d53a4a1e3f0cddbf291fac97bd3;hpb=850767541647c102a299d7fbc39c97555ac70224 diff --git a/src/common/ust-consumer/ust-consumer.c b/src/common/ust-consumer/ust-consumer.c index 4f374f030..5bcca4e17 100644 --- a/src/common/ust-consumer/ust-consumer.c +++ b/src/common/ust-consumer/ust-consumer.c @@ -579,7 +579,7 @@ static int flush_channel(uint64_t chan_key) cds_lfht_for_each_entry_duplicate(ht->ht, ht->hash_fct(&channel->key, lttng_ht_seed), ht->match_fct, &channel->key, &iter.iter, stream, node_channel_id.node) { - ustctl_flush_buffer(stream->ustream, 1); + ustctl_flush_buffer(stream->ustream, 1); } error: rcu_read_unlock(); @@ -1568,8 +1568,6 @@ int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream, DBG("In UST read_subbuffer (wait_fd: %d, name: %s)", stream->wait_fd, stream->name); - sleep(1); - /* Ease our life for what's next. */ ustream = stream->ustream;