TapTap
8f4ea62ae7
Phase 1 — Bugs: - receive_data: fix unsigned long long vs size_t mismatch - chunk_deserialize: add NULL check in multiprocessing.c and server.c - file_content_to_buffer: add missing fclose on error path - send_files_multithreaded: propagate sender thread result - server: add SIGPIPE handler - to_disk: check fwrite return value - scanner: use S_ISDIR instead of !S_ISREG - scanner: free cur_path before early return Phase 2 — Cleanup: - Remove unused chunk_decompress function - Remove unused array_list_clear function - Remove unused num_connections config field - Remove duplicate FILE_METADATA_WIRE_SIZE macro - Update tests for removed APIs
94 lines
3.4 KiB
C
94 lines
3.4 KiB
C
#include "config.h"
|
|
#include "protocol.h"
|
|
#include "utils.h"
|
|
#include <stdbool.h>
|
|
#include <stdio.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
|
|
Config *config_create(char *version, char *send_directory,
|
|
char *receive_directory, bool save_to_disk,
|
|
bool use_multithreading, bool use_chunk_serialization,
|
|
bool use_compression, bool use_metadata,
|
|
int compression_level, bool use_sendfile) {
|
|
|
|
Config *config = malloc(sizeof(Config));
|
|
config->version = version;
|
|
config->send_directory = send_directory;
|
|
config->receive_root_directory = receive_directory;
|
|
config->save_to_disk = save_to_disk;
|
|
config->use_multithreading = use_multithreading;
|
|
config->use_chunk_serialization = use_chunk_serialization;
|
|
config->use_compression = use_compression;
|
|
config->use_metadata = use_metadata;
|
|
config->compression_level = compression_level;
|
|
config->use_sendfile = use_sendfile;
|
|
config->transport = TRANSPORT_TCP;
|
|
config->ssh_destination = NULL;
|
|
return config;
|
|
}
|
|
|
|
bool is_remote_dest(const char *s) {
|
|
if (s == NULL) return false;
|
|
const char *colon = strchr(s, ':');
|
|
if (colon == NULL) return false;
|
|
if (colon == s) return false;
|
|
for (const char *p = s; p < colon; p++) {
|
|
if (*p == '/') return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
void config_parse_ssh_dest(Config *config) {
|
|
if (!is_remote_dest(config->receive_root_directory)) return;
|
|
config->transport = TRANSPORT_SSH;
|
|
config->ssh_destination = str_dup(config->receive_root_directory);
|
|
char *colon = strchr(config->receive_root_directory, ':');
|
|
char *path = str_dup(colon + 1);
|
|
free(config->receive_root_directory);
|
|
config->receive_root_directory = path;
|
|
}
|
|
|
|
void config_delete(Config *config) {
|
|
free(config->version);
|
|
free(config->send_directory);
|
|
free(config->receive_root_directory);
|
|
free(config->ssh_destination);
|
|
free(config);
|
|
}
|
|
|
|
void config_send(int file_descriptor, Config *config) {
|
|
send_str(file_descriptor, config->version);
|
|
send_str(file_descriptor, config->send_directory);
|
|
send_str(file_descriptor, config->receive_root_directory);
|
|
send_int(file_descriptor, config->save_to_disk);
|
|
send_int(file_descriptor, config->use_multithreading);
|
|
send_int(file_descriptor, config->use_chunk_serialization);
|
|
send_int(file_descriptor, config->use_compression);
|
|
send_int(file_descriptor, config->use_metadata);
|
|
send_int(file_descriptor, config->compression_level);
|
|
send_int(file_descriptor, config->use_sendfile);
|
|
if (receive_status(file_descriptor) != STATUS_OK) {
|
|
perror("Error transmitting config!");
|
|
exit(EXIT_FAILURE);
|
|
}
|
|
}
|
|
|
|
Config *config_receive(int file_descriptor) {
|
|
Config *config = (Config *)malloc(sizeof(Config));
|
|
config->version = receive_str(file_descriptor);
|
|
config->send_directory = receive_str(file_descriptor);
|
|
config->receive_root_directory = receive_str(file_descriptor);
|
|
config->save_to_disk = receive_int(file_descriptor);
|
|
config->use_multithreading = receive_int(file_descriptor);
|
|
config->use_chunk_serialization = receive_int(file_descriptor);
|
|
config->use_compression = receive_int(file_descriptor);
|
|
config->use_metadata = receive_int(file_descriptor);
|
|
config->compression_level = receive_int(file_descriptor);
|
|
config->use_sendfile = receive_int(file_descriptor);
|
|
config->transport = TRANSPORT_TCP;
|
|
config->ssh_destination = NULL;
|
|
send_status(file_descriptor, STATUS_OK);
|
|
return config;
|
|
}
|