panic when we can't install essential worker threads

2 files changed, 4 insertions, 2 deletions

diff --git a/src/ot_clean.c b/src/ot_clean.c
index 130bd2a..8eb1da2 100644
--- a/src/ot_clean.c
+++ b/src/ot_clean.c
@@ -193,7 +193,8 @@ static pthread_t thread_id;
 void clean_init(void) {
   if (pipe(g_clean_pipe) == -1)
     fprintf(stderr, "Warning: the cleaner has no pipe to be woken through and will take up to one sleep interval to stop.\n");
-  pthread_create(&thread_id, NULL, clean_worker, NULL);
+  if (pthread_create(&thread_id, NULL, clean_worker, NULL))
+    exerr("Cannot create cleanup worker thread.");
 }
 
 void clean_deinit(void) {
diff --git a/src/ot_fullscrape.c b/src/ot_fullscrape.c
index 787b508..bbceb0b 100644
--- a/src/ot_fullscrape.c
+++ b/src/ot_fullscrape.c
@@ -72,7 +72,8 @@ static void *fullscrape_worker(void *args) {
 
 static pthread_t thread_id;
 void fullscrape_init(void) {
-  pthread_create( &thread_id, NULL, fullscrape_worker, NULL );
+  if (pthread_create(&thread_id, NULL, fullscrape_worker, NULL))
+    exerr("Cannot create fullscrape worker thread.");
 }
 
 void fullscrape_deinit(void) {