database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复aio无法关闭的问题

Browse Source
This commit is contained in:
arcoalien@qq.com
2023-03-27 21:00:36 +08:00
parent b5b40d673e
commit 3a4f779906
2 changed files with 3 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/common/backend/utils/misc/guc/guc_storage.cpp
View File

@ -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)
{

2
src/gausskernel/storage/buffer/bufmgr.cpp
View File

@ -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;