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

fix: address PR review comments

Browse Source 
- Rename receive_file_receive -> file_receive (comment 62)
- Guard metadata receive with config->use_metadata in server.c (comment 63)
- Add NULL check after malloc in file_load_data (comment 66)
- Make chunk_serialize/chunk_deserialize metadata conditional on use_metadata param,
  thread through chunk_compress/chunk_decompress (comment 65)
- Add missing stdbool.h include to chunk.h
This commit is contained in:
TapTap
2026-07-05 20:45:34 +02:00
parent 660834d453
commit 5fa0dc11e1
7 changed files with 42 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/client/client.c
+2 -2
View File
@@ -21,11 +21,11 @@ int send_chunk(Client *client, Chunk *chunk, Config *config) {
send_status(client->file_descriptor, STATUS_CHUNK);
Data *data;
if (config->use_compression) {
data = chunk_compress(chunk, config->compression_level);
data = chunk_compress(chunk, config->compression_level, config->use_metadata);
} else {
for (int i = 0; i < chunk->element_count; i++)
file_load_data(chunk->items[i]);
data = chunk_serialize(chunk);
data = chunk_serialize(chunk, config->use_metadata);
}
send_data(client->file_descriptor, data->data, data->size);
data_destroy(data);
src/server/server.c
+7 -6
View File
@@ -12,11 +12,12 @@
#include <stdlib.h>
#include <threads.h>
File *receive_file_receive(Config *config, int file_descriptor) {
File *file_receive(Config *config, int file_descriptor) {
char *path = (char *)receive_str(file_descriptor);
File *file = file_create(path);
free(path);
file->metadata = file_receive_metadata(file_descriptor);
if (config->use_metadata)
file->metadata = file_receive_metadata(file_descriptor);
Data *file_data = receive_data(file_descriptor);
if (config->use_compression) {
Data *file_data_uncompressed = data_decompress(file_data);
@@ -37,7 +38,7 @@ static void receive_chunk_enqueue(int file_descriptor, Config *config,
data_to_process = data_decompress(chunk_data);
data_destroy(chunk_data);
}
Chunk *chunk = chunk_deserialize(data_to_process);
Chunk *chunk = chunk_deserialize(data_to_process, config->use_metadata);
data_destroy(data_to_process);
for (int i = 0; i < chunk->element_count; i++) {
@@ -63,7 +64,7 @@ int receive_thread(void *pipeline_context) {
if (status == STATUS_CHUNK) {
receive_chunk_enqueue(file_descriptor, config, context);
} else {
File *file = receive_file_receive(config, file_descriptor);
File *file = file_receive(config, file_descriptor);
queue_enqueue_multithreaded(context->queue, file, &context->mutex,
&context->condition_not_empty,
&context->condition_not_full);
@@ -113,7 +114,7 @@ int receive_files(Config *config, int file_descriptor) {
data_to_process = data_decompress(chunk_data);
data_destroy(chunk_data);
}
Chunk *chunk = chunk_deserialize(data_to_process);
Chunk *chunk = chunk_deserialize(data_to_process, config->use_metadata);
data_destroy(data_to_process);
for (int i = 0; i < chunk->element_count; i++) {
@@ -126,7 +127,7 @@ int receive_files(Config *config, int file_descriptor) {
}
chunk_destroy(chunk);
} else {
File *file = receive_file_receive(config, file_descriptor);
File *file = file_receive(config, file_descriptor);
if (config->save_to_disk) {
char *disk_path = path_cat(config->receive_root_directory, file->path);
to_disk(disk_path, file->data->data, file->data->size);
src/shared/chunk.c
+18 -15
View File
@@ -133,16 +133,16 @@ Data *chunk_format(Chunk *chunk) {
return chunk_data_create(data, buffer_size);
}
static unsigned long long per_file_serialize_size(File *file) {
return sizeof(size_t) + strlen(file->path) + sizeof(int) +
(file->metadata ? FILE_METADATA_WIRE_SIZE : 0) +
static unsigned long long per_file_serialize_size(File *file, bool use_metadata) {
return sizeof(size_t) + strlen(file->path) +
(use_metadata ? sizeof(int) + (file->metadata ? FILE_METADATA_WIRE_SIZE : 0) : 0) +
sizeof(size_t) + file->data->size;
}
Data *chunk_serialize(Chunk *chunk) {
Data *chunk_serialize(Chunk *chunk, bool use_metadata) {
unsigned long long data_size = 0;
for (int i = 0; i < chunk->element_count; i++) {
data_size += per_file_serialize_size(chunk->items[i]);
data_size += per_file_serialize_size(chunk->items[i], use_metadata);
}
Data *data = data_create_empty(data_size);
if (data == NULL) {
@@ -159,7 +159,8 @@ Data *chunk_serialize(Chunk *chunk) {
memcpy(data_pointer, file->path, path_len);
data_pointer += path_len;
metadata_to_buf(&data_pointer, file->metadata);
if (use_metadata)
metadata_to_buf(&data_pointer, file->metadata);
size_t file_data_size = file->data->size;
memcpy(data_pointer, &file_data_size, sizeof(size_t));
@@ -170,7 +171,7 @@ Data *chunk_serialize(Chunk *chunk) {
return data;
}
Chunk *chunk_deserialize(Data *data) {
Chunk *chunk_deserialize(Data *data, bool use_metadata) {
ArrayList *files = array_list_create(file_destroy);
char *data_pointer = data->data;
size_t remaining_size = data->size;
@@ -206,10 +207,12 @@ Chunk *chunk_deserialize(Data *data) {
File *file = file_create(path);
free(path);
file->metadata = metadata_from_buf(&data_pointer);
remaining_size -= sizeof(int);
if (file->metadata)
remaining_size -= FILE_METADATA_WIRE_SIZE;
if (use_metadata) {
file->metadata = metadata_from_buf(&data_pointer);
remaining_size -= sizeof(int);
if (file->metadata)
remaining_size -= FILE_METADATA_WIRE_SIZE;
}
if (remaining_size < sizeof(size_t)) {
log_message(LOG_LEVEL_ERROR, "Invalid chunk format: not enough data for data size");
@@ -252,16 +255,16 @@ Chunk *chunk_deserialize(Data *data) {
return chunk;
}
Data *chunk_compress(Chunk *chunk, int compression_level) {
Data *chunk_compress(Chunk *chunk, int compression_level, bool use_metadata) {
log_message(LOG_LEVEL_DEBUG, "Starting to compress chunk");
Data *serialized = chunk_serialize(chunk);
Data *serialized = chunk_serialize(chunk, use_metadata);
Data *compressed = data_compress(serialized, compression_level);
data_destroy(serialized);
log_message(LOG_LEVEL_DEBUG, "Chunk successfully compressed");
return compressed;
}
Chunk *chunk_decompress(Data *compressed_data) {
Chunk *chunk_decompress(Data *compressed_data, bool use_metadata) {
log_message(LOG_LEVEL_DEBUG, "Starting to decompress chunk");
Data *uncompressed_data = data_decompress(compressed_data);
if (uncompressed_data == NULL) {
@@ -269,7 +272,7 @@ Chunk *chunk_decompress(Data *compressed_data) {
return NULL;
}
Chunk *chunk = chunk_deserialize(uncompressed_data);
Chunk *chunk = chunk_deserialize(uncompressed_data, use_metadata);
if (chunk == NULL) {
log_message(LOG_LEVEL_ERROR, "Failed to deserialize chunk data");
data_destroy(uncompressed_data);
src/shared/chunk.h
+5 -4
View File
@@ -3,6 +3,7 @@
#include "data.h"
#include "file.h"
#include <stdbool.h>
#include <sys/stat.h>
#define DESIRED_CHUNK_SIZE 10 * 1024 * 1024
@@ -16,10 +17,10 @@ Chunk *chunk_create(File **items, int element_count);
void chunk_destroy(void *chunk);
void chunk_print(void *chunk);
Data *chunk_format(Chunk *chunk);
Data *chunk_serialize(Chunk *chunk);
Chunk *chunk_deserialize(Data *data);
Data *chunk_compress(Chunk *chunk, int compression_level);
Chunk *chunk_decompress(Data *compressed_data);
Data *chunk_serialize(Chunk *chunk, bool use_metadata);
Chunk *chunk_deserialize(Data *data, bool use_metadata);
Data *chunk_compress(Chunk *chunk, int compression_level, bool use_metadata);
Chunk *chunk_decompress(Data *compressed_data, bool use_metadata);
Data *chunk_data_create(void *data, unsigned long long data_size);
void chunk_data_delete(void *chunk);
src/shared/file.c
+6 -1
View File
@@ -73,8 +73,13 @@ void file_metadata_destroy(void *metadata) {
void file_load_data(File *file) {
if (file == NULL)
return;
if (file->data->data == NULL)
if (file->data->data == NULL) {
file->data->data = malloc(file->data->size);
if (file->data->data == NULL) {
perror("Could not allocate memory for file data");
exit(EXIT_FAILURE);
}
}
printf("%ld is file big", file->data->size);
size_t bytes_read = file_content_to_buffer(file);
if (bytes_read != file->data->size) {