diff --git a/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.cpp b/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.cpp index cd08a89f4..592d4e71d 100644 --- a/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.cpp +++ b/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.cpp @@ -841,7 +841,7 @@ bool CheckpointManager::CreateTpcRecoveryFile() break; } - if (tpcFileHeader.m_numEntries > 0 && SerializeInProcessTxns(fd) == false) { + if (tpcFileHeader.m_numEntries > 0 && SerializeInProcessTxns(fd) != RC_OK) { MOT_LOG_ERROR("create2PCRecoveryFile: failed to serialize transactions [%d %s]", errno, gs_strerror(errno)); break; } @@ -861,11 +861,11 @@ bool CheckpointManager::CreateTpcRecoveryFile() return ret; } -bool CheckpointManager::SerializeInProcessTxns(int fd) +RC CheckpointManager::SerializeInProcessTxns(int fd) { if (fd == -1) { MOT_LOG_ERROR("SerializeInProcessTxns: bad fd"); - return false; + return RC_ERROR; } auto serializeLambda = [this, fd](RedoLogTransactionSegments* segments, uint64_t) -> RC { diff --git a/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.h b/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.h index ac5f15d39..c2855f7e7 100644 --- a/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.h +++ b/src/gausskernel/storage/mot/core/src/system/checkpoint/checkpoint_manager.h @@ -387,9 +387,9 @@ private: /** * @brief Serializes inProcess transactions to disk - * @return Boolean value denoting success or failure. + * @return RC value denoting the status of the operation. */ - bool SerializeInProcessTxns(int fd); + RC SerializeInProcessTxns(int fd); void ResetFlags();