mirror of
https://github.com/ByteWelder/Tactility.git
synced 2026-02-19 23:15:05 +00:00
Restructure ObjectFileReader/Writer for improved debugging
This commit is contained in:
parent
3836301c6e
commit
2d0b78d497
@ -9,6 +9,7 @@ if (DEFINED ENV{ESP_IDF_VERSION})
|
|||||||
idf_component_register(
|
idf_component_register(
|
||||||
SRCS ${SOURCE_FILES}
|
SRCS ${SOURCE_FILES}
|
||||||
INCLUDE_DIRS "Include/"
|
INCLUDE_DIRS "Include/"
|
||||||
|
PRIV_INCLUDE_DIRS "Private/"
|
||||||
REQUIRES mbedtls nvs_flash esp_rom esp_timer
|
REQUIRES mbedtls nvs_flash esp_rom esp_timer
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -24,6 +25,10 @@ else()
|
|||||||
PRIVATE ${SOURCES}
|
PRIVATE ${SOURCES}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
include_directories(
|
||||||
|
PRIVATE Private/
|
||||||
|
)
|
||||||
|
|
||||||
target_include_directories(TactilityCore SYSTEM
|
target_include_directories(TactilityCore SYSTEM
|
||||||
PUBLIC Include/
|
PUBLIC Include/
|
||||||
)
|
)
|
||||||
|
|||||||
19
TactilityCore/Private/Tactility/file/ObjectFilePrivate.h
Normal file
19
TactilityCore/Private/Tactility/file/ObjectFilePrivate.h
Normal file
@ -0,0 +1,19 @@
|
|||||||
|
#pragma once
|
||||||
|
|
||||||
|
namespace tt::file {
|
||||||
|
|
||||||
|
constexpr uint32_t OBJECT_FILE_IDENTIFIER = 0x13371337;
|
||||||
|
constexpr uint32_t OBJECT_FILE_VERSION = 1;
|
||||||
|
|
||||||
|
struct FileHeader {
|
||||||
|
uint32_t identifier = OBJECT_FILE_IDENTIFIER;
|
||||||
|
uint32_t version = OBJECT_FILE_VERSION;
|
||||||
|
};
|
||||||
|
|
||||||
|
struct ContentHeader {
|
||||||
|
uint32_t recordVersion = 0;
|
||||||
|
uint32_t recordSize = 0;
|
||||||
|
uint32_t recordCount = 0;
|
||||||
|
};
|
||||||
|
|
||||||
|
}
|
||||||
78
TactilityCore/Source/file/ObjectFileReader.cpp
Normal file
78
TactilityCore/Source/file/ObjectFileReader.cpp
Normal file
@ -0,0 +1,78 @@
|
|||||||
|
#include "Tactility/file/ObjectFile.h"
|
||||||
|
#include "Tactility/file/ObjectFilePrivate.h"
|
||||||
|
|
||||||
|
#include <cstring>
|
||||||
|
#include <Tactility/Log.h>
|
||||||
|
|
||||||
|
namespace tt::file {
|
||||||
|
|
||||||
|
constexpr const char* TAG = "ObjectFileReader";
|
||||||
|
|
||||||
|
bool ObjectFileReader::open() {
|
||||||
|
auto opening_file = std::unique_ptr<FILE, FileCloser>(fopen(filePath.c_str(), "r"));
|
||||||
|
if (opening_file == nullptr) {
|
||||||
|
TT_LOG_E(TAG, "Failed to open file %s", filePath.c_str());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
FileHeader file_header;
|
||||||
|
if (fread(&file_header, sizeof(FileHeader), 1, opening_file.get()) != 1) {
|
||||||
|
TT_LOG_E(TAG, "Failed to read file header from %s", filePath.c_str());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (file_header.identifier != OBJECT_FILE_IDENTIFIER) {
|
||||||
|
TT_LOG_E(TAG, "Invalid file type for %s", filePath.c_str());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (file_header.version != OBJECT_FILE_VERSION) {
|
||||||
|
TT_LOG_E(TAG, "Unknown version for %s: %lu", filePath.c_str(), file_header.identifier);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
ContentHeader content_header;
|
||||||
|
if (fread(&content_header, sizeof(ContentHeader), 1, opening_file.get()) != 1) {
|
||||||
|
TT_LOG_E(TAG, "Failed to read content header from %s", filePath.c_str());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (recordSize != content_header.recordSize) {
|
||||||
|
TT_LOG_E(TAG, "Record size mismatch for %s: expected %lu, got %lu", filePath.c_str(), recordSize, content_header.recordSize);
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
recordCount = content_header.recordCount;
|
||||||
|
recordVersion = content_header.recordVersion;
|
||||||
|
|
||||||
|
file = std::move(opening_file);
|
||||||
|
|
||||||
|
TT_LOG_D(TAG, "File version: %lu", file_header.version);
|
||||||
|
TT_LOG_D(TAG, "Content: version = %lu, size = %lu bytes, count = %lu", content_header.recordVersion, content_header.recordSize, content_header.recordCount);
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ObjectFileReader::close() {
|
||||||
|
recordCount = 0;
|
||||||
|
recordVersion = 0;
|
||||||
|
recordsRead = 0;
|
||||||
|
|
||||||
|
file = nullptr;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool ObjectFileReader::readNext(void* output) {
|
||||||
|
if (file == nullptr) {
|
||||||
|
TT_LOG_E(TAG, "File not open");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool result = fread(output, recordSize, 1, file.get()) == 1;
|
||||||
|
if (result) {
|
||||||
|
recordsRead++;
|
||||||
|
}
|
||||||
|
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@ -1,107 +1,25 @@
|
|||||||
#include "Tactility/file/ObjectFile.h"
|
#include "Tactility/file/ObjectFile.h"
|
||||||
|
#include "Tactility/file/ObjectFilePrivate.h"
|
||||||
|
|
||||||
|
#include <cstring>
|
||||||
#include <Tactility/Log.h>
|
#include <Tactility/Log.h>
|
||||||
#include <unistd.h>
|
#include <unistd.h>
|
||||||
|
|
||||||
namespace tt::file {
|
namespace tt::file {
|
||||||
|
|
||||||
constexpr const char* TAG = "ObjectFile";
|
constexpr const char* TAG = "ObjectFileWriter";
|
||||||
|
|
||||||
constexpr uint32_t OBJECT_FILE_IDENTIFIER = 0x13371337;
|
|
||||||
constexpr uint32_t OBJECT_FILE_VERSION = 1;
|
|
||||||
|
|
||||||
struct FileHeader {
|
|
||||||
uint32_t identifier = OBJECT_FILE_IDENTIFIER;
|
|
||||||
uint32_t version = OBJECT_FILE_VERSION;
|
|
||||||
};
|
|
||||||
|
|
||||||
struct ContentHeader {
|
|
||||||
uint32_t recordVersion = 0;
|
|
||||||
uint32_t recordSize = 0;
|
|
||||||
uint32_t recordCount = 0;
|
|
||||||
};
|
|
||||||
|
|
||||||
// region Reader
|
|
||||||
|
|
||||||
bool ObjectFileReader::open() {
|
|
||||||
auto opening_file = std::unique_ptr<FILE, FileCloser>(fopen(filePath.c_str(), "r"));
|
|
||||||
if (opening_file == nullptr) {
|
|
||||||
TT_LOG_E(TAG, "Failed to open file %s", filePath.c_str());
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
FileHeader file_header;
|
|
||||||
if (fread(&file_header, sizeof(FileHeader), 1, opening_file.get()) != 1) {
|
|
||||||
TT_LOG_E(TAG, "Failed to read file header from %s", filePath.c_str());
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (file_header.identifier != OBJECT_FILE_IDENTIFIER) {
|
|
||||||
TT_LOG_E(TAG, "Invalid file type for %s", filePath.c_str());
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (file_header.version != OBJECT_FILE_VERSION) {
|
|
||||||
TT_LOG_E(TAG, "Unknown version for %s: %lu", filePath.c_str(), file_header.identifier);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
ContentHeader content_header;
|
|
||||||
if (fread(&content_header, sizeof(ContentHeader), 1, opening_file.get()) != 1) {
|
|
||||||
TT_LOG_E(TAG, "Failed to read content header from %s", filePath.c_str());
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
if (recordSize != content_header.recordSize) {
|
|
||||||
TT_LOG_E(TAG, "Record size mismatch for %s: expected %lu, got %lu", filePath.c_str(), recordSize, content_header.recordSize);
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
recordCount = content_header.recordCount;
|
|
||||||
recordVersion = content_header.recordVersion;
|
|
||||||
|
|
||||||
file = std::move(opening_file);
|
|
||||||
|
|
||||||
TT_LOG_D(TAG, "File version: %lu", file_header.version);
|
|
||||||
TT_LOG_D(TAG, "Content: version = %lu, size = %lu bytes, count = %lu", content_header.recordVersion, content_header.recordSize, content_header.recordCount);
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
|
|
||||||
void ObjectFileReader::close() {
|
|
||||||
recordCount = 0;
|
|
||||||
recordVersion = 0;
|
|
||||||
recordsRead = 0;
|
|
||||||
|
|
||||||
file = nullptr;
|
|
||||||
}
|
|
||||||
|
|
||||||
bool ObjectFileReader::readNext(void* output) {
|
|
||||||
if (file == nullptr) {
|
|
||||||
TT_LOG_E(TAG, "File not open");
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
bool result = fread(output, recordSize, 1, file.get()) == 1;
|
|
||||||
if (result) {
|
|
||||||
recordsRead++;
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
}
|
|
||||||
|
|
||||||
// endregion Reader
|
|
||||||
|
|
||||||
// region Writer
|
|
||||||
|
|
||||||
bool ObjectFileWriter::open() {
|
bool ObjectFileWriter::open() {
|
||||||
// If file exists
|
|
||||||
bool edit_existing = append && access(filePath.c_str(), F_OK) == 0;
|
bool edit_existing = append && access(filePath.c_str(), F_OK) == 0;
|
||||||
|
if (append && !edit_existing) {
|
||||||
|
TT_LOG_W(TAG, "access() to %s failed: %s", filePath.c_str(), strerror(errno));
|
||||||
|
}
|
||||||
|
|
||||||
|
// Edit existing or create a new file
|
||||||
auto* mode = edit_existing ? "r+" : "w";
|
auto* mode = edit_existing ? "r+" : "w";
|
||||||
auto opening_file = std::unique_ptr<FILE, FileCloser>(fopen(filePath.c_str(), mode));
|
auto opening_file = std::unique_ptr<FILE, FileCloser>(std::fopen(filePath.c_str(), mode));
|
||||||
if (opening_file == nullptr) {
|
if (opening_file == nullptr) {
|
||||||
TT_LOG_E(TAG, "Failed to open file %s", filePath.c_str());
|
TT_LOG_E(TAG, "Failed to open file %s in %s mode", filePath.c_str(), mode);
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
Loading…
x
Reference in New Issue
Block a user