TapTap
0021ca3fcd
CI / lint (pull_request) Failing after 11s
CI / build-and-test (pull_request) Has been skipped
CI / sanitizers (address) (pull_request) Has been skipped
CI / sanitizers (undefined) (pull_request) Has been skipped
CI / fuzz-build (pull_request) Has been skipped
CI / coverage (pull_request) Has been skipped
CI / valgrind (pull_request) Has been skipped
- #150: Replace 11-parameter config_create() with config_create() that initializes to sensible defaults; callers set fields directly - #149: Extract validate_config() from main(); reduce main() from 325 to 281 lines by extracting validation logic into separate function - #151: Extract run_dry_run(), connect_to_server(), send_manifest(), and print_progress() shared helpers from send_files()/send_files_multithreaded() to eliminate code duplication
119 lines
3.7 KiB
C
119 lines
3.7 KiB
C
#include "test_multiprocessing.h"
|
|
#include "multiprocessing.h"
|
|
#include "config.h"
|
|
#include "queue.h"
|
|
#include "utils.h"
|
|
#include "test_utils.h"
|
|
#include <stdlib.h>
|
|
|
|
/* Test pipeline_context_sender_create/destroy with valid arguments */
|
|
static void test_sender_create_destroy() {
|
|
Config* cfg = config_create();
|
|
EXPECT_NOT_NULL(cfg);
|
|
free(cfg->version);
|
|
cfg->version = str_dup("1.0");
|
|
cfg->send_directory = str_dup("/src");
|
|
cfg->receive_root_directory = str_dup("/dst");
|
|
|
|
Queue* q_scanner = queue_create(5, NULL);
|
|
EXPECT_NOT_NULL(q_scanner);
|
|
|
|
Queue* q_loader = queue_create(10, NULL);
|
|
EXPECT_NOT_NULL(q_loader);
|
|
|
|
PipelineContextSender* ctx = pipeline_context_sender_create(cfg, q_scanner, q_loader);
|
|
EXPECT_NOT_NULL(ctx);
|
|
EXPECT_EQ_STR(ctx->config->version, "1.0");
|
|
EXPECT_EQ_INT(ctx->queue_scanner->capacity, 5);
|
|
EXPECT_EQ_INT(ctx->queue_loader->capacity, 10);
|
|
EXPECT_FALSE(ctx->scanner_done);
|
|
EXPECT_FALSE(ctx->loader_done);
|
|
EXPECT_NULL(ctx->manifest);
|
|
|
|
pipeline_context_sender_destroy(ctx);
|
|
}
|
|
|
|
/* Test pipeline_context_receiver_create/destroy with valid arguments */
|
|
static void test_receiver_create_destroy() {
|
|
Config* cfg = config_create();
|
|
EXPECT_NOT_NULL(cfg);
|
|
free(cfg->version);
|
|
cfg->version = str_dup("2.0");
|
|
cfg->send_directory = str_dup("/src");
|
|
cfg->receive_root_directory = str_dup("/dst");
|
|
cfg->save_to_disk = true;
|
|
cfg->use_multithreading = true;
|
|
|
|
Queue* q = queue_create(20, NULL);
|
|
EXPECT_NOT_NULL(q);
|
|
|
|
PipelineContextReceiver* ctx = pipeline_context_receiver_create(cfg, q, 42);
|
|
EXPECT_NOT_NULL(ctx);
|
|
EXPECT_EQ_STR(ctx->config->version, "2.0");
|
|
EXPECT_EQ_INT(ctx->queue->capacity, 20);
|
|
EXPECT_EQ_INT(ctx->file_descriptor, 42);
|
|
EXPECT_FALSE(ctx->receiver_done);
|
|
|
|
pipeline_context_receiver_destroy(ctx);
|
|
}
|
|
|
|
/* Test that create handles various queue capacities */
|
|
static void test_sender_queue_capacities() {
|
|
Config* cfg = config_create();
|
|
EXPECT_NOT_NULL(cfg);
|
|
free(cfg->version);
|
|
cfg->version = str_dup("3.0");
|
|
cfg->send_directory = str_dup("/src");
|
|
cfg->receive_root_directory = str_dup("/dst");
|
|
|
|
/* Single-element queues */
|
|
Queue* q1 = queue_create(1, NULL);
|
|
Queue* q2 = queue_create(1, NULL);
|
|
PipelineContextSender* ctx = pipeline_context_sender_create(cfg, q1, q2);
|
|
EXPECT_NOT_NULL(ctx);
|
|
EXPECT_EQ_INT(ctx->queue_scanner->capacity, 1);
|
|
EXPECT_EQ_INT(ctx->queue_loader->capacity, 1);
|
|
pipeline_context_sender_destroy(ctx);
|
|
}
|
|
|
|
/* Test that create handles zero-capacity queues */
|
|
static void test_sender_zero_capacity() {
|
|
Config* cfg = config_create();
|
|
EXPECT_NOT_NULL(cfg);
|
|
free(cfg->version);
|
|
cfg->version = str_dup("4.0");
|
|
cfg->send_directory = str_dup("/src");
|
|
cfg->receive_root_directory = str_dup("/dst");
|
|
|
|
Queue* q1 = queue_create(0, NULL);
|
|
Queue* q2 = queue_create(0, NULL);
|
|
PipelineContextSender* ctx = pipeline_context_sender_create(cfg, q1, q2);
|
|
EXPECT_NOT_NULL(ctx);
|
|
EXPECT_EQ_INT(ctx->queue_scanner->capacity, 0);
|
|
EXPECT_EQ_INT(ctx->queue_loader->capacity, 0);
|
|
pipeline_context_sender_destroy(ctx);
|
|
}
|
|
|
|
/* Test receiver with zero file_descriptor */
|
|
static void test_receiver_fd_zero() {
|
|
Config* cfg = config_create();
|
|
free(cfg->version);
|
|
cfg->version = str_dup("5.0");
|
|
cfg->send_directory = str_dup("/src");
|
|
cfg->receive_root_directory = str_dup("/dst");
|
|
Queue* q = queue_create(5, NULL);
|
|
PipelineContextReceiver* ctx = pipeline_context_receiver_create(cfg, q, 0);
|
|
EXPECT_NOT_NULL(ctx);
|
|
EXPECT_EQ_INT(ctx->file_descriptor, 0);
|
|
EXPECT_FALSE(ctx->receiver_done);
|
|
pipeline_context_receiver_destroy(ctx);
|
|
}
|
|
|
|
void test_multiprocessing() {
|
|
test_sender_create_destroy();
|
|
test_receiver_create_destroy();
|
|
test_sender_queue_capacities();
|
|
test_sender_zero_capacity();
|
|
test_receiver_fd_zero();
|
|
}
|