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

fix mysqltest

Browse Source
This commit is contained in:
18523270951@163.com 2025-01-02 10:15:22 +00:00 committed by ob-robot
parent 9496d4c6fb
commit 926b77d761
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/sql/dtl/ob_dtl_rpc_channel.cpp
View File

@ -334,9 +334,9 @@ int ObDtlRpcChannel::send_message(ObDtlLinkedBuffer *&buf)
LOG_WARN("set start fail failed", K(tmp_ret));
}
} else if (!send_by_tenant()
&& DTL.get_rpc_proxy().to(peer_).timeout(timeout_us)
&& OB_FAIL(DTL.get_rpc_proxy().to(peer_).timeout(timeout_us)
.compressed(compressor_type_)
.ap_send_message(ObDtlSendArgs{peer_id_, *buf}, &cb)) {
.ap_send_message(ObDtlSendArgs{peer_id_, *buf}, &cb))) {
LOG_WARN("send message failed", K_(peer), K(ret));
int tmp_ret = msg_response_.on_start_fail();
if (OB_SUCCESS != tmp_ret) {