summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
09b72f7)
Signed-off-by: Jonathan Rajotte <jonathan.rajotte-julien@efficios.com>
break;
case LTTNG_CONSUMER32_UST:
case LTTNG_CONSUMER64_UST:
break;
case LTTNG_CONSUMER32_UST:
case LTTNG_CONSUMER64_UST:
- lttng_ustctl_flush_buffer(stream, producer_active);
+ lttng_ustconsumer_flush_buffer(stream, producer_active);
break;
default:
ERR("Unknown consumer_data type");
break;
default:
ERR("Unknown consumer_data type");
pthread_mutex_lock(&stream->lock);
if (!stream->quiescent) {
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);
stream->quiescent = true;
}
pthread_mutex_unlock(&stream->lock);
* Else, if quiescent, it has already been done by the prior stop.
*/
if (!stream->quiescent) {
* 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);
}
ret = lttng_ustconsumer_take_snapshot(stream);
return ustctl_get_mmap_base(stream->ustream);
}
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.
*
/*
* Take a snapshot for a specific stream.
*
pthread_mutex_lock(&stream->lock);
if (!stream->quiescent) {
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);
stream->quiescent = true;
}
pthread_mutex_unlock(&stream->lock);
- ustctl_flush_buffer(metadata->ustream, 1);
+ lttng_ustconsumer_flush_buffer(metadata, 1);
ret = ustctl_snapshot(metadata->ustream);
if (ret < 0) {
if (errno != EAGAIN) {
ret = ustctl_snapshot(metadata->ustream);
if (ret < 0) {
if (errno != EAGAIN) {
if (ret <= 0) {
goto error;
}
if (ret <= 0) {
goto error;
}
- ustctl_flush_buffer(stream->ustream, 1);
+ lttng_ustconsumer_flush_buffer(stream, 1);
int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
unsigned long *off);
void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream);
int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
unsigned long *off);
void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream);
-void lttng_ustctl_flush_buffer(struct lttng_consumer_stream *stream,
- int producer_active);
int lttng_ustconsumer_get_stream_id(struct lttng_consumer_stream *stream,
uint64_t *stream_id);
int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream);
int lttng_ustconsumer_get_stream_id(struct lttng_consumer_stream *stream,
uint64_t *stream_id);
int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream);
return NULL;
}
static inline
return NULL;
}
static inline
-void lttng_ustctl_flush_buffer(struct lttng_consumer_stream *stream,
- int producer_active)
-{
-}
-static inline
void lttng_ustconsumer_close_all_metadata(struct lttng_ht *ht)
{
}
void lttng_ustconsumer_close_all_metadata(struct lttng_ht *ht)
{
}