This is an automated email from the ASF dual-hosted git repository.

reshke pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/cloudberry.git


The following commit(s) were added to refs/heads/main by this push:
     new 8b563fbff30 Fix missing smgrAO calls (#1193)
8b563fbff30 is described below

commit 8b563fbff30c09d4208c83b61cebff1fa19630e5
Author: reshke <[email protected]>
AuthorDate: Wed Jul 2 13:38:24 2025 +0500

    Fix missing smgrAO calls (#1193)
---
 src/backend/cdb/cdbappendonlystorageread.c  | 2 +-
 src/backend/cdb/cdbappendonlystoragewrite.c | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/backend/cdb/cdbappendonlystorageread.c 
b/src/backend/cdb/cdbappendonlystorageread.c
index 67314014997..10e8c57529a 100755
--- a/src/backend/cdb/cdbappendonlystorageread.c
+++ b/src/backend/cdb/cdbappendonlystorageread.c
@@ -437,7 +437,7 @@ AppendOnlyStorageRead_CloseFile(AppendOnlyStorageRead 
*storageRead)
        if (storageRead->file == -1)
                return;
 
-       FileClose(storageRead->file);
+       storageRead->smgrAO->smgr_FileClose(storageRead->file);
 
        storageRead->file = -1;
        storageRead->formatVersion = -1;
diff --git a/src/backend/cdb/cdbappendonlystoragewrite.c 
b/src/backend/cdb/cdbappendonlystoragewrite.c
index fe99836f02f..6a17e1cdd0f 100755
--- a/src/backend/cdb/cdbappendonlystoragewrite.c
+++ b/src/backend/cdb/cdbappendonlystoragewrite.c
@@ -410,14 +410,14 @@ AppendOnlyStorageWrite_FlushAndCloseFile(
         * primary.  Temp tables are not crash safe, no need to fsync them.
         */
        if (!RelFileNodeBackendIsTemp(storageWrite->relFileNode) &&
-               FileSync(storageWrite->file, WAIT_EVENT_DATA_FILE_SYNC) != 0)
+               storageWrite->smgrAO->smgr_FileSync(storageWrite->file, 
WAIT_EVENT_DATA_FILE_SYNC) != 0)
                ereport(ERROR,
                                (errcode_for_file_access(),
                                 errmsg("Could not flush (fsync) Append-Only 
segment file '%s' to disk for relation '%s': %m",
                                                storageWrite->segmentFileName,
                                                storageWrite->relationName)));
 
-       FileClose(storageWrite->file);
+       storageWrite->smgrAO->smgr_FileClose(storageWrite->file);
 
        storageWrite->file = -1;
        storageWrite->formatVersion = -1;


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to