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

fix the error of high_prio_rpc_shutdown when observer stop

Browse Source
This commit is contained in:
obdev
2023-02-13 04:14:44 +00:00
committed by ob-robot
parent a5e5719fa7
commit ce71f6c3d9
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
deps/oblib/src/rpc/frame/ob_net_easy.cpp vendored
View File

@ -921,9 +921,11 @@ int ObNetEasy::rpc_shutdown()
int ObNetEasy::high_prio_rpc_shutdown() int ObNetEasy::high_prio_rpc_shutdown()
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
if (!started_ || !is_inited_ || OB_ISNULL(high_prio_rpc_eio_)) { if (!started_ || !is_inited_) {
ret = OB_ERR_UNEXPECTED; ret = OB_ERR_UNEXPECTED;
LOG_WARN("easy net hasn't started", K(ret)); LOG_WARN("easy net hasn't started", K(ret));
} else if (OB_ISNULL(high_prio_rpc_eio_)) {
LOG_INFO("user does not start high priority net threads");
} else { } else {
int eret = easy_eio_shutdown(high_prio_rpc_eio_); int eret = easy_eio_shutdown(high_prio_rpc_eio_);
if (eret != EASY_OK) { if (eret != EASY_OK) {