X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Flive.c;h=2c3a10574b5499c6a4a8585f3a22e5eac05562bc;hb=fbc08f38de61a27756c2e667715db8dce7fcb15e;hp=78ea95cc247652185e5ab0fc218c259458e629c6;hpb=f8f011fbfe48d1cef9000ccf54d13372f7d9ff1f;p=lttng-tools.git

diff --git a/src/bin/lttng-relayd/live.c b/src/bin/lttng-relayd/live.c
index 78ea95cc2..2c3a10574 100644
--- a/src/bin/lttng-relayd/live.c
+++ b/src/bin/lttng-relayd/live.c
@@ -339,7 +339,10 @@ int make_viewer_streams(struct relay_session *session,
 				 * Ensure a self-reference is preserved even
 				 * after we have put our local reference.
 				 */
-				viewer_stream_get(vstream);
+				if (!viewer_stream_get(vstream)) {
+					ERR("Unable to get self-reference on viewer stream, logic error.");
+					abort();
+				}
 			} else {
 				if (!vstream->sent_flag && nb_unsent) {
 					/* Update number of unsent stream counter. */
@@ -2183,7 +2186,7 @@ int relayd_live_create(struct lttng_uri *uri)
 	}
 
 	/* Setup the dispatcher thread */
-	ret = pthread_create(&live_dispatcher_thread, NULL,
+	ret = pthread_create(&live_dispatcher_thread, default_pthread_attr(),
 			thread_dispatcher, (void *) NULL);
 	if (ret) {
 		errno = ret;
@@ -2193,7 +2196,7 @@ int relayd_live_create(struct lttng_uri *uri)
 	}
 
 	/* Setup the worker thread */
-	ret = pthread_create(&live_worker_thread, NULL,
+	ret = pthread_create(&live_worker_thread, default_pthread_attr(),
 			thread_worker, NULL);
 	if (ret) {
 		errno = ret;
@@ -2203,7 +2206,7 @@ int relayd_live_create(struct lttng_uri *uri)
 	}
 
 	/* Setup the listener thread */
-	ret = pthread_create(&live_listener_thread, NULL,
+	ret = pthread_create(&live_listener_thread, default_pthread_attr(),
 			thread_listener, (void *) NULL);
 	if (ret) {
 		errno = ret;