pthread_mutex_lock(&stream->lock);
if (!stream->quiescent) {
- ustctl_flush_buffer(stream->ustream, 0);
+ lttng_ustconsumer_flush_buffer(stream, 0);
stream->quiescent = true;
}
pthread_mutex_unlock(&stream->lock);
* Else, if quiescent, it has already been done by the prior stop.
*/
if (!stream->quiescent) {
- ustctl_flush_buffer(stream->ustream, 0);
+ lttng_ustconsumer_flush_buffer(stream, 0);
}
ret = lttng_ustconsumer_take_snapshot(stream);
return ustctl_get_mmap_base(stream->ustream);
}
-void lttng_ustctl_flush_buffer(struct lttng_consumer_stream *stream,
- int producer_active)
-{
- assert(stream);
- assert(stream->ustream);
-
- ustctl_flush_buffer(stream->ustream, producer_active);
-}
-
/*
* Take a snapshot for a specific stream.
*
pthread_mutex_lock(&stream->lock);
if (!stream->quiescent) {
- ustctl_flush_buffer(stream->ustream, 0);
+ lttng_ustconsumer_flush_buffer(stream, 0);
stream->quiescent = true;
}
pthread_mutex_unlock(&stream->lock);
retry = 1;
}
- ustctl_flush_buffer(metadata->ustream, 1);
+ lttng_ustconsumer_flush_buffer(metadata, 1);
ret = ustctl_snapshot(metadata->ustream);
if (ret < 0) {
if (errno != EAGAIN) {
if (ret <= 0) {
goto error;
}
- ustctl_flush_buffer(stream->ustream, 1);
+ lttng_ustconsumer_flush_buffer(stream, 1);
goto retry;
}