TapTap/FastSync
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: pass use_sendfile to config_create

Browse Source
This commit is contained in:
TapTap
2026-07-05 16:38:13 +02:00
parent d0c57ba2bb
commit a48b3e3a17
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/client.c
+1 -1
View File
@@ -201,7 +201,7 @@ int main(int argc, char *argv[]) {
} }
Config *config = config_create(str_dup("1.0.0"), source_dir, dest_dir, Config *config = config_create(str_dup("1.0.0"), source_dir, dest_dir,
save_to_disk, false, false, false, 5, 20); save_to_disk, false, false, false, 5, 20, false);
for (int i = 1; i < argc; i++) { for (int i = 1; i < argc; i++) {
if (strcmp(argv[i], "-c") == 0) { if (strcmp(argv[i], "-c") == 0) {
config->use_compression = true; config->use_compression = true;
src/shared/config.c
+2 -2
View File
@@ -8,7 +8,7 @@ Config *config_create(char *version, char *send_directory,
char *receive_directory, bool save_to_disk, char *receive_directory, bool save_to_disk,
bool use_multithreading, bool use_chunk_serialization, bool use_multithreading, bool use_chunk_serialization,
bool use_compression, int compression_level, bool use_compression, int compression_level,
int num_connections) { int num_connections, bool use_sendfile) {
Config *config = malloc(sizeof(Config)); Config *config = malloc(sizeof(Config));
config->version = version; config->version = version;
@@ -20,7 +20,7 @@ Config *config_create(char *version, char *send_directory,
config->use_compression = use_compression; config->use_compression = use_compression;
config->compression_level = compression_level; config->compression_level = compression_level;
config->num_connections = num_connections; config->num_connections = num_connections;
config->use_sendfile = false; config->use_sendfile = use_sendfile;
return config; return config;
} }
src/shared/config.h
+1 -1
View File
@@ -21,7 +21,7 @@ Config *config_create(char *version, char *send_directory,
char *receive_directory, bool save_to_disk, char *receive_directory, bool save_to_disk,
bool use_multithreading, bool use_chunk_serialization, bool use_multithreading, bool use_chunk_serialization,
bool use_compression, int compression_level, bool use_compression, int compression_level,
int num_connections); int num_connections, bool use_sendfile);
void config_delete(Config *config); void config_delete(Config *config);
void config_send(int file_descriptor, Config *config); void config_send(int file_descriptor, Config *config);
Config *config_receive(int file_descriptor); Config *config_receive(int file_descriptor);
tests/test_config.c
+3 -3
View File
@@ -8,7 +8,7 @@
static void test_config_lifecycle() { static void test_config_lifecycle() {
Config *cfg = config_create(str_dup("1.0"), str_dup("/src"), str_dup("/dst"), Config *cfg = config_create(str_dup("1.0"), str_dup("/src"), str_dup("/dst"),
true, true, false, false, 1, 4); true, true, false, false, 1, 4, false);
EXPECT_NOT_NULL(cfg); EXPECT_NOT_NULL(cfg);
EXPECT_EQ_STR(cfg->version, "1.0"); EXPECT_EQ_STR(cfg->version, "1.0");
EXPECT_EQ_STR(cfg->send_directory, "/src"); EXPECT_EQ_STR(cfg->send_directory, "/src");
@@ -23,7 +23,7 @@ static void test_config_lifecycle() {
static void test_pipeline_sender_lifecycle() { static void test_pipeline_sender_lifecycle() {
Config *cfg = config_create(str_dup("2.0"), str_dup("/src2"), Config *cfg = config_create(str_dup("2.0"), str_dup("/src2"),
str_dup("/dst2"), false, false, true, true, 1, 8); str_dup("/dst2"), false, false, true, true, 1, 8, false);
Queue *q1 = queue_create(5, NULL); Queue *q1 = queue_create(5, NULL);
Queue *q2 = queue_create(15, NULL); Queue *q2 = queue_create(15, NULL);
@@ -40,7 +40,7 @@ static void test_pipeline_sender_lifecycle() {
static void test_pipeline_receiver_lifecycle() { static void test_pipeline_receiver_lifecycle() {
Config *cfg = config_create(str_dup("3.0"), str_dup("/src3"), Config *cfg = config_create(str_dup("3.0"), str_dup("/src3"),
str_dup("/dst3"), true, true, true, true, 1, 2); str_dup("/dst3"), true, true, true, true, 1, 2, false);
Queue *q = queue_create(20, NULL); Queue *q = queue_create(20, NULL);
PipelineContextReceiver *pcr = pipeline_context_receiver_create(cfg, q, 42); PipelineContextReceiver *pcr = pipeline_context_receiver_create(cfg, q, 42);