uid_t uid;
} reg_msg;
+ DBG("[thread] Manage apps started");
+
/* Notify all applications to register */
notify_apps(default_global_apps_pipe);
int sock, ret;
struct lttcomm_session_msg lsm;
+ DBG("[thread] Manage client started");
+
ret = lttcomm_listen_unix_sock(client_socket);
if (ret < 0) {
goto error;
int sock;
struct ltt_traceable_app *lta;
+ DBG("Connect to application pid %d", pid);
+
lta = find_app_by_pid(pid);
if (lta == NULL) {
/* App not found */
int fd;
int ret = -1;
+ DBG("Notify the global application pipe");
+
/* Try opening the global pipe */
fd = open(name, O_WRONLY);
if (fd < 0) {
int sock, ret;
struct ltt_ust_trace *trace;
+ DBG("Creating trace for pid %d", pid);
+
trace = malloc(sizeof(struct ltt_ust_trace));
if (trace == NULL) {
perror("malloc");
/* Init */
trace->pid = pid;
trace->shmid = 0;
+ /* NOTE: to be removed. Trace name will no longer be
+ * required for LTTng userspace tracer. For now, we set it
+ * to 'auto' for API compliance.
+ */
+ snprintf(trace->name, 5, "auto");
/* Connect to app using ustctl API */
sock = connect_app(pid);
goto error;
}
- ret = ustctl_create_trace(sock, "auto");
+ ret = ustctl_create_trace(sock, trace->name);
if (ret < 0) {
ret = LTTCOMM_CREATE_FAIL;
goto error;
/* Check if current session is valid */
if (current_session) {
cds_list_add(&trace->list, ¤t_session->ust_traces);
+ current_session->ust_trace_count++;
}
error:
char *send_buf = NULL;
struct lttcomm_lttng_msg llm;
+ DBG("Processing client message");
+
/* Copy common data to identify the response
* on the lttng client side.
*/
/* No auxiliary data so only send the llm struct. */
goto end;
}
+ case LTTNG_LIST_TRACES:
+ {
+ unsigned int trace_count = get_trace_count_per_session(current_session);
+
+ if (trace_count == 0) {
+ ret = LTTCOMM_NO_TRACE;
+ goto end;
+ }
+
+ buf_size = setup_data_buffer(&send_buf,
+ sizeof(struct lttng_trace) * trace_count, &llm);
+ if (buf_size < 0) {
+ ret = LTTCOMM_FATAL;
+ goto end;
+ }
+
+ get_traces_per_session(current_session, (struct lttng_trace *)(send_buf + header_size));
+ break;
+ }
case UST_CREATE_TRACE:
{
ret = ust_create_trace(lsm->pid);
perror("chown");
}
+ DBG("Sockets permissions set");
+
end:
return ret;
}
return ret;
}
+ DBG("Signal handler set for SIGTERM, SIGPIPE and SIGINT");
+
return ret;
}
{
switch (sig) {
case SIGPIPE:
+ DBG("SIGPIPE catched");
return;
case SIGINT:
+ DBG("SIGINT catched");
+ cleanup();
+ break;
case SIGTERM:
+ DBG("SIGTERM catched");
cleanup();
break;
default:
*/
static void cleanup()
{
+ DBG("Cleaning up");
+
/* <fun> */
MSG("\n%c[%d;%dm*** assert failed *** ==> %c[%dm", 27,1,31,27,0);
MSG("%c[%d;%dmMatthew, BEET driven development works!%c[%dm",27,1,33,27,0);