Skip to content

Commit 70ea664

Browse files
committed
merge master
1 parent 5f27180 commit 70ea664

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

platform/consensus/execution/transaction_executor.cpp

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -244,6 +244,7 @@ void TransactionExecutor::OnlyExecute(std::unique_ptr<Request> request) {
244244
// << batch_request.user_requests_size()<<" proxy
245245
// id:"<<request->proxy_id();
246246
std::unique_ptr<BatchUserResponse> response;
247+
global_stats_->GetTransactionDetails(batch_request);
247248
if (transaction_manager_) {
248249
response = transaction_manager_->ExecuteBatch(batch_request);
249250
}
@@ -289,6 +290,7 @@ void TransactionExecutor::Execute(std::unique_ptr<Request> request,
289290
// <<request->proxy_id()<<" need execute:"<<need_execute;
290291

291292
std::unique_ptr<BatchUserResponse> response;
293+
global_stats_->GetTransactionDetails(*batch_request_p);
292294
if (transaction_manager_ && need_execute) {
293295
if (execute_thread_num_ == 1) {
294296
response = transaction_manager_->ExecuteBatch(*batch_request_p);
@@ -325,6 +327,10 @@ void TransactionExecutor::Execute(std::unique_ptr<Request> request,
325327
}
326328
// LOG(ERROR)<<" CF = :"<<(cf==1)<<" uid:"<<uid;
327329

330+
if (duplicate_manager_) {
331+
duplicate_manager_->AddExecuted(batch_request.hash(), batch_request.seq());
332+
}
333+
328334
if (response == nullptr) {
329335
response = std::make_unique<BatchUserResponse>();
330336
}

0 commit comments

Comments
 (0)