X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Fevent.c;h=a2e6c37effb853d43385cd5da1a4b89de11957c1;hp=4bc8fb90df81f6b722d5ef50d282a6c4cf15d597;hb=49c336c1679295a31b92223dca05feccfe3e3464;hpb=a027b2d2edced8011ef674f88146253715952af7 diff --git a/src/bin/lttng-sessiond/event.c b/src/bin/lttng-sessiond/event.c index 4bc8fb90d..a2e6c37ef 100644 --- a/src/bin/lttng-sessiond/event.c +++ b/src/bin/lttng-sessiond/event.c @@ -51,6 +51,15 @@ static void init_syscalls_kernel_event(struct lttng_event *event) static int loglevel_match(struct ltt_ust_event *uevent, enum lttng_ust_loglevel_type log_type, int loglevel) { + /* + * For the loglevel type ALL, the loglevel is set to -1 but the event + * received by the session daemon is 0 which does not match the negative + * value in the existing event. + */ + if (log_type == LTTNG_UST_LOGLEVEL_ALL) { + loglevel = -1; + } + if (uevent == NULL || uevent->attr.loglevel_type != log_type || uevent->attr.loglevel != loglevel) { goto no_match; @@ -73,20 +82,20 @@ int event_kernel_disable_tracepoint(struct ltt_kernel_session *ksession, kevent = trace_kernel_get_event_by_name(event_name, kchan); if (kevent == NULL) { - ret = LTTCOMM_NO_EVENT; + ret = LTTNG_ERR_NO_EVENT; goto error; } ret = kernel_disable_event(kevent); if (ret < 0) { - ret = LTTCOMM_KERN_DISABLE_FAIL; + ret = LTTNG_ERR_KERN_DISABLE_FAIL; goto error; } DBG("Kernel event %s disable for channel %s.", kevent->event->name, kchan->channel->name); - ret = LTTCOMM_OK; + ret = LTTNG_OK; error: return ret; @@ -109,7 +118,7 @@ int event_kernel_disable_all_tracepoints(struct ltt_kernel_session *ksession, continue; } } - ret = LTTCOMM_OK; + ret = LTTNG_OK; return ret; } @@ -120,7 +129,7 @@ int event_kernel_disable_all_syscalls(struct ltt_kernel_session *ksession, struct ltt_kernel_channel *kchan) { ERR("Cannot disable syscall tracing for existing session. Please destroy session instead."); - return LTTCOMM_OK; /* Return OK so disable all succeeds */ + return LTTNG_OK; /* Return OK so disable all succeeds */ } /* @@ -132,7 +141,7 @@ int event_kernel_disable_all(struct ltt_kernel_session *ksession, int ret; ret = event_kernel_disable_all_tracepoints(ksession, kchan); - if (ret != LTTCOMM_OK) + if (ret != LTTNG_OK) return ret; ret = event_kernel_disable_all_syscalls(ksession, kchan); return ret; @@ -153,13 +162,13 @@ int event_kernel_enable_tracepoint(struct ltt_kernel_session *ksession, if (ret < 0) { switch (-ret) { case EEXIST: - ret = LTTCOMM_KERN_EVENT_EXIST; + ret = LTTNG_ERR_KERN_EVENT_EXIST; break; case ENOSYS: - ret = LTTCOMM_KERN_EVENT_ENOSYS; + ret = LTTNG_ERR_KERN_EVENT_ENOSYS; break; default: - ret = LTTCOMM_KERN_ENABLE_FAIL; + ret = LTTNG_ERR_KERN_ENABLE_FAIL; break; } goto end; @@ -167,16 +176,16 @@ int event_kernel_enable_tracepoint(struct ltt_kernel_session *ksession, } else if (kevent->enabled == 0) { ret = kernel_enable_event(kevent); if (ret < 0) { - ret = LTTCOMM_KERN_ENABLE_FAIL; + ret = LTTNG_ERR_KERN_ENABLE_FAIL; goto end; } } else { /* At this point, the event is considered enabled */ - ret = LTTCOMM_KERN_EVENT_EXIST; + ret = LTTNG_ERR_KERN_EVENT_EXIST; goto end; } - ret = LTTCOMM_OK; + ret = LTTNG_OK; end: return ret; } @@ -204,7 +213,7 @@ int event_kernel_enable_all_tracepoints(struct ltt_kernel_session *ksession, size = kernel_list_events(kernel_tracer_fd, &event_list); if (size < 0) { - ret = LTTCOMM_KERN_LIST_FAIL; + ret = LTTNG_ERR_KERN_LIST_FAIL; goto end; } @@ -222,7 +231,7 @@ int event_kernel_enable_all_tracepoints(struct ltt_kernel_session *ksession, } free(event_list); - ret = LTTCOMM_OK; + ret = LTTNG_OK; end: return ret; @@ -244,14 +253,14 @@ int event_kernel_enable_all_syscalls(struct ltt_kernel_session *ksession, ret = kernel_create_event(&event, kchan); if (ret < 0) { if (ret == -EEXIST) { - ret = LTTCOMM_KERN_EVENT_EXIST; + ret = LTTNG_ERR_KERN_EVENT_EXIST; } else { - ret = LTTCOMM_KERN_ENABLE_FAIL; + ret = LTTNG_ERR_KERN_ENABLE_FAIL; } goto end; } - ret = LTTCOMM_OK; + ret = LTTNG_OK; end: return ret; } @@ -265,7 +274,7 @@ int event_kernel_enable_all(struct ltt_kernel_session *ksession, int tp_ret; tp_ret = event_kernel_enable_all_tracepoints(ksession, kchan, kernel_tracer_fd); - if (tp_ret != LTTCOMM_OK) { + if (tp_ret != LTTNG_OK) { goto end; } @@ -319,7 +328,7 @@ int event_ust_enable_all_tracepoints(struct ltt_ust_session *usess, int domain, /* Get all UST available events */ size = ust_app_list_events(&events); if (size < 0) { - ret = LTTCOMM_UST_LIST_FAIL; + ret = LTTNG_ERR_UST_LIST_FAIL; goto error; } @@ -334,8 +343,8 @@ int event_ust_enable_all_tracepoints(struct ltt_ust_session *usess, int domain, ret = ust_app_enable_event_pid(usess, uchan, uevent, events[i].pid); if (ret < 0) { - if (ret != -EEXIST) { - ret = LTTCOMM_UST_ENABLE_FAIL; + if (ret != -LTTNG_UST_ERR_EXIST) { + ret = LTTNG_ERR_UST_ENABLE_FAIL; goto error; } } @@ -345,7 +354,7 @@ int event_ust_enable_all_tracepoints(struct ltt_ust_session *usess, int domain, /* Create ust event */ uevent = trace_ust_create_event(&events[i]); if (uevent == NULL) { - ret = LTTCOMM_FATAL; + ret = LTTNG_ERR_FATAL; goto error_destroy; } @@ -353,11 +362,11 @@ int event_ust_enable_all_tracepoints(struct ltt_ust_session *usess, int domain, ret = ust_app_enable_event_pid(usess, uchan, uevent, events[i].pid); if (ret < 0) { - if (ret == -EEXIST) { - ret = LTTCOMM_UST_EVENT_EXIST; + if (ret == -LTTNG_UST_ERR_EXIST) { + ret = LTTNG_ERR_UST_EVENT_EXIST; goto error; } else { - ret = LTTCOMM_UST_ENABLE_FAIL; + ret = LTTNG_ERR_UST_ENABLE_FAIL; goto error_destroy; } } @@ -378,11 +387,11 @@ int event_ust_enable_all_tracepoints(struct ltt_ust_session *usess, int domain, case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN: #endif default: - ret = LTTCOMM_UND; + ret = LTTNG_ERR_UND; goto error; } - return LTTCOMM_OK; + return LTTNG_OK; error_destroy: trace_ust_destroy_event(uevent); @@ -398,14 +407,14 @@ error: int event_ust_enable_tracepoint(struct ltt_ust_session *usess, int domain, struct ltt_ust_channel *uchan, struct lttng_event *event) { - int ret = LTTCOMM_OK, to_create = 0; + int ret = LTTNG_OK, to_create = 0; struct ltt_ust_event *uevent; uevent = trace_ust_find_event_by_name(uchan->events, event->name); if (uevent == NULL) { uevent = trace_ust_create_event(event); if (uevent == NULL) { - ret = LTTCOMM_FATAL; + ret = LTTNG_ERR_UST_ENABLE_FAIL; goto error; } /* Valid to set it after the goto error since uevent is still NULL */ @@ -422,13 +431,13 @@ int event_ust_enable_tracepoint(struct ltt_ust_session *usess, int domain, DBG("Enable event %s does not match existing event %s with loglevel " "respectively of %d and %d", event->name, uevent->attr.name, uevent->attr.loglevel, event->loglevel); - ret = LTTCOMM_EVENT_EXIST_LOGLEVEL; + ret = LTTNG_ERR_EVENT_EXIST_LOGLEVEL; goto error; } if (uevent->enabled) { /* It's already enabled so everything is OK */ - ret = LTTCOMM_OK; + ret = LTTNG_OK; goto end; } @@ -446,11 +455,11 @@ int event_ust_enable_tracepoint(struct ltt_ust_session *usess, int domain, } if (ret < 0) { - if (ret == -EEXIST) { - ret = LTTCOMM_UST_EVENT_EXIST; + if (ret == -LTTNG_UST_ERR_EXIST) { + ret = LTTNG_ERR_UST_EVENT_EXIST; goto end; } else { - ret = LTTCOMM_UST_ENABLE_FAIL; + ret = LTTNG_ERR_UST_ENABLE_FAIL; goto error; } } @@ -462,7 +471,7 @@ int event_ust_enable_tracepoint(struct ltt_ust_session *usess, int domain, case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN: #endif default: - ret = LTTCOMM_UND; + ret = LTTNG_ERR_UND; goto end; } @@ -476,7 +485,7 @@ int event_ust_enable_tracepoint(struct ltt_ust_session *usess, int domain, DBG("Event UST %s %s in channel %s", uevent->attr.name, to_create ? "created" : "enabled", uchan->name); - ret = LTTCOMM_OK; + ret = LTTNG_OK; end: return ret; @@ -507,21 +516,21 @@ int event_ust_disable_tracepoint(struct ltt_ust_session *usess, int domain, uevent = trace_ust_find_event_by_name(uchan->events, event_name); if (uevent == NULL) { - ret = LTTCOMM_UST_EVENT_NOT_FOUND; + ret = LTTNG_ERR_UST_EVENT_NOT_FOUND; goto error; } if (uevent->enabled == 0) { /* It's already enabled so everything is OK */ - ret = LTTCOMM_OK; + ret = LTTNG_OK; goto end; } switch (domain) { case LTTNG_DOMAIN_UST: ret = ust_app_disable_event_glb(usess, uchan, uevent); - if (ret < 0 && ret != -EEXIST) { - ret = LTTCOMM_UST_DISABLE_FAIL; + if (ret < 0 && ret != -LTTNG_UST_ERR_EXIST) { + ret = LTTNG_ERR_UST_DISABLE_FAIL; goto error; } break; @@ -531,12 +540,12 @@ int event_ust_disable_tracepoint(struct ltt_ust_session *usess, int domain, case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN: #endif default: - ret = LTTCOMM_UND; + ret = LTTNG_ERR_UND; goto error; } uevent->enabled = 0; - ret = LTTCOMM_OK; + ret = LTTNG_OK; end: DBG2("Event UST %s disabled in channel %s", uevent->attr.name, @@ -575,7 +584,7 @@ int event_ust_disable_all_tracepoints(struct ltt_ust_session *usess, int domain, /* Get all UST available events */ size = ust_app_list_events(&events); if (size < 0) { - ret = LTTCOMM_UST_LIST_FAIL; + ret = LTTNG_ERR_UST_LIST_FAIL; goto error; } @@ -585,8 +594,8 @@ int event_ust_disable_all_tracepoints(struct ltt_ust_session *usess, int domain, if (uevent != NULL && uevent->enabled == 1) { ret = ust_app_disable_event_pid(usess, uchan, uevent, events[i].pid); - if (ret < 0 && ret != -EEXIST) { - ret = LTTCOMM_UST_DISABLE_FAIL; + if (ret < 0 && ret != -LTTNG_UST_ERR_EXIST) { + ret = LTTNG_ERR_UST_DISABLE_FAIL; goto error; } uevent->enabled = 0; @@ -603,11 +612,11 @@ int event_ust_disable_all_tracepoints(struct ltt_ust_session *usess, int domain, case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN: #endif default: - ret = LTTCOMM_UND; + ret = LTTNG_ERR_UND; goto error; } - return LTTCOMM_OK; + return LTTNG_OK; error: free(events);