From e76dc6cb8249c3aad8c6d3fd57f33c6acaad5b8a Mon Sep 17 00:00:00 2001
From: evgeny <evgeny@adaptto.ru>
Date: Tue, 6 Oct 2026 11:25:18 +0200
Subject: [PATCH] Report actual directory creation separately from durability
 errors

---
 src/member_files/disk.c | 12 +++++++++---
 src/member_files/disk.h |  3 ++-
 2 files changed, 11 insertions(+), 4 deletions(-)

diff --git a/src/member_files/disk.c b/src/member_files/disk.c
index ff387a4a..53ba65fc 100644
--- a/src/member_files/disk.c
+++ b/src/member_files/disk.c
@@ -148,10 +148,12 @@ int mf_disk_stat(struct mf_disk_root* root, const char* path, struct mf_disk_inf
 
 int mf_disk_info(int fd, struct mf_disk_info* info) { return disk_handle_info((HANDLE)_get_osfhandle(fd), info); }
 
-int mf_disk_mkdir(struct mf_disk_root* root, const char* path) {
+int mf_disk_mkdir(struct mf_disk_root* root, const char* path, int* created) {
+    if (created) *created = 0;
     struct disk_parent p; int rc = disk_parent_open(root, path, &p);
     if (rc) return rc;
     if (!CreateDirectoryW(p.path, NULL)) rc = disk_win_error("mkdir");
+    else if (created) *created = 1;
     disk_parent_close(&p); return rc;
 }
 
@@ -291,11 +293,15 @@ int mf_disk_info(int fd, struct mf_disk_info* info) {
     struct stat st;
     return fstat(fd, &st) ? disk_error("fstat", NULL) : disk_posix_info(&st, info);
 }
-int mf_disk_mkdir(struct mf_disk_root* root, const char* path) {
+int mf_disk_mkdir(struct mf_disk_root* root, const char* path, int* created) {
+    if (created) *created = 0;
     struct disk_parent p; int rc = disk_parent_open(root, path, &p);
     if (rc) return rc;
     if (mkdirat(p.fd, p.leaf, 0700)) rc = disk_error("mkdir", path);
-    else if (fsync(p.fd)) rc = disk_error("sync mkdir", path);
+    else {
+        if (created) *created = 1;
+        if (fsync(p.fd)) rc = disk_error("sync mkdir", path);
+    }
     close(p.fd); return rc;
 }
 int mf_disk_remove(struct mf_disk_root* root, const char* path, int directory) {
diff --git a/src/member_files/disk.h b/src/member_files/disk.h
index 58291e83..bbdaa334 100644
--- a/src/member_files/disk.h
+++ b/src/member_files/disk.h
@@ -21,7 +21,8 @@ void mf_disk_root_close(struct mf_disk_root* root);
 int mf_disk_open(struct mf_disk_root* root, const char* path, int create, int writable, int* fd);
 int mf_disk_stat(struct mf_disk_root* root, const char* path, struct mf_disk_info* info);
 int mf_disk_info(int fd, struct mf_disk_info* info);
-int mf_disk_mkdir(struct mf_disk_root* root, const char* path);
+/* created, если не NULL, показывает факт создания даже при последующей ошибке sync. */
+int mf_disk_mkdir(struct mf_disk_root* root, const char* path, int* created);
 int mf_disk_remove(struct mf_disk_root* root, const char* path, int directory);
 int mf_disk_rename(struct mf_disk_root* root, const char* from, const char* to);
 typedef int (*mf_disk_entry_fn)(void* arg, const char* name, const struct mf_disk_info* info);