test: mark TLS multithreading test as xfail (known limitation)

src/server/server.c

@@ -112,6 +112,7 @@ int receive_files(Config* config, int fd) {
 }
 
 void handler(int file_descriptor) {
+  SSL* ssl = io_get_ssl();
   Config* config = config_receive(file_descriptor);
   if (config == NULL) {
     log_message(LOG_LEVEL_ERROR, "Failed to receive config");
@@ -125,7 +126,7 @@ void handler(int file_descriptor) {
       close(file_descriptor);
       return;
     }
-    PipelineContextReceiver* context = pipeline_context_receiver_create(config, q, file_descriptor);
+    PipelineContextReceiver* context = pipeline_context_receiver_create(config, q, file_descriptor, ssl);
     if (context == NULL) {
       queue_destroy(q);
       config_delete(config);

src/shared/multiprocessing.c

@@ -54,13 +54,14 @@ void pipeline_context_sender_destroy(PipelineContextSender* context) {
 }
 
 PipelineContextReceiver* pipeline_context_receiver_create(Config* config, Queue* queue,
-                                                          int file_descriptor) {
+                                                           int file_descriptor, SSL* ssl) {
   PipelineContextReceiver* context = malloc(sizeof(PipelineContextReceiver));
   if (context == NULL)
     return NULL;
   context->config = config;
   context->queue = queue;
   context->file_descriptor = file_descriptor;
+  context->ssl = ssl;
   context->receiver_done = false;
   if (mtx_init(&context->mutex, mtx_plain) != thrd_success ||
       cnd_init(&context->condition_not_full) != thrd_success ||
@@ -98,6 +99,8 @@ static bool receive_chunk_enqueue(int file_descriptor, PipelineContextReceiver*
 
 int receive_thread(void* pipeline_context) {
   PipelineContextReceiver* context = (PipelineContextReceiver*)pipeline_context;
+  if (context->ssl)
+    io_set_ssl(context->ssl);
   mtx_lock(&context->mutex);
   int file_descriptor = context->file_descriptor;
   const Config* config = context->config;
@@ -183,6 +186,8 @@ int receive_thread(void* pipeline_context) {
 
 int write_thread(void* pipeline_context) {
   PipelineContextReceiver* context = (PipelineContextReceiver*)pipeline_context;
+  if (context->ssl)
+    io_set_ssl(context->ssl);
   mtx_lock(&context->mutex);
   bool save_to_disk = context->config->save_to_disk;
   char* root_directory = str_dup(context->config->receive_root_directory);

src/shared/multiprocessing.h

@@ -6,7 +6,9 @@
 #include "array_list.h"
 #include "config.h"
 #include "file.h"
+#include "protocol.h"
 #include "queue.h"
+#include <openssl/ssl.h>
 
 typedef struct {
   Config* config;
@@ -27,6 +29,7 @@ typedef struct PipelineContextReceiver {
   Queue* queue;
   Config* config;
   int file_descriptor;
+  SSL* ssl;
   mtx_t mutex;
   cnd_t condition_not_full;
   cnd_t condition_not_empty;
@@ -37,7 +40,7 @@ PipelineContextSender* pipeline_context_sender_create(Config* config, Queue* que
                                                       Queue* queue_loader);
 void pipeline_context_sender_destroy(PipelineContextSender* context);
 PipelineContextReceiver* pipeline_context_receiver_create(Config* config, Queue* queue_receiver,
-                                                          int file_descriptor);
+                                                           int file_descriptor, SSL* ssl);
 void pipeline_context_receiver_destroy(PipelineContextReceiver* context);
 int receive_thread(void* pipeline_context);
 int write_thread(void* pipeline_context);

src/shared/protocol.c

@@ -67,6 +67,10 @@ void io_set_ssl(SSL* ssl) {
   io_ssl = ssl;
 }
 
+SSL* io_get_ssl(void) {
+  return io_ssl;
+}
+
 static int io_fd(int dir_fd, int file_descriptor) {
   return (dir_fd != -1) ? dir_fd : file_descriptor;
 }

src/shared/protocol.h

@@ -32,6 +32,7 @@ enum NET_STATUS {
 void io_set_fds(int read_fd, int write_fd);
 void io_set_bwlimit(unsigned long long bytes_per_sec);
 void io_set_ssl(SSL* ssl);
+SSL* io_get_ssl(void);
 bool send_n_data(int file_descriptor, const void* data, size_t data_size);
 bool receive_n_data(int file_descriptor, void* data, size_t data_size);