health_code_update();
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/* Thread quit pipe has been closed. Killing thread. */
ret = sessiond_check_thread_quit_pipe(pollfd, revents);
if (ret) {
health_code_update();
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/* Thread quit pipe has been closed. Killing thread. */
ret = sessiond_check_thread_quit_pipe(pollfd, revents);
if (ret) {
health_code_update();
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/*
* Thread quit pipe has been triggered, flag that we should stop
* but continue the current loop to handle potential data from
health_code_update();
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/* Thread quit pipe has been closed. Killing thread. */
ret = sessiond_check_thread_quit_pipe(pollfd, revents);
if (ret) {
uint32_t revents = LTTNG_POLL_GETEV(&events, i);
int pollfd = LTTNG_POLL_GETFD(&events, i);
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
cds_list_for_each_entry_safe(wait_node, tmp_wait_node,
&wait_queue->head, head) {
if (pollfd == wait_node->app->sock &&
revents = LTTNG_POLL_GETEV(&events, i);
pollfd = LTTNG_POLL_GETFD(&events, i);
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/* Thread quit pipe has been closed. Killing thread. */
ret = sessiond_check_thread_quit_pipe(pollfd, revents);
if (ret) {
revents = LTTNG_POLL_GETEV(&events, i);
pollfd = LTTNG_POLL_GETFD(&events, i);
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/* Thread quit pipe has been closed. Killing thread. */
ret = sessiond_check_thread_quit_pipe(pollfd, revents);
if (ret) {
health_code_update();
+ if (!revents) {
+ /* No activity for this FD (poll implementation). */
+ continue;
+ }
+
/* Thread quit pipe has been closed. Killing thread. */
ret = sessiond_check_thread_quit_pipe(pollfd, revents);
if (ret) {
}
tracing_group_name = strdup(arg);
if (!tracing_group_name) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
tracing_group_name_override = 1;
}
consumerd32_bin = strdup(arg);
if (!consumerd32_bin) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
consumerd32_bin_override = 1;
}
consumerd32_libdir = strdup(arg);
if (!consumerd32_libdir) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
consumerd32_libdir_override = 1;
}
consumerd64_bin = strdup(arg);
if (!consumerd64_bin) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
consumerd64_bin_override = 1;
}
consumerd64_libdir = strdup(arg);
if (!consumerd64_libdir) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
consumerd64_libdir_override = 1;
free(opt_pidfile);
opt_pidfile = strdup(arg);
if (!opt_pidfile) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
break;
free(opt_load_session_path);
opt_load_session_path = strdup(arg);
if (!opt_load_session_path) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
break;
free(kmod_probes_list);
kmod_probes_list = strdup(arg);
if (!kmod_probes_list) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
break;
free(kmod_extra_probes_list);
kmod_extra_probes_list = strdup(arg);
if (!kmod_extra_probes_list) {
- perror("strdup");
+ PERROR("strdup");
ret = -ENOMEM;
}
break;