From 67c46e44524cbefcebac275bfd5e62010a544bc8 Mon Sep 17 00:00:00 2001 From: felix-w15 <806547150@qq.com> Date: Wed, 1 Nov 2023 11:13:25 +0000 Subject: [PATCH] [CP] split clog io error into disk full and disk hang --- src/storage/tx/ob_tx_data_functor.cpp | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/src/storage/tx/ob_tx_data_functor.cpp b/src/storage/tx/ob_tx_data_functor.cpp index 29976dde4f..990d8b129e 100644 --- a/src/storage/tx/ob_tx_data_functor.cpp +++ b/src/storage/tx/ob_tx_data_functor.cpp @@ -388,8 +388,16 @@ int LockForReadFunctor::check_clog_disk_full_() MTL(logservice::coordinator::ObFailureDetector *); if (NULL != detector && detector->is_clog_disk_has_fatal_error()) { - ret = detector->is_clog_disk_has_full_error()? OB_SERVER_OUTOF_DISK_SPACE: OB_CLOG_DISK_HANG; - TRANS_LOG(ERROR, "unexpected io error", K(ret), KPC(this)); + if (detector->is_clog_disk_has_full_error()) { + ret = OB_SERVER_OUTOF_DISK_SPACE; + TRANS_LOG(ERROR, "disk full error", K(ret), KPC(this)); + } else if (detector->is_clog_disk_has_hang_error()) { + ret = OB_CLOG_DISK_HANG; + TRANS_LOG(ERROR, "disk hang error", K(ret), KPC(this)); + } else { + ret = OB_IO_ERROR; + TRANS_LOG(ERROR, "unexpected io error", K(ret), KPC(this)); + } } return ret;