diff --git a/src/server/server.c b/src/server/server.c index 52748b5..f8fdb54 100644 --- a/src/server/server.c +++ b/src/server/server.c @@ -126,7 +126,8 @@ void handler(int file_descriptor) { close(file_descriptor); return; } - PipelineContextReceiver* context = pipeline_context_receiver_create(config, q, file_descriptor, ssl); + PipelineContextReceiver* context = + pipeline_context_receiver_create(config, q, file_descriptor, ssl); if (context == NULL) { queue_destroy(q); config_delete(config); diff --git a/src/shared/multiprocessing.c b/src/shared/multiprocessing.c index b0ed691..e7c4624 100644 --- a/src/shared/multiprocessing.c +++ b/src/shared/multiprocessing.c @@ -54,7 +54,7 @@ void pipeline_context_sender_destroy(PipelineContextSender* context) { } PipelineContextReceiver* pipeline_context_receiver_create(Config* config, Queue* queue, - int file_descriptor, SSL* ssl) { + int file_descriptor, SSL* ssl) { PipelineContextReceiver* context = malloc(sizeof(PipelineContextReceiver)); if (context == NULL) return NULL; diff --git a/src/shared/multiprocessing.h b/src/shared/multiprocessing.h index 15d480e..5d0a39e 100644 --- a/src/shared/multiprocessing.h +++ b/src/shared/multiprocessing.h @@ -40,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, SSL* ssl); + int file_descriptor, SSL* ssl); void pipeline_context_receiver_destroy(PipelineContextReceiver* context); int receive_thread(void* pipeline_context); int write_thread(void* pipeline_context); diff --git a/tests/test_multiprocessing.c b/tests/test_multiprocessing.c index b6ba101..54ed5d6 100644 --- a/tests/test_multiprocessing.c +++ b/tests/test_multiprocessing.c @@ -116,7 +116,6 @@ static void test_receiver_fd_zero() { pipeline_context_receiver_destroy(ctx); } - /* Test that receive_thread completes cleanly when sent FINISHED immediately */ static void test_receive_thread_finished() { Config* cfg = config_create();