projects
/
lttng-ust.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: handle pthread errors
[lttng-ust.git]
/
liblttng-ust
/
lttng-ust-comm.c
diff --git
a/liblttng-ust/lttng-ust-comm.c
b/liblttng-ust/lttng-ust-comm.c
index 12385dfca95762d32839b4e5917a92f8b82b4c58..5e738b06cf6eee5b539f4f507ba97817525a8fbf 100644
(file)
--- a/
liblttng-ust/lttng-ust-comm.c
+++ b/
liblttng-ust/lttng-ust-comm.c
@@
-883,15
+883,20
@@
void __attribute__((constructor)) lttng_ust_init(void)
sigfillset(&sig_all_blocked);
ret = pthread_sigmask(SIG_SETMASK, &sig_all_blocked, &orig_parent_mask);
if (ret) {
sigfillset(&sig_all_blocked);
ret = pthread_sigmask(SIG_SETMASK, &sig_all_blocked, &orig_parent_mask);
if (ret) {
-
PERRO
R("pthread_sigmask: %s", strerror(ret));
+
ER
R("pthread_sigmask: %s", strerror(ret));
}
ret = pthread_create(&global_apps.ust_listener, NULL,
ust_listener_thread, &global_apps);
}
ret = pthread_create(&global_apps.ust_listener, NULL,
ust_listener_thread, &global_apps);
-
+ if (ret) {
+ ERR("pthread_create global: %s", strerror(ret));
+ }
if (local_apps.allowed) {
ret = pthread_create(&local_apps.ust_listener, NULL,
ust_listener_thread, &local_apps);
if (local_apps.allowed) {
ret = pthread_create(&local_apps.ust_listener, NULL,
ust_listener_thread, &local_apps);
+ if (ret) {
+ ERR("pthread_create local: %s", strerror(ret));
+ }
} else {
handle_register_done(&local_apps);
}
} else {
handle_register_done(&local_apps);
}
@@
-899,7
+904,7
@@
void __attribute__((constructor)) lttng_ust_init(void)
/* Restore original signal mask in parent */
ret = pthread_sigmask(SIG_SETMASK, &orig_parent_mask, NULL);
if (ret) {
/* Restore original signal mask in parent */
ret = pthread_sigmask(SIG_SETMASK, &orig_parent_mask, NULL);
if (ret) {
-
PERRO
R("pthread_sigmask: %s", strerror(ret));
+
ER
R("pthread_sigmask: %s", strerror(ret));
}
switch (timeout_mode) {
}
switch (timeout_mode) {
@@
-975,12
+980,14
@@
void __attribute__((destructor)) lttng_ust_exit(void)
/* cancel threads */
ret = pthread_cancel(global_apps.ust_listener);
if (ret) {
/* cancel threads */
ret = pthread_cancel(global_apps.ust_listener);
if (ret) {
- ERR("Error cancelling global ust listener thread");
+ ERR("Error cancelling global ust listener thread: %s",
+ strerror(ret));
}
if (local_apps.allowed) {
ret = pthread_cancel(local_apps.ust_listener);
if (ret) {
}
if (local_apps.allowed) {
ret = pthread_cancel(local_apps.ust_listener);
if (ret) {
- ERR("Error cancelling local ust listener thread");
+ ERR("Error cancelling local ust listener thread: %s",
+ strerror(ret));
}
}
/*
}
}
/*
This page took
0.024323 seconds
and
4
git commands to generate.