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

[BUG.FIX] fix hang in allocate extents of tmp file store

Browse Source
This commit is contained in:
Tyshawn
2023-07-27 06:42:26 +00:00
committed by ob-robot
parent 379a6dabb1
commit e6bf768b97
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/storage/blocksstable/ob_tmp_file_store.cpp
View File

@ -1003,11 +1003,17 @@ int ObTmpTenantFileStore::alloc(const int64_t dir_id, const uint64_t tenant_id,
ret = OB_INVALID_ARGUMENT; ret = OB_INVALID_ARGUMENT;
STORAGE_LOG(WARN, "invalid argument", K(alloc_size), K(block_size)); STORAGE_LOG(WARN, "invalid argument", K(alloc_size), K(block_size));
} else { } else {
const int64_t timeout_ts = THIS_WORKER.get_timeout_ts();
ret = OB_STATE_NOT_MATCH; ret = OB_STATE_NOT_MATCH;
while (OB_STATE_NOT_MATCH == ret || OB_SIZE_OVERFLOW == ret) { while (OB_STATE_NOT_MATCH == ret || OB_SIZE_OVERFLOW == ret) {
if (OB_FAIL(tmp_mem_block_manager_.cleanup())) { if (OB_UNLIKELY(timeout_ts <= ObTimeUtility::current_time())) {
ret = OB_TIMEOUT;
STORAGE_LOG(WARN, "it's timeout", K(ret), K(timeout_ts), K(ObTimeUtility::current_time()));
} else if (OB_FAIL(tmp_mem_block_manager_.cleanup())) {
if (OB_STATE_NOT_MATCH != ret) {
STORAGE_LOG(WARN, "fail to try wash tmp macro block", K(ret), K(dir_id), K(tenant_id)); STORAGE_LOG(WARN, "fail to try wash tmp macro block", K(ret), K(dir_id), K(tenant_id));
} }
}
SpinWLockGuard guard(lock_); SpinWLockGuard guard(lock_);
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {
if (alloc_size > max_cont_size_per_block) { if (alloc_size > max_cont_size_per_block) {