diff --git a/src/common/backend/utils/misc/guc/guc_storage.cpp b/src/common/backend/utils/misc/guc/guc_storage.cpp index e5bc80c3e..2f3957d44 100755 --- a/src/common/backend/utils/misc/guc/guc_storage.cpp +++ b/src/common/backend/utils/misc/guc/guc_storage.cpp @@ -1020,7 +1020,7 @@ static void InitStorageConfigureNamesBool() NULL}, {{"ss_enable_aio", - PGC_SIGHUP, + PGC_POSTMASTER, NODE_SINGLENODE, SHARED_STORAGE_OPTIONS, gettext_noop("Whether use dss aio"), @@ -1029,7 +1029,7 @@ static void InitStorageConfigureNamesBool() &g_instance.attr.attr_storage.dms_attr.enable_dss_aio, true, NULL, - assign_ss_enable_aio, + NULL, NULL}, #ifdef USE_ASSERT_CHECKING @@ -5878,11 +5878,6 @@ static bool check_ss_enable_ssl(bool *newval, void **extra, GucSource source) return true; } -static void assign_ss_enable_aio(bool newval, void *extra) -{ - g_instance.attr.attr_storage.dms_attr.enable_dss_aio = newval; -} - #ifdef USE_ASSERT_CHECKING static void assign_ss_enable_verify_page(bool newval, void *extra) { diff --git a/src/gausskernel/storage/buffer/bufmgr.cpp b/src/gausskernel/storage/buffer/bufmgr.cpp index d41c78bc8..a607390d1 100644 --- a/src/gausskernel/storage/buffer/bufmgr.cpp +++ b/src/gausskernel/storage/buffer/bufmgr.cpp @@ -4785,7 +4785,7 @@ void FlushBuffer(void *buf, SMgrRelation reln, ReadBufferMethod flushmethod, boo SegFlushCheckDiskLSN(spc, fakenode, bufferinfo.blockinfo.forknum, bufdesc->extra->seg_blockno, bufToWrite); #endif - if (ENABLE_DMS && t_thrd.role == PAGEWRITER_THREAD && ENABLE_DSS_AIO) { + if (ENABLE_DMS && (t_thrd.role == PAGEWRITER_THREAD) && ENABLE_DSS_AIO) { int thread_id = t_thrd.pagewriter_cxt.pagewriter_id; PageWriterProc *pgwr = &g_instance.ckpt_cxt_ctl->pgwr_procs.writer_proc[thread_id]; DSSAioCxt *aio_cxt = &pgwr->aio_cxt;