MAINT: Move call of ProcessTerminated to DoExecute...

include/caosdb/logging.h

@@ -64,10 +64,12 @@ class TraceEnterLeaveLogger {
 public:
   inline TraceEnterLeaveLogger(const std::string &channel, const std::string &function_name)
     : channel(channel), function_name(function_name) {
-    caosdb::logging::LoggerOutputStream::get(this->channel, CAOSDB_LOG_LEVEL_TRACE) << "Enter " << this->function_name;
+    caosdb::logging::LoggerOutputStream::get(this->channel, CAOSDB_LOG_LEVEL_TRACE)
+      << "Enter " << this->function_name;
   }
   inline ~TraceEnterLeaveLogger() {
-    caosdb::logging::LoggerOutputStream::get(this->channel, CAOSDB_LOG_LEVEL_TRACE) << "Leave " << this->function_name;
+    caosdb::logging::LoggerOutputStream::get(this->channel, CAOSDB_LOG_LEVEL_TRACE)
+      << "Leave " << this->function_name;
   }
 
 private:

src/caosdb/logging.cpp

@@ -40,7 +40,6 @@
 #include <boost/smart_ptr/shared_ptr.hpp>
 #include <cstdint> // for uint64_t
 #include <memory>
-#include <ostream> // for ostream
 #include <sstream>
 #include <string>
 #include <utility> // for move

src/caosdb/transaction.cpp

@@ -35,10 +35,8 @@
 #include <filesystem>                             // for operator<<, path
 #include <future>                                 // for async, future
 #include <google/protobuf/arena.h>                // for Arena
-#include <google/protobuf/generated_message_util.h> // for CreateMessage...
 #include <grpc/impl/codegen/gpr_types.h>          // for gpr_timespec
 #include <grpcpp/impl/codegen/completion_queue.h> // for CompletionQueue
-#include <iosfwd>                                   // for streamsize
 #include <map>                                    // for map, operator!=
 #include <memory>                                 // for unique_ptr
 #include <random>                                 // for mt19937, rand...
@@ -291,6 +289,9 @@ auto Transaction::DoExecuteTransaction() noexcept -> StatusCode {
       }
     }
   }
+  if (this->status.GetCode() == StatusCode::EXECUTING) {
+    return ProcessTerminated().GetCode();
+  }
   return this->status.GetCode();
 }
 
@@ -353,6 +354,7 @@ auto Transaction::ProcessRetrieveResponse(RetrieveResponse *retrieve_response,
 }
 
 auto Transaction::ProcessTerminated() const noexcept -> TransactionStatus {
+  CAOSDB_LOG_TRACE_ENTER_AND_LEAVE(logger_name, "Transaction::ProcessTerminated()")
   bool set_error = false;
   auto *responses = this->response->mutable_responses();
   std::vector<std::unique_ptr<Entity>> entities;
@@ -418,13 +420,9 @@ auto Transaction::WaitForIt() const noexcept -> TransactionStatus {
 
   this->transaction_future.wait();
 
-  if (this->status.GetCode() != StatusCode::EXECUTING) {
   return this->status;
 }
 
-  return ProcessTerminated();
-}
-
 // NOLINTNEXTLINE
 auto Transaction::ProcessCalls() -> TransactionStatus {
   CAOSDB_LOG_TRACE_ENTER_AND_LEAVE(logger_name, "Transaction::ProcessCalls()")