X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Frotation-thread.c;h=036296a3fe80bcc4a797311fcfa87d6e6f9078fc;hp=f07672c220158d285325db3c57207edfed525f08;hb=16100d7ad8517131cc3ef29743e325184802ad13;hpb=f8a374116cf842e26bd8fbfd7168b922fdb98ea4;ds=sidebyside diff --git a/src/bin/lttng-sessiond/rotation-thread.c b/src/bin/lttng-sessiond/rotation-thread.c index f07672c22..036296a3f 100644 --- a/src/bin/lttng-sessiond/rotation-thread.c +++ b/src/bin/lttng-sessiond/rotation-thread.c @@ -352,13 +352,13 @@ void check_session_rotation_pending_on_consumers(struct ltt_session *session, goto end; } - if (exists_status != CONSUMER_TRACE_CHUNK_EXISTS_STATUS_UNKNOWN_CHUNK) { + if (exists_status != CONSUMER_TRACE_CHUNK_EXISTS_STATUS_UNKNOWN_CHUNK) { pthread_mutex_unlock(socket->lock); chunk_exists_on_peer = true; goto end; - } + } pthread_mutex_unlock(socket->lock); - } + } skip_ust: if (!session->kernel_session) { @@ -381,11 +381,11 @@ skip_ust: goto end; } - if (exists_status != CONSUMER_TRACE_CHUNK_EXISTS_STATUS_UNKNOWN_CHUNK) { + if (exists_status != CONSUMER_TRACE_CHUNK_EXISTS_STATUS_UNKNOWN_CHUNK) { pthread_mutex_unlock(socket->lock); chunk_exists_on_peer = true; goto end; - } + } pthread_mutex_unlock(socket->lock); } skip_kernel: @@ -548,7 +548,7 @@ int run_job(struct rotation_thread_job *job, struct ltt_session *session, switch (job->type) { case ROTATION_THREAD_JOB_TYPE_SCHEDULED_ROTATION: - ret = launch_session_rotation(session); + ret = launch_session_rotation(session); break; case ROTATION_THREAD_JOB_TYPE_CHECK_PENDING_ROTATION: ret = check_session_rotation_pending(session, @@ -604,7 +604,7 @@ int handle_job_queue(struct rotation_thread_handle *handle, } session_lock(session); - ret = run_job(job, session, handle->notification_thread_handle); + ret = run_job(job, session, handle->notification_thread_handle); session_unlock(session); /* Release reference held by the job. */ session_put(session);