From 7a9a104e7cbe8c305f9afccf45b98d3a481c8ccb Mon Sep 17 00:00:00 2001 From: "@oliverwxx" Date: Mon, 17 Jun 2024 09:55:08 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=86=99=E9=9B=B6=E5=9B=9E?= =?UTF-8?q?=E9=80=80=E8=A1=A5=E5=85=85?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/po/zh_CN.po | 4 ++-- .../storage/smgr/segment/data_file.cpp | 17 ++++++++--------- 2 files changed, 10 insertions(+), 11 deletions(-) diff --git a/src/gausskernel/po/zh_CN.po b/src/gausskernel/po/zh_CN.po index 2ed82dc5e..7947bc6ad 100644 --- a/src/gausskernel/po/zh_CN.po +++ b/src/gausskernel/po/zh_CN.po @@ -104690,8 +104690,8 @@ msgstr "无法找到文件\"%s\": " #: storage/smgr/segment/data_file.cpp:57 #, c-format -msgid "dv_open_file filename: %s, flags is %d, mode is %d, fd is %d" -msgstr "dv_open_file filename: %s, flags is %d, mode is %d, fd is %d" +msgid "dv_open_file filename: %s, flags is %lu, mode is %d, fd is %d" +msgstr "dv_open_file filename: %s, flags is %lu, mode is %d, fd is %d" #: storage/smgr/segment/data_file.cpp:67 #, c-format diff --git a/src/gausskernel/storage/smgr/segment/data_file.cpp b/src/gausskernel/storage/smgr/segment/data_file.cpp index 2c94f1128..dd54725d1 100644 --- a/src/gausskernel/storage/smgr/segment/data_file.cpp +++ b/src/gausskernel/storage/smgr/segment/data_file.cpp @@ -31,14 +31,13 @@ #include "storage/smgr/fd.h" #include "storage/smgr/knl_usync.h" #include "storage/smgr/segment.h" -#include "storage/dss/dss_adaptor.h" #include "storage/file/fio_device.h" #include "postmaster/pagerepair.h" #include "ddes/dms/ss_common_attr.h" static const mode_t SEGMENT_FILE_MODE = S_IWUSR | S_IRUSR; -static int dv_open_file(char *filename, int flags, int mode); +static int dv_open_file(char *filename, uint32 flags, int mode); static void dv_close_file(int fd); static void df_open_target_files(SegLogicFile *sf, int targetno); @@ -50,12 +49,12 @@ void df_extend_file_vector(SegLogicFile *sf); * We can not use virtual fd because space data files are accessed by multi-thread. * Callers must handle fd < 0 */ -static int dv_open_file(char *filename, int flags, int mode) +static int dv_open_file(char *filename, uint32 flags, int mode) { int fd = -1; fd = BasicOpenFile(filename, flags, mode); int err = errno; - ereport(LOG, (errmsg("dv_open_file filename: %s, flags is %d, mode is %d, fd is %d", filename, flags, mode, fd))); + ereport(LOG, (errmsg("dv_open_file filename: %s, flags is %d, mode is %lu, fd is %d", filename, flags, mode, fd))); errno = err; return fd; } @@ -107,7 +106,7 @@ void df_create_file(SegLogicFile *sf, bool redo) } } else { // File not exists - int flags = O_RDWR | O_CREAT | O_EXCL | PG_BINARY; + uint32 flags = O_RDWR | O_CREAT | O_EXCL | PG_BINARY; if (sf->segfiles != NULL) { ereport(LOG, (errmodule(MOD_SEGMENT_PAGE), @@ -155,7 +154,7 @@ bool df_ss_update_segfile_size(SegLogicFile *sf, BlockNumber target_block) return false; } - int flags = O_RDWR | PG_BINARY; + uint32 flags = O_RDWR | PG_BINARY; /* need palloc segfiles if file_num is 0 */ if (sf->vector_capacity == 0) { df_extend_file_vector(sf); @@ -389,7 +388,7 @@ void df_open_all_file(RepairFileKey key, int32 max_sliceno) { int fd = -1; char *filename = NULL; - int flags = O_RDWR | PG_BINARY; + uint32 flags = O_RDWR | PG_BINARY; Oid relNode = key.relfilenode.relNode; ForkNumber forknum = key.forknum; SegSpace *spc = spc_init_space_node(key.relfilenode.spcNode, key.relfilenode.dbNode); @@ -437,7 +436,7 @@ void df_open_all_file(RepairFileKey key, int32 max_sliceno) static void df_open_target_files(SegLogicFile *sf, int targetno) { int sliceno = sf->file_num; - int flags = O_RDWR | PG_BINARY; + uint32 flags = O_RDWR | PG_BINARY; for (;;) { if (targetno != 0 && targetno < sliceno) { @@ -613,7 +612,7 @@ void df_shrink(SegLogicFile *sf, BlockNumber target) if (unlink(filename) != 0) { /* The fd is closed, if we can not open it, next access to this file will panic */ - int flags = O_RDWR | O_EXCL | PG_BINARY; + uint32 flags = O_RDWR | O_EXCL | PG_BINARY; sf->segfiles[i].fd = dv_open_file(filename, flags, SEGMENT_FILE_MODE); if (sf->segfiles[i].fd < 0) { ereport(PANIC, (errmsg("Unlink file %s failed and unable to read it again.", filename)));