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

[4.0] add trace info

Browse Source
This commit is contained in:
Handora
2023-02-24 15:49:17 +00:00
committed by ob-robot
parent 52c45c7403
commit f0b05ed93c
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/storage/tx/ob_tx_2pc_msg_handler.cpp
View File

@ -31,7 +31,7 @@ int ObPartTransCtx::post_msg_(const ObTwoPhaseCommitMsgType& msg_type,
build_tx_common_msg_(receiver, prepare_redo_req); build_tx_common_msg_(receiver, prepare_redo_req);
prepare_redo_req.upstream_ = ls_id_; prepare_redo_req.upstream_ = ls_id_;
prepare_redo_req.xid_ = exec_info_.xid_; prepare_redo_req.xid_ = exec_info_.xid_;
// TODO(handora.qc): add app_trace_info prepare_redo_req.app_trace_info_ = trace_info_.get_app_trace_info();
if (OB_FAIL(post_msg_(receiver, prepare_redo_req))) { if (OB_FAIL(post_msg_(receiver, prepare_redo_req))) {
TRANS_LOG(WARN, "rpc post msg failed", K(ret), K(*this), K(receiver), K(msg_type)); TRANS_LOG(WARN, "rpc post msg failed", K(ret), K(*this), K(receiver), K(msg_type));
} }
@ -58,7 +58,7 @@ int ObPartTransCtx::post_msg_(const ObTwoPhaseCommitMsgType& msg_type,
Ob2pcPrepareReqMsg prepare_req; Ob2pcPrepareReqMsg prepare_req;
build_tx_common_msg_(receiver, prepare_req); build_tx_common_msg_(receiver, prepare_req);
prepare_req.upstream_ = ls_id_; prepare_req.upstream_ = ls_id_;
// TODO(handora.qc): add app_trace_info prepare_req.app_trace_info_ = trace_info_.get_app_trace_info();
if (OB_FAIL(post_msg_(receiver, prepare_req))) { if (OB_FAIL(post_msg_(receiver, prepare_req))) {
TRANS_LOG(WARN, "rpc post msg failed", K(ret), K(*this), K(receiver), K(msg_type)); TRANS_LOG(WARN, "rpc post msg failed", K(ret), K(*this), K(receiver), K(msg_type));
} }
@ -609,6 +609,8 @@ int ObPartTransCtx::handle_tx_2pc_prepare_req(const Ob2pcPrepareReqMsg &msg)
msg_2pc_cache_ = &msg; msg_2pc_cache_ = &msg;
if (OB_FAIL(set_2pc_request_id_(msg.request_id_))) { if (OB_FAIL(set_2pc_request_id_(msg.request_id_))) {
TRANS_LOG(WARN, "set request id failed", KR(ret), K(msg), K(*this)); TRANS_LOG(WARN, "set request id failed", KR(ret), K(msg), K(*this));
} else if (OB_FAIL(set_app_trace_info_(msg.app_trace_info_))) {
TRANS_LOG(WARN, "set app trace info failed", KR(ret), K(msg), K(*this));
} else if (OB_FAIL(handle_2pc_req(msg_type))) { } else if (OB_FAIL(handle_2pc_req(msg_type))) {
TRANS_LOG(WARN, "handle 2pc request failed", KR(ret), K(msg), K(*this)); TRANS_LOG(WARN, "handle 2pc request failed", KR(ret), K(msg), K(*this));
} }