hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Remove unstable case

Browse Source
This commit is contained in:
tino247
2023-12-08 04:42:52 +00:00
committed by ob-robot
parent adc5c71a50
commit 7ff8be91fa
2 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/logservice/ob_server_log_block_mgr.cpp
View File

@ -1126,9 +1126,11 @@ int ObServerLogBlockMgr::allocate_block_at_tmp_dir_(const FileDesc &dir_fd,
CLOG_LOG(ERROR, "::fallocate failed", K(ret), KPC(this), K(dir_fd), K(block_id), CLOG_LOG(ERROR, "::fallocate failed", K(ret), KPC(this), K(dir_fd), K(block_id),
K(errno)); K(errno));
} else { } else {
if (REACH_TIME_INTERVAL(PRINT_INTERVAL)) {
CLOG_LOG(INFO, "allocate_block_at_ success", K(ret), KPC(this), K(dir_fd), CLOG_LOG(INFO, "allocate_block_at_ success", K(ret), KPC(this), K(dir_fd),
K(block_id)); K(block_id));
} }
}
if (-1 != fd && -1 == ::close(fd)) { if (-1 != fd && -1 == ::close(fd)) {
int tmp_ret = convert_sys_errno(); int tmp_ret = convert_sys_errno();
CLOG_LOG(ERROR, "::close failed", K(ret), K(tmp_ret), KPC(this), K(dir_fd), K(block_path)); CLOG_LOG(ERROR, "::close failed", K(ret), K(tmp_ret), KPC(this), K(dir_fd), K(block_path));
@ -1169,9 +1171,11 @@ int ObServerLogBlockMgr::free_block_at_(const FileDesc &src_dir_fd,
CLOG_LOG(ERROR, "unlinkat_until_success_i failed", K(ret), KPC(this), K(src_dir_fd), CLOG_LOG(ERROR, "unlinkat_until_success_i failed", K(ret), KPC(this), K(src_dir_fd),
K(src_block_id)); K(src_block_id));
} else { } else {
if (REACH_TIME_INTERVAL(PRINT_INTERVAL)) {
CLOG_LOG(INFO, "free_block_at_ success", K(ret), KPC(this), K(src_dir_fd), CLOG_LOG(INFO, "free_block_at_ success", K(ret), KPC(this), K(src_dir_fd),
K(src_block_id)); K(src_block_id));
} }
}
return ret; return ret;
} }

1
src/logservice/ob_server_log_block_mgr.h
View File

@ -51,6 +51,7 @@ private:
S_IRUSR | S_IWUSR | S_IXUSR | S_IRGRP | S_IROTH; S_IRUSR | S_IWUSR | S_IXUSR | S_IRGRP | S_IROTH;
static const int CREATE_FILE_MODE = S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH; static const int CREATE_FILE_MODE = S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH;
static const int64_t RUN_INTERVAL = 1 * 1000 * 1000; static const int64_t RUN_INTERVAL = 1 * 1000 * 1000;
static const int64_t PRINT_INTERVAL = 3 * 1000 * 1000;
private: private:
typedef common::RWLock RWLock; typedef common::RWLock RWLock;