cozis/ToastyFS
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add fault injection of disk operations

Browse Source
This commit is contained in:
cozis
2026-01-24 11:53:38 +01:00
parent 7306bd1203
commit 07bc952cb9
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
quakey/src/quakey.c
+16
View File
@@ -1695,6 +1695,10 @@ static int host_read(Host *host, int desc_idx, char *dst, int len)
if (desc->type == DESC_SOCKET_C) { if (desc->type == DESC_SOCKET_C) {
num = recv_inner(desc, dst, len); num = recv_inner(desc, dst, len);
} else if (desc->type == DESC_FILE) { } else if (desc->type == DESC_FILE) {
#ifdef FAULT_INJECTION
uint64_t roll = sim_random(host->sim) % 1000;
if (roll == 0) return HOST_ERROR_IO;
#endif
int ret = mockfs_read(&desc->file, dst, len); int ret = mockfs_read(&desc->file, dst, len);
if (ret < 0) if (ret < 0)
return mockfs_to_quakey_error(ret); return mockfs_to_quakey_error(ret);
@@ -1724,6 +1728,12 @@ static int host_write(Host *host, int desc_idx, char *src, int len)
if (desc->type == DESC_SOCKET_C) { if (desc->type == DESC_SOCKET_C) {
num = send_inner(desc, src, len); num = send_inner(desc, src, len);
} else if (desc->type == DESC_FILE) { } else if (desc->type == DESC_FILE) {
#ifdef FAULT_INJECTION
uint64_t roll = sim_random(host->sim) % 1000;
if (roll == 0) return HOST_ERROR_IO;
if (roll == 1) return HOST_ERROR_NOSPC;
// TODO: inject corruptions
#endif
int ret = mockfs_write(&desc->file, src, len); int ret = mockfs_write(&desc->file, src, len);
if (ret < 0) if (ret < 0)
return mockfs_to_quakey_error(ret); return mockfs_to_quakey_error(ret);
@@ -1874,6 +1884,12 @@ static int host_fsync(Host *host, int desc_idx)
if (desc->type != DESC_FILE) if (desc->type != DESC_FILE)
return HOST_ERROR_BADIDX; return HOST_ERROR_BADIDX;
#ifdef FAULT_INJECTION
uint64_t roll = sim_random(host->sim) % 100;
if (roll == 0)
return HOST_ERROR_IO;
#endif
int ret = mockfs_sync(&desc->file); int ret = mockfs_sync(&desc->file);
if (ret < 0) if (ret < 0)
return mockfs_to_quakey_error(ret); return mockfs_to_quakey_error(ret);