From b2bd1353a9bff1f7881087f6998e8e22fb17dac5 Mon Sep 17 00:00:00 2001 From: MX <10697207+xMasterX@users.noreply.github.com> Date: Wed, 10 Aug 2022 16:53:54 +0300 Subject: [PATCH] Temporary drop storage fixes OFW PR #1563 --- applications/rpc/rpc_storage.c | 64 +++++++++++++----------------- applications/storage/storage_cli.c | 44 ++++++++++---------- lib/toolbox/path.c | 4 -- 3 files changed, 47 insertions(+), 65 deletions(-) diff --git a/applications/rpc/rpc_storage.c b/applications/rpc/rpc_storage.c index 48ea9e998..1e2920f5b 100644 --- a/applications/rpc/rpc_storage.c +++ b/applications/rpc/rpc_storage.c @@ -305,27 +305,21 @@ static void rpc_system_storage_read_process(const PB_Main* request, void* contex response->command_id = request->command_id; response->which_content = PB_Main_storage_read_response_tag; response->command_status = PB_CommandStatus_OK; + response->content.storage_read_response.has_file = true; + response->content.storage_read_response.file.data = + malloc(PB_BYTES_ARRAY_T_ALLOCSIZE(MIN(size_left, MAX_DATA_SIZE))); + uint8_t* buffer = response->content.storage_read_response.file.data->bytes; + uint16_t* read_size_msg = &response->content.storage_read_response.file.data->size; size_t read_size = MIN(size_left, MAX_DATA_SIZE); - if(read_size) { - response->content.storage_read_response.has_file = true; - response->content.storage_read_response.file.data = - malloc(PB_BYTES_ARRAY_T_ALLOCSIZE()); - uint8_t* buffer = response->content.storage_read_response.file.data->bytes; - uint16_t* read_size_msg = &response->content.storage_read_response.file.data->size; + *read_size_msg = storage_file_read(file, buffer, read_size); + size_left -= read_size; + result = (*read_size_msg == read_size); - *read_size_msg = storage_file_read(file, buffer, read_size); - size_left -= read_size; - result = (*read_size_msg == read_size); - - response->has_next = result && (size_left > 0); - } else { - response->content.storage_read_response.has_file = false; - response->has_next = false; - result = true; + if(result) { + response->has_next = (size_left > 0); + rpc_send_and_release(session, response); } - - rpc_send_and_release(session, response); } while((size_left != 0) && result); if(!result) { @@ -355,7 +349,7 @@ static void rpc_system_storage_write_process(const PB_Main* request, void* conte RpcSession* session = rpc_storage->session; furi_assert(session); - bool fs_operation_success = true; + bool result = true; if(!path_contains_only_ascii(request->content.storage_write_request.path)) { rpc_storage->current_command_id = request->command_id; @@ -376,32 +370,28 @@ static void rpc_system_storage_write_process(const PB_Main* request, void* conte rpc_storage->current_command_id = request->command_id; rpc_storage->state = RpcStorageStateWriting; const char* path = request->content.storage_write_request.path; - fs_operation_success = - storage_file_open(rpc_storage->file, path, FSAM_WRITE, FSOM_CREATE_ALWAYS); + result = storage_file_open(rpc_storage->file, path, FSAM_WRITE, FSOM_CREATE_ALWAYS); } File* file = rpc_storage->file; - bool send_response = false; - if(fs_operation_success) { - if(request->content.storage_write_request.has_file) { - uint8_t* buffer = request->content.storage_write_request.file.data->bytes; - size_t buffer_size = request->content.storage_write_request.file.data->size; - uint16_t written_size = storage_file_write(file, buffer, buffer_size); - fs_operation_success = (written_size == buffer_size); + if(result) { + uint8_t* buffer = request->content.storage_write_request.file.data->bytes; + size_t buffer_size = request->content.storage_write_request.file.data->size; + + uint16_t written_size = storage_file_write(file, buffer, buffer_size); + result = (written_size == buffer_size); + + if(result && !request->has_next) { + rpc_send_and_release_empty( + session, rpc_storage->current_command_id, PB_CommandStatus_OK); + rpc_system_storage_reset_state(rpc_storage, session, false); } - - send_response = !request->has_next; } - PB_CommandStatus command_status = PB_CommandStatus_OK; - if(!fs_operation_success) { - send_response = true; - command_status = rpc_system_storage_get_file_error(file); - } - - if(send_response) { - rpc_send_and_release_empty(session, rpc_storage->current_command_id, command_status); + if(!result) { + rpc_send_and_release_empty( + session, rpc_storage->current_command_id, rpc_system_storage_get_file_error(file)); rpc_system_storage_reset_state(rpc_storage, session, false); } } diff --git a/applications/storage/storage_cli.c b/applications/storage/storage_cli.c index 802ebd548..fd988da76 100644 --- a/applications/storage/storage_cli.c +++ b/applications/storage/storage_cli.c @@ -274,26 +274,24 @@ static void storage_cli_read_chunks(Cli* cli, string_t path, string_t args) { if(parsed_count == EOF || parsed_count != 1) { storage_cli_print_usage(); } else if(storage_file_open(file, string_get_cstr(path), FSAM_READ, FSOM_OPEN_EXISTING)) { + uint8_t* data = malloc(buffer_size); uint64_t file_size = storage_file_size(file); printf("Size: %lu\r\n", (uint32_t)file_size); - if(buffer_size) { - uint8_t* data = malloc(buffer_size); - while(file_size > 0) { - printf("\r\nReady?\r\n"); - cli_getc(cli); + while(file_size > 0) { + printf("\r\nReady?\r\n"); + cli_getc(cli); - uint16_t read_size = storage_file_read(file, data, buffer_size); - for(uint16_t i = 0; i < read_size; i++) { - putchar(data[i]); - } - file_size -= read_size; + uint16_t read_size = storage_file_read(file, data, buffer_size); + for(uint16_t i = 0; i < read_size; i++) { + putchar(data[i]); } - free(data); + file_size -= read_size; } printf("\r\n"); + free(data); } else { storage_cli_print_error(storage_file_get_error(file)); } @@ -317,21 +315,19 @@ static void storage_cli_write_chunk(Cli* cli, string_t path, string_t args) { if(storage_file_open(file, string_get_cstr(path), FSAM_WRITE, FSOM_OPEN_APPEND)) { printf("Ready\r\n"); - if(buffer_size) { - uint8_t* buffer = malloc(buffer_size); + uint8_t* buffer = malloc(buffer_size); - for(uint32_t i = 0; i < buffer_size; i++) { - buffer[i] = cli_getc(cli); - } - - uint16_t written_size = storage_file_write(file, buffer, buffer_size); - - if(written_size != buffer_size) { - storage_cli_print_error(storage_file_get_error(file)); - } - - free(buffer); + for(uint32_t i = 0; i < buffer_size; i++) { + buffer[i] = cli_getc(cli); } + + uint16_t written_size = storage_file_write(file, buffer, buffer_size); + + if(written_size != buffer_size) { + storage_cli_print_error(storage_file_get_error(file)); + } + + free(buffer); } else { storage_cli_print_error(storage_file_get_error(file)); } diff --git a/lib/toolbox/path.c b/lib/toolbox/path.c index 1262362ef..38af1efe5 100644 --- a/lib/toolbox/path.c +++ b/lib/toolbox/path.c @@ -85,10 +85,6 @@ void path_concat(const char* path, const char* suffix, string_t out_path) { } bool path_contains_only_ascii(const char* path) { - if(!path) { - return false; - } - const char* name_pos = strrchr(path, '/'); if(name_pos == NULL) { name_pos = path;