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

fix the problem that stream rpc timeout is cast from int64_t to int32_t

Browse Source
This commit is contained in:
obdev 2023-04-26 14:31:17 +00:00 committed by ob-robot
parent dbedb800a4
commit 18e8703eba
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/oblib/src/rpc/obrpc/ob_rpc_session_handler.cpp vendored
View File

@ -198,7 +198,7 @@ int ObRpcSessionHandler::wait_for_next_request(int64_t sessid,
LOG_WARN("session wait thread id doesn't equal each other",
K(ret), K(sessid), K(thid), K(wait_object.thid_), K(ret));
} else if (NULL == wait_object.req_) {
int32_t timeout_ms = static_cast<int32_t>(timeout / 1000);
int64_t timeout_ms = timeout / 1000;
if (timeout_ms < DEFAULT_WAIT_TIMEOUT_MS) {
timeout_ms = DEFAULT_WAIT_TIMEOUT_MS;
} else {