*/
consumer_stream_destroy(metadata->metadata_stream, nullptr);
metadata->metadata_stream = nullptr;
- lttng_wait_queue_wake_all(&metadata->metadata_pushed_wait_queue);
+ metadata->metadata_pushed_wait_queue.wake_all();
send_streams_error:
error_no_stream:
*/
consumer_stream_destroy(metadata_stream, nullptr);
metadata_channel->metadata_stream = nullptr;
- lttng_wait_queue_wake_all(&metadata_channel->metadata_pushed_wait_queue);
+ metadata_channel->metadata_pushed_wait_queue.wake_all();
error:
return ret;
ret = write_len;
goto end;
}
+
stream->ust_metadata_pushed += write_len;
- lttng_wait_queue_wake_all(&stream->chan->metadata_pushed_wait_queue);
+ stream->chan->metadata_pushed_wait_queue.wake_all();
LTTNG_ASSERT(stream->chan->metadata_cache->contents.size >= stream->ust_metadata_pushed);
ret = write_len;