Skip to content

Commit 15153e8

Browse files
authored
Revert "Connect broken traces in consensus for preexecuted transactions (#2616)" (#2645)
This reverts commit 0edb6be.
1 parent aae3400 commit 15153e8

File tree

1 file changed

+8
-9
lines changed

1 file changed

+8
-9
lines changed

bftengine/src/bftengine/ReplicaImp.cpp

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -2097,8 +2097,7 @@ void ReplicaImp::onCommitCombinedSigSucceeded(SeqNum seqNumber,
20972097
(seqNumber > lastExecutedSeqNum + config_.getconcurrencyLevel() + activeExecutions_);
20982098

20992099
auto span = concordUtils::startChildSpanFromContext(
2100-
commitFull->spanContext<std::remove_pointer<decltype(commitFull)>::type>(),
2101-
"bft_handle_commit_combined_sig_succeeded_message");
2100+
commitFull->spanContext<std::remove_pointer<decltype(commitFull)>::type>(), "bft_execute_committed_reqs");
21022101
updateCommitMetrics(CommitPath::SLOW);
21032102
startExecution(seqNumber, span, askForMissingInfoAboutCommittedItems);
21042103
}
@@ -2145,8 +2144,7 @@ void ReplicaImp::onCommitVerifyCombinedSigResult(SeqNum seqNumber, ViewNum view,
21452144
LOG_INFO(CNSUS, "Request committed, proceeding to try to execute" << KVLOG(view));
21462145

21472146
auto span = concordUtils::startChildSpanFromContext(
2148-
commitFull->spanContext<std::remove_pointer<decltype(commitFull)>::type>(),
2149-
"bft_handle_commit_verify_combined_sig_result");
2147+
commitFull->spanContext<std::remove_pointer<decltype(commitFull)>::type>(), "bft_execute_committed_reqs");
21502148
bool askForMissingInfoAboutCommittedItems =
21512149
(seqNumber > lastExecutedSeqNum + config_.getconcurrencyLevel() + activeExecutions_);
21522150
updateCommitMetrics(CommitPath::SLOW);
@@ -2205,7 +2203,7 @@ void ReplicaImp::onFastPathCommitCombinedSigSucceeded(SeqNum seqNumber,
22052203
lastExecutedSeqNum + config_.getconcurrencyLevel() + activeExecutions_); // TODO(GG): check/improve this logic
22062204

22072205
auto span = concordUtils::startChildSpanFromContext(fcp->spanContext<std::remove_pointer<decltype(fcp)>::type>(),
2208-
"bft_handle_fast_path_commit_combined_sig_succeeded");
2206+
"bft_execute_committed_reqs");
22092207

22102208
updateCommitMetrics(cPath);
22112209

@@ -2270,7 +2268,7 @@ void ReplicaImp::onFastPathCommitVerifyCombinedSigResult(SeqNum seqNumber,
22702268
lastExecutedSeqNum + config_.getconcurrencyLevel() + activeExecutions_); // TODO(GG): check/improve this logic
22712269

22722270
auto span = concordUtils::startChildSpanFromContext(fcp->spanContext<std::remove_pointer<decltype(fcp)>::type>(),
2273-
"bft_handle_fast_path_commit_verify_combined_sig_result");
2271+
"bft_execute_committed_reqs");
22742272

22752273
updateCommitMetrics(cPath);
22762274

@@ -4970,14 +4968,14 @@ void ReplicaImp::executeSpecialRequests(PrePrepareMsg *ppMsg,
49704968
reqIdx++;
49714969
}
49724970

4973-
auto span_context = ppMsg->spanContext<std::remove_pointer<decltype(ppMsg)>::type>();
49744971
// TODO(GG): the following code is cumbersome. We can call to execute directly in the above loop
49754972
IRequestsHandler::ExecutionRequestsQueue singleRequest;
49764973
for (IRequestsHandler::ExecutionRequest &req : accumulatedRequests) {
49774974
ConcordAssert(singleRequest.empty());
49784975
singleRequest.push_back(req);
49794976
{
4980-
auto span = concordUtils::startChildSpanFromContext(span_context, "bft_client_special_request");
4977+
const concordUtils::SpanContext &span_context{""};
4978+
auto span = concordUtils::startChildSpanFromContext(span_context, "bft_client_request");
49814979
span.setTag("rid", config_.getreplicaId());
49824980
span.setTag("cid", req.cid);
49834981
span.setTag("seq_num", req.requestSequenceNum);
@@ -5039,12 +5037,12 @@ void ReplicaImp::executeRequests(PrePrepareMsg *ppMsg, Bitmap &requestSet, Times
50395037
setConflictDetectionBlockId(req, pAccumulatedRequests->back());
50405038
}
50415039
}
5042-
auto span_context = ppMsg->spanContext<std::remove_pointer<decltype(ppMsg)>::type>();
50435040
if (ReplicaConfig::instance().blockAccumulation) {
50445041
LOG_DEBUG(GL,
50455042
"Executing all the requests of preprepare message with cid: " << ppMsg->getCid() << " with accumulation");
50465043
{
50475044
// TimeRecorder scoped_timer1(*histograms_.executeWriteRequest);
5045+
const concordUtils::SpanContext &span_context{""};
50485046
auto span = concordUtils::startChildSpanFromContext(span_context, "bft_client_request");
50495047
span.setTag("rid", config_.getreplicaId());
50505048
span.setTag("cid", ppMsg->getCid());
@@ -5067,6 +5065,7 @@ void ReplicaImp::executeRequests(PrePrepareMsg *ppMsg, Bitmap &requestSet, Times
50675065
singleRequest.push_back(req);
50685066
{
50695067
// TimeRecorder scoped_timer1(*histograms_.executeWriteRequest);
5068+
const concordUtils::SpanContext &span_context{""};
50705069
auto span = concordUtils::startChildSpanFromContext(span_context, "bft_client_request");
50715070
span.setTag("rid", config_.getreplicaId());
50725071
span.setTag("cid", ppMsg->getCid());

0 commit comments

Comments
 (0)