diff --git a/src/gausskernel/ddes/adapter/ss_dms_callback.cpp b/src/gausskernel/ddes/adapter/ss_dms_callback.cpp index 8b8d1272f..d04ae88dd 100644 --- a/src/gausskernel/ddes/adapter/ss_dms_callback.cpp +++ b/src/gausskernel/ddes/adapter/ss_dms_callback.cpp @@ -1285,7 +1285,7 @@ static bool SSCheckBufferIfCanGoRebuild(BufferDesc* buf_desc, uint64 buf_state) dms_buf_ctrl_t *buf_ctrl = GetDmsBufCtrl(buf_desc->buf_id); if ((buf_state & BM_VALID) && (buf_ctrl->lock_mode != (unsigned char)DMS_LOCK_NULL)) { ret = true; - } else if ((buf_state & BM_TAG_VALID) && (buf_ctrl->lock_mode != (unsigned char)DMS_LOCK_NULL) && !(buf_ctrl->state | BUF_IS_EXTEND)) { + } else if ((buf_state & BM_TAG_VALID) && (buf_ctrl->lock_mode != (unsigned char)DMS_LOCK_NULL)) { if (LWLockConditionalAcquire(buf_desc->io_in_progress_lock, LW_SHARED)) { ret = true; } else { diff --git a/src/gausskernel/storage/buffer/bufmgr.cpp b/src/gausskernel/storage/buffer/bufmgr.cpp index 991ab1d67..40f5e693d 100644 --- a/src/gausskernel/storage/buffer/bufmgr.cpp +++ b/src/gausskernel/storage/buffer/bufmgr.cpp @@ -2190,14 +2190,6 @@ static bool ReadBuffer_common_ReadBlock(SMgrRelation smgr, char relpersistence, } } - if (ENABLE_DMS) { - Buffer buf = BlockGetBuffer((char *)bufBlock); - dms_buf_ctrl_t *buf_ctrl = GetDmsBufCtrl(buf - 1); - if (buf_ctrl->lock_mode == DMS_LOCK_NULL) { - ereport(PANIC, (errmsg("It seemd read buffer not across DMS!"))); - } - } - return needputtodirty; }