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

Fix ObKVGlobalCache::put

Browse Source
This commit is contained in:
obdev 2024-12-17 07:45:02 +00:00 committed by ob-robot
parent 1efaa1d7b8
commit 566a745c7a
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/share/cache/ob_kv_storecache.cpp vendored
View File

@ -358,8 +358,18 @@ int ObKVGlobalCache::put(
} else if (NULL == inst_handle.get_inst()) {
ret = OB_ERR_UNEXPECTED;
COMMON_LOG(WARN, "The inst is NULL, ", K(ret));
} else if (!overwrite && (OB_SUCC(map_.get(cache_id, key, pvalue, mb_handle)))) {
ret = OB_ENTRY_EXIST;
} else if (!overwrite) {
if (OB_FAIL(map_.get(cache_id, key, pvalue, mb_handle))) {
if (OB_ENTRY_NOT_EXIST != ret) {
COMMON_LOG(WARN, "KVCacheMap::get failed", K(ret));
} else {
ret = OB_SUCCESS;
}
} else {
ret = OB_ENTRY_EXIST;
}
}
if (OB_FAIL(ret)) {
} else if (OB_FAIL(store.store(*inst_handle.get_inst(), key, value, kvpair, mb_wrapper))) {
COMMON_LOG(WARN, "Fail to store kvpair to store, ", K(ret));
} else {