summaryrefslogtreecommitdiff
path: root/tests/storage_test.c
diff options
context:
space:
mode:
Diffstat (limited to 'tests/storage_test.c')
-rw-r--r--tests/storage_test.c130
1 files changed, 89 insertions, 41 deletions
diff --git a/tests/storage_test.c b/tests/storage_test.c
index bac0f0b..3217095 100644
--- a/tests/storage_test.c
+++ b/tests/storage_test.c
@@ -1,7 +1,5 @@
-#define WIN32_LEAN_AND_MEAN
-#include <windows.h>
-
#include "storage/store.h"
+#include "sys/system.h"
#include <stdio.h>
#include <stdlib.h>
@@ -19,24 +17,69 @@ static int failures;
} \
while (0)
+static char *
+duplicate_string(const char *value)
+{
+ const size_t length = strlen(value);
+ char *copy = malloc(length + 1);
+ if (copy != NULL)
+ {
+ memcpy(copy, value, length + 1);
+ }
+ return copy;
+}
+
int
-wmain(void)
+main(void)
{
- wchar_t temporary[MAX_PATH], directory[MAX_PATH], log_path[MAX_PATH];
+ char *temporary_root = tiny_sys_temp_directory_create("tcm");
+ char *directory;
+ char *log_path;
+ char *temporary_path;
+ char *lock_path;
+ char *snapshot_path;
tiny_store_t *store = NULL, *second = NULL;
tiny_message_t input, first, second_message;
tiny_store_status_t status;
- HANDLE log;
- HANDLE blocker;
+ tiny_sys_file_t log;
tiny_rebuild_report_t report;
- LARGE_INTEGER position;
unsigned char byte;
- DWORD count;
+ uint32_t count;
+ tiny_store_health_t health;
+ size_t operation;
+ static const tiny_sys_test_operation_t rebuild_failures[] = { TINY_SYS_TEST_OPEN,
+ TINY_SYS_TEST_RANDOM,
+ TINY_SYS_TEST_WRITE,
+ TINY_SYS_TEST_FLUSH,
+ TINY_SYS_TEST_REPLACE };
+
+ CHECK(tiny_store_open(NULL, "unused") == TINY_STORE_IO_ERROR);
+ store = (tiny_store_t *)(uintptr_t)1;
+ CHECK(tiny_store_open(&store, NULL) == TINY_STORE_IO_ERROR && store == NULL);
+ CHECK(tiny_store_entry_count(NULL) == 0);
+ CHECK(tiny_store_entry(NULL, 0) == NULL);
+ memset(&health, 0xff, sizeof(health));
+ tiny_store_health(NULL, &health);
+ CHECK(health.active_messages == 0 && health.log_size == 0);
+
+ CHECK(temporary_root != NULL);
+ if (temporary_root == NULL)
+ {
+ return 1;
+ }
+ directory = tiny_sys_path_join(temporary_root, "日本語-memory");
+ CHECK(directory != NULL && tiny_sys_directory_create(directory) == TINY_SYS_OK);
+ if (directory == NULL)
+ {
+ free(temporary_root);
+ return 1;
+ }
+ log_path = tiny_sys_path_join(directory, "active.log");
+ temporary_path = tiny_sys_path_join(directory, "active.tmp");
+ lock_path = tiny_sys_path_join(directory, "store.lock");
+ snapshot_path = tiny_sys_path_join(directory, "snapshot.bin");
+ CHECK(log_path != NULL && temporary_path != NULL && lock_path != NULL && snapshot_path != NULL);
- CHECK(GetTempPathW(MAX_PATH, temporary) > 0);
- CHECK(GetTempFileNameW(temporary, L"tcm", 0, directory) > 0);
- DeleteFileW(directory);
- CHECK(CreateDirectoryW(directory, NULL) != 0);
status = tiny_store_open(&store, directory);
CHECK(status == TINY_STORE_OK);
CHECK(tiny_store_open(&second, directory) == TINY_STORE_BUSY);
@@ -44,12 +87,12 @@ wmain(void)
tiny_message_init(&input);
tiny_message_init(&first);
tiny_message_init(&second_message);
- input.session_id = _strdup("unit");
- input.content = _strdup("first");
+ input.session_id = duplicate_string("unit");
+ input.content = duplicate_string("first");
input.role = TINY_ROLE_USER;
CHECK(tiny_store_write(store, &input, &first) == TINY_STORE_OK);
free(input.content);
- input.content = _strdup("second");
+ input.content = duplicate_string("second");
CHECK(tiny_store_write(store, &input, &second_message) == TINY_STORE_OK);
CHECK(strcmp(first.message_id, second_message.message_id) < 0);
tiny_message_free(&input);
@@ -60,38 +103,43 @@ wmain(void)
CHECK(tiny_store_open(&store, directory) == TINY_STORE_OK);
CHECK(tiny_store_entry_count(store) == 2);
- swprintf_s(log_path, MAX_PATH, L"%s\\active.tmp", directory);
- blocker = CreateFileW(
- log_path, GENERIC_READ | GENERIC_WRITE, 0, NULL, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
- CHECK(blocker != INVALID_HANDLE_VALUE);
+ for (operation = 0; operation < sizeof(rebuild_failures) / sizeof(rebuild_failures[0]);
+ ++operation)
+ {
+ tiny_sys_test_reset();
+ CHECK(tiny_sys_test_fail_after(rebuild_failures[operation], 1));
+ CHECK(tiny_store_rebuild(store, &report) != TINY_STORE_OK);
+ CHECK(tiny_store_entry_count(store) == 2);
+ tiny_sys_test_reset();
+ (void)tiny_sys_file_remove(temporary_path);
+ }
+ CHECK(tiny_sys_directory_create(temporary_path) == TINY_SYS_OK);
CHECK(tiny_store_rebuild(store, &report) == TINY_STORE_IO_ERROR);
CHECK(tiny_store_entry_count(store) == 2);
- CloseHandle(blocker);
- DeleteFileW(log_path);
+ CHECK(tiny_sys_directory_remove(temporary_path));
tiny_store_close(store);
store = NULL;
- swprintf_s(log_path, MAX_PATH, L"%s\\active.log", directory);
- log = CreateFileW(
- log_path, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
- CHECK(log != INVALID_HANDLE_VALUE);
- position.QuadPart = -1;
- CHECK(SetFilePointerEx(log, position, NULL, FILE_END) != 0);
- CHECK(ReadFile(log, &byte, 1, &count, NULL) != 0 && count == 1);
+ CHECK(tiny_sys_file_open(&log, log_path, TINY_SYS_FILE_READ_WRITE) == TINY_SYS_OK);
+ CHECK(tiny_sys_file_seek(&log, -1, TINY_SYS_SEEK_END));
+ CHECK(tiny_sys_file_read(&log, &byte, 1, &count) && count == 1);
byte ^= 0x5a;
- position.QuadPart = -1;
- CHECK(SetFilePointerEx(log, position, NULL, FILE_CURRENT) != 0);
- CHECK(WriteFile(log, &byte, 1, &count, NULL) != 0 && count == 1);
- CloseHandle(log);
+ CHECK(tiny_sys_file_seek(&log, -1, TINY_SYS_SEEK_CURRENT));
+ CHECK(tiny_sys_file_write(&log, &byte, 1, &count) && count == 1);
+ tiny_sys_file_close(&log);
CHECK(tiny_store_open(&store, directory) == TINY_STORE_CORRUPT);
- DeleteFileW(log_path);
- swprintf_s(log_path, MAX_PATH, L"%s\\active.tmp", directory);
- DeleteFileW(log_path);
- swprintf_s(log_path, MAX_PATH, L"%s\\store.lock", directory);
- DeleteFileW(log_path);
- swprintf_s(log_path, MAX_PATH, L"%s\\snapshot.bin", directory);
- DeleteFileW(log_path);
- RemoveDirectoryW(directory);
+ (void)tiny_sys_file_remove(log_path);
+ (void)tiny_sys_file_remove(temporary_path);
+ (void)tiny_sys_file_remove(lock_path);
+ (void)tiny_sys_file_remove(snapshot_path);
+ (void)tiny_sys_directory_remove(directory);
+ (void)tiny_sys_directory_remove(temporary_root);
+ free(snapshot_path);
+ free(lock_path);
+ free(temporary_path);
+ free(log_path);
+ free(directory);
+ free(temporary_root);
return failures == 0 ? 0 : 1;
}
generated by cgit v1.2.3 (git 2.39.1) at 2026-10-19 19:40:34 +0000