projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Cleanup: remove duplicated code in snapshot record command
[lttng-tools.git]
/
src
/
bin
/
lttng-sessiond
/
rotation-thread.c
diff --git
a/src/bin/lttng-sessiond/rotation-thread.c
b/src/bin/lttng-sessiond/rotation-thread.c
index 9a1d803b795846a380fa53b157616b370f2d2e05..6669372dd471210470138dbab6605907fa15019d 100644
(file)
--- 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.
*/
* possible for a job targeting that session to have
* already been queued before it was destroyed.
*/
- session_unlock_list();
free(job);
session_put(session);
free(job);
session_put(session);
+ session_unlock_list();
continue;
}
continue;
}
@@
-832,7
+832,6
@@
int handle_condition(const struct lttng_condition *condition,
goto end;
}
session_lock(session);
goto end;
}
session_lock(session);
- session_unlock_list();
ret = unsubscribe_session_consumed_size_rotation(session,
notification_thread_handle);
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);
end_unlock:
session_unlock(session);
session_put(session);
+ session_unlock_list();
end:
return ret;
}
end:
return ret;
}
@@
-950,9
+950,6
@@
void *thread_rotation(void *data)
goto error;
}
goto error;
}
- /* Ready to handle client connections. */
- sessiond_notify_ready();
-
while (true) {
int fd_count, i;
while (true) {
int fd_count, i;
This page took
0.025434 seconds
and
4
git commands to generate.