rcu_read_unlock();
if (rotation_completed) {
- DBG("[rotation-thread] Totation of trace archive %" PRIu64 " of session \"%s\" is complete on the relay",
+ DBG("[rotation-thread] Rotation of trace archive %" PRIu64 " of session \"%s\" is complete on the relay",
session->current_archive_id - 1,
session->name);
session->rotation_pending_relay = false;
{
int ret = 0;
int fd = lttng_pipe_get_readfd(queue->event_pipe);
- struct ltt_session *session;
char buf;
ret = lttng_read(fd, &buf, 1);
}
for (;;) {
+ struct ltt_session *session;
struct rotation_thread_job *job;
/* Take the queue lock only to pop an element from the list. */
*/
session_unlock_list();
free(job);
+ session_put(session);
continue;
}
session_lock(session);
ret = run_job(job, session, handle->notification_thread_handle);
session_unlock(session);
+ session_put(session);
session_unlock_list();
free(job);
if (ret) {
end_unlock:
session_unlock(session);
+ session_put(session);
end:
return ret;
}
status = lttng_notification_channel_has_pending_notification(
rotate_notification_channel, ¬ification_pending);
if (status != LTTNG_NOTIFICATION_CHANNEL_STATUS_OK) {
- ERR("[rotation-thread ]Error occured while checking for pending notification");
+ ERR("[rotation-thread ]Error occurred while checking for pending notification");
ret = -1;
goto end;
}
ret = handle_notification_channel(fd, handle,
&thread);
if (ret) {
- ERR("[rotation-thread] Error occured while handling activity on notification channel socket");
+ ERR("[rotation-thread] Error occurred while handling activity on notification channel socket");
goto error;
}
}