uint64_t relayd_id;
bool chunk_exists_on_peer = false;
enum lttng_trace_chunk_status chunk_status;
- lttng::urcu::read_lock_guard read_lock;
+ const lttng::urcu::read_lock_guard read_lock;
LTTNG_ASSERT(session->chunk_being_archived);
-1ULL :
session->ust_session->consumer->net_seq_index;
- lttng::pthread::lock_guard socket_lock(*socket->lock);
+ const lttng::pthread::lock_guard socket_lock(*socket->lock);
ret = consumer_trace_chunk_exists(socket,
relayd_id,
session->id,
cds_lfht_for_each_entry (
session->kernel_session->consumer->socks->ht, &iter, socket, node.node) {
- lttng::pthread::lock_guard socket_lock(*socket->lock);
+ const lttng::pthread::lock_guard socket_lock(*socket->lock);
relayd_id = session->kernel_session->consumer->type == CONSUMER_DST_LOCAL ?
-1ULL :
lttng_pipe_destroy(queue->event_pipe);
{
- lttng::pthread::lock_guard queue_lock(queue->lock);
+ const lttng::pthread::lock_guard queue_lock(queue->lock);
LTTNG_ASSERT(cds_list_empty(&queue->list));
}
const char dummy = '!';
struct rotation_thread_job *job = nullptr;
const char *job_type_str = get_job_type_str(job_type);
- lttng::pthread::lock_guard queue_lock(queue->lock);
+ const lttng::pthread::lock_guard queue_lock(queue->lock);
if (timer_job_exists(queue, job_type, session)) {
/*
{
/* Take the queue lock only to pop an element from the list. */
- lttng::pthread::lock_guard rotation_timer_queue_lock(
+ const lttng::pthread::lock_guard rotation_timer_queue_lock(
_rotation_timer_queue.lock);
if (cds_list_empty(&_rotation_timer_queue.list)) {
break;