@@ -251,11 +251,6 @@ void TransactionExecutor::OnlyExecute(std::unique_ptr<Request> request) {
251251 // LOG(INFO) << " get request batch size:"
252252 // << batch_request.user_requests_size()<<" proxy
253253 // id:"<<request->proxy_id();
254- <<<<<<< HEAD
255- =======
256- // std::unique_ptr<BatchUserResponse> batch_response =
257- // std::make_unique<BatchUserResponse>();
258- >>>>>>> master
259254 std::unique_ptr<BatchUserResponse> response;
260255 global_stats_->GetTransactionDetails (batch_request);
261256 if (transaction_manager_) {
@@ -348,11 +343,7 @@ void TransactionExecutor::Execute(std::unique_ptr<Request> request,
348343 // <<request->proxy_id()<<" need execute:"<<need_execute;
349344
350345 std::unique_ptr<BatchUserResponse> response;
351- <<<<<<< HEAD
352- // need_execute = false;
353- =======
354346 global_stats_->GetTransactionDetails (batch_request);
355- >>>>>>> master
356347 if (transaction_manager_ && need_execute) {
357348 if (execute_thread_num_ == 1 ) {
358349 response = transaction_manager_->ExecuteBatch (*batch_request_p);
@@ -398,14 +389,11 @@ void TransactionExecutor::Execute(std::unique_ptr<Request> request,
398389 response->set_local_id (batch_request_p->local_id ());
399390 global_stats_->AddCommitDelay (GetCurrentTime ()- response->createtime ());
400391
401- <<<<<<< HEAD
402392 response->set_seq (request->seq ());
403- =======
404393 response->set_proxy_id (batch_request.proxy_id ());
405394 response->set_createtime (batch_request.createtime ());
406395 response->set_local_id (batch_request.local_id ());
407396 response->set_hash (batch_request.hash ());
408- >>>>>>> master
409397
410398 if (post_exec_func_) {
411399 post_exec_func_ (std::move (request), std::move (response));
0 commit comments