* - metadata_socket_lock
* - Calling lttng_ustconsumer_recv_metadata():
* - channel->metadata_cache->lock
- * - Calling consumer_metadata_cache_flushed():
+ * - Calling consumer_wait_metadata_cache_flushed():
* - channel->timer_lock
* - channel->metadata_cache->lock
*
* they are held while consumer_timer_switch_stop() is
* called.
*/
- ret = lttng_ustconsumer_request_metadata(ctx, channel, 1, 1);
+ ret = lttng_ustconsumer_request_metadata(ctx, channel, true, 1);
if (ret < 0) {
channel->switch_timer_error = 1;
}
ret = consumer_channel_timer_stop(&channel->monitor_timer, LTTNG_CONSUMER_SIG_MONITOR);
if (ret == -1) {
- ERR("Failed to stop live timer");
+ ERR("Failed to stop monitor timer");
goto end;
}
msg.highest = highest;
msg.lowest = lowest;
- msg.consumed_since_last_sample = total_consumed - channel->last_consumed_size_sample_sent;
+ msg.consumed_since_last_sample =
+ total_consumed - channel->consumed_size_as_of_last_sample_sent;
/*
* Writes performed here are assumed to be atomic which is only
channel->key,
msg.highest,
msg.lowest);
- channel->last_consumed_size_sample_sent = msg.consumed_since_last_sample;
+ channel->consumed_size_as_of_last_sample_sent = total_consumed;
}
}