From be79c014d43dfc6f23eaf966e6543cc64932be8d Mon Sep 17 00:00:00 2001 From: TapTap Date: Tue, 21 Jul 2026 16:43:40 +0200 Subject: [PATCH] feat: add CLI flags (#95-#99, #103-#105) --- src/client/client_cli.c | 8 ++++---- src/client/client_send.c | 8 ++++---- src/client/scanner.c | 3 +-- src/client/scanner.h | 3 +-- src/server/server.c | 3 +-- src/shared/multiprocessing.c | 3 +-- 6 files changed, 12 insertions(+), 16 deletions(-) diff --git a/src/client/client_cli.c b/src/client/client_cli.c index 011c1bb..756c386 100644 --- a/src/client/client_cli.c +++ b/src/client/client_cli.c @@ -290,14 +290,14 @@ int main(int argc, char* argv[]) { goto cleanup; } } else if (strcmp(argv[i], "--exclude-from") == 0 && i + 1 < argc) { - if (read_patterns_from_file(argv[++i], &config->exclude_patterns, - &config->exclude_count) != 0) { + if (read_patterns_from_file(argv[++i], &config->exclude_patterns, &config->exclude_count) != + 0) { exit_code = 1; goto cleanup; } } else if (strcmp(argv[i], "--include-from") == 0 && i + 1 < argc) { - if (read_patterns_from_file(argv[++i], &config->include_patterns, - &config->include_count) != 0) { + if (read_patterns_from_file(argv[++i], &config->include_patterns, &config->include_count) != + 0) { exit_code = 1; goto cleanup; } diff --git a/src/client/client_send.c b/src/client/client_send.c index 27376b1..8dfb2af 100644 --- a/src/client/client_send.c +++ b/src/client/client_send.c @@ -365,8 +365,8 @@ static int scan_directory_multithreaded(void* pipeline_context) { DirectoryScanner* scanner = directory_scanner_create( context->config->send_directory, context->config->use_metadata, context->config->chunk_size, context->config->exclude_patterns, context->config->exclude_count, - context->config->include_patterns, context->config->include_count, context->config->max_size, - context->config->min_size, context->config->max_depth); + context->config->include_patterns, context->config->include_count, context->config->max_size, + context->config->min_size, context->config->max_depth); mtx_unlock(&context->mutex_scanner); Chunk* current_chunk; @@ -491,7 +491,7 @@ int send_files(Config* config) { DirectoryScanner* scanner = directory_scanner_create( config->send_directory, config->use_metadata, config->chunk_size, config->exclude_patterns, config->exclude_count, config->include_patterns, config->include_count, config->max_size, - config->min_size, config->max_depth); + config->min_size, config->max_depth); ArrayList* all_files = array_list_create(NULL); ArrayList* manifest = config->use_delete ? array_list_create(free) : NULL; Chunk* current_chunk; @@ -564,7 +564,7 @@ int send_files(Config* config) { continue; } if (!file_send_single_calls(file, client->file_descriptor, config->use_metadata, - compression_level, true)) { + compression_level, true)) { log_message(LOG_LEVEL_ERROR, "Failed to send file"); batch_ok = false; break; diff --git a/src/client/scanner.c b/src/client/scanner.c index 5b49188..10c3278 100644 --- a/src/client/scanner.c +++ b/src/client/scanner.c @@ -37,8 +37,7 @@ DirectoryScanner* directory_scanner_create(char* root_directory, bool use_metada unsigned long long chunk_size, char** exclude_patterns, int exclude_count, char** include_patterns, int include_count, unsigned long long max_size, - unsigned long long min_size, - int max_depth) { + unsigned long long min_size, int max_depth) { DirectoryScanner* scanner = malloc(sizeof(DirectoryScanner)); if (scanner == NULL) return NULL; diff --git a/src/client/scanner.h b/src/client/scanner.h index eb0146e..a9e6c0d 100644 --- a/src/client/scanner.h +++ b/src/client/scanner.h @@ -26,8 +26,7 @@ DirectoryScanner* directory_scanner_create(char* root_directory, bool use_metada unsigned long long chunk_size, char** exclude_patterns, int exclude_count, char** include_patterns, int include_count, unsigned long long max_size, - unsigned long long min_size, - int max_depth); + unsigned long long min_size, int max_depth); Chunk* directory_scanner_next(DirectoryScanner* scanner); void directory_scanner_destroy(DirectoryScanner* scanner); diff --git a/src/server/server.c b/src/server/server.c index 5e59938..2e045ca 100644 --- a/src/server/server.c +++ b/src/server/server.c @@ -22,8 +22,7 @@ int receive_files(Config* config, int fd) { return -1; while (status == STATUS_NEXT || status == STATUS_CHUNK || status == STATUS_CHECK || - status == STATUS_KEEPALIVE || status == STATUS_ABORT || - status == STATUS_CHECK_BATCH) { + status == STATUS_KEEPALIVE || status == STATUS_ABORT || status == STATUS_CHECK_BATCH) { if (status == STATUS_KEEPALIVE) { send_status(fd, STATUS_KEEPALIVE); goto next; diff --git a/src/shared/multiprocessing.c b/src/shared/multiprocessing.c index a008059..9aaa599 100644 --- a/src/shared/multiprocessing.c +++ b/src/shared/multiprocessing.c @@ -106,8 +106,7 @@ int receive_thread(void* pipeline_context) { if (!receive_status(file_descriptor, &status)) return thrd_error; while (status == STATUS_NEXT || status == STATUS_CHUNK || status == STATUS_CHECK || - status == STATUS_KEEPALIVE || status == STATUS_ABORT || - status == STATUS_CHECK_BATCH) { + status == STATUS_KEEPALIVE || status == STATUS_ABORT || status == STATUS_CHECK_BATCH) { if (status == STATUS_KEEPALIVE) { send_status(file_descriptor, STATUS_KEEPALIVE); goto next;