#include "thread.hpp"
#include "utils.hpp"
+#include <fcntl.h>
+
namespace {
struct thread_notifiers {
struct lttng_pipe *quit_pipe;
*
* At that point, it flushes the data (tracing and metadata) associated
* with this application and tears down ust app sessions and other
- * associated data structures through ust_app_unregister().
+ * associated data structures through ust_app_unregister_by_socket().
*
* Note that this thread never sends commands to the applications
* through the command sockets; it merely listens for hang-ups
health_code_update();
- while (1) {
+ while (true) {
DBG("Apps thread polling");
/* Inifinite blocking call, waiting for transmission */
}
/* Socket closed on remote end. */
- ust_app_unregister(pollfd);
+ ust_app_unregister_by_socket(pollfd);
} else {
ERR("Unexpected poll events %u for sock %d",
revents,
DBG("Application communication apps thread cleanup complete");
rcu_thread_offline();
rcu_unregister_thread();
- return NULL;
+ return nullptr;
}
static bool shutdown_application_management_thread(void *data)
bool launch_application_management_thread(int apps_cmd_pipe_read_fd)
{
struct lttng_pipe *quit_pipe;
- struct thread_notifiers *notifiers = NULL;
+ struct thread_notifiers *notifiers = nullptr;
struct lttng_thread *thread;
notifiers = zmalloc<thread_notifiers>();