X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Frotation-thread.c;h=6669372dd471210470138dbab6605907fa15019d;hb=f4cc5e83435948e64f5c7bce395ca19703da02a3;hp=9a1d803b795846a380fa53b157616b370f2d2e05;hpb=64d9b072ae17f9d2b9cc320ddef3dbe373761a93;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/rotation-thread.c b/src/bin/lttng-sessiond/rotation-thread.c index 9a1d803b7..6669372dd 100644 --- a/src/bin/lttng-sessiond/rotation-thread.c +++ b/src/bin/lttng-sessiond/rotation-thread.c @@ -761,9 +761,9 @@ int handle_job_queue(struct rotation_thread_handle *handle, * possible for a job targeting that session to have * already been queued before it was destroyed. */ - session_unlock_list(); free(job); session_put(session); + session_unlock_list(); continue; } @@ -832,7 +832,6 @@ int handle_condition(const struct lttng_condition *condition, goto end; } session_lock(session); - session_unlock_list(); ret = unsubscribe_session_consumed_size_rotation(session, notification_thread_handle); @@ -861,6 +860,7 @@ int handle_condition(const struct lttng_condition *condition, end_unlock: session_unlock(session); session_put(session); + session_unlock_list(); end: return ret; } @@ -950,9 +950,6 @@ void *thread_rotation(void *data) goto error; } - /* Ready to handle client connections. */ - sessiond_notify_ready(); - while (true) { int fd_count, i;