char wait_shm_path[PATH_MAX];
char *wait_shm_mmap;
- struct lttng_session *session_enabled;
+ int session_enabled;
};
/* Socket from app (connect) to session daemon (listen) for communication */
.wait_shm_path = "/" LTTNG_UST_WAIT_FILENAME,
- .session_enabled = NULL,
+ .session_enabled = 0,
};
/* TODO: allow global_apps_sock_path override */
.socket = -1,
.notify_socket = -1,
- .session_enabled = NULL,
+ .session_enabled = 0,
};
static int wait_poll_fallback;
return ret;
}
+static
+void handle_pending_statedumps(struct sock_info *sock_info)
+{
+ int ctor_passed = sock_info->constructor_sem_posted;
+
+ if (ctor_passed && sock_info->session_enabled) {
+ sock_info->session_enabled = 0;
+ lttng_handle_pending_statedumps(<tng_ust_baddr_statedump);
+ }
+}
+
static
void cleanup_sock_info(struct sock_info *sock_info, int exiting)
{
if (ret) {
ERR("Error handling message for %s socket", sock_info->name);
} else {
- struct lttng_session *session;
-
- session = sock_info->session_enabled;
- if (session) {
- sock_info->session_enabled = NULL;
- lttng_ust_baddr_statedump(session);
- }
+ handle_pending_statedumps(sock_info);
}
continue;
default:
lttng_ust_init();
}
-void lttng_ust_sockinfo_session_enabled(void *owner,
- struct lttng_session *session_enabled)
+void lttng_ust_sockinfo_session_enabled(void *owner)
{
struct sock_info *sock_info = owner;
- sock_info->session_enabled = session_enabled;
+ sock_info->session_enabled = 1;
}