From 3a4f779906dfd55bd568afe23d501ceb7d7280c1 Mon Sep 17 00:00:00 2001 From: "arcoalien@qq.com" Date: Mon, 27 Mar 2023 21:00:36 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Daio=E6=97=A0=E6=B3=95?= =?UTF-8?q?=E5=85=B3=E9=97=AD=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/common/backend/utils/misc/guc/guc_storage.cpp | 9 ++------- src/gausskernel/storage/buffer/bufmgr.cpp | 2 +- 2 files changed, 3 insertions(+), 8 deletions(-) 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;