From f0b05ed93c88d55b9e47d346e6c7b0d150ec2fae Mon Sep 17 00:00:00 2001 From: Handora Date: Fri, 24 Feb 2023 15:49:17 +0000 Subject: [PATCH] [4.0] add trace info --- src/storage/tx/ob_tx_2pc_msg_handler.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/storage/tx/ob_tx_2pc_msg_handler.cpp b/src/storage/tx/ob_tx_2pc_msg_handler.cpp index 4111fb34ec..2a4e8deb51 100644 --- a/src/storage/tx/ob_tx_2pc_msg_handler.cpp +++ b/src/storage/tx/ob_tx_2pc_msg_handler.cpp @@ -31,7 +31,7 @@ int ObPartTransCtx::post_msg_(const ObTwoPhaseCommitMsgType& msg_type, build_tx_common_msg_(receiver, prepare_redo_req); prepare_redo_req.upstream_ = ls_id_; 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))) { 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; build_tx_common_msg_(receiver, prepare_req); 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))) { 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; if (OB_FAIL(set_2pc_request_id_(msg.request_id_))) { 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))) { TRANS_LOG(WARN, "handle 2pc request failed", KR(ret), K(msg), K(*this)); }