rcu_read_lock();
app = agent_find_app_by_sock(sock);
assert(app);
- rcu_read_unlock();
- /* RCU read side lock is taken in this function call. */
+ /* RCU read side lock is assumed to be held by this function. */
agent_delete_app(app);
/* The application is freed in a RCU call but the socket is closed here. */
agent_destroy_app(app);
+ rcu_read_unlock();
}
/*
}
while (1) {
- DBG3("[agent-thread] Manage agent polling on %d fds",
- LTTNG_POLL_GETNB(&events));
+ DBG3("[agent-thread] Manage agent polling");
/* Inifinite blocking call, waiting for transmission */
restart:
ret = lttng_poll_wait(&events, -1);
+ DBG3("[agent-thread] Manage agent return from poll on %d fds",
+ LTTNG_POLL_GETNB(&events));
if (ret < 0) {
/*
* Restart interrupted system call.