add a debug log(FATAL)

vesoft-inc · Apr 8, 2022 · 22003dc · 22003dc
1 parent 78a9edd
commit 22003dc
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/src/kvstore/raftex/RaftPart.cpp b/src/kvstore/raftex/RaftPart.cpp
@@ -84,6 +84,21 @@ class AppendLogsIterator final : public LogIterator {
   AppendLogsIterator& operator=(const AppendLogsIterator&) = delete;
   AppendLogsIterator& operator=(AppendLogsIterator&&) = default;
 
+  ~AppendLogsIterator() {
+    if (!logs_.empty()) {
+      size_t notFulfilledPromise = 0;
+      for (auto& log : logs_) {
+        auto& promiseRef = std::get<4>(log);
+        if (!promiseRef.isFulfilled()) {
+          ++notFulfilledPromise;
+        }
+      }
+      if (notFulfilledPromise > 0) {
+        LOG(FATAL) << "notFulfilledPromise == " << notFulfilledPromise;
+      }
+    }
+  }
+
   void commit(nebula::cpp2::ErrorCode code = nebula::cpp2::ErrorCode::SUCCEEDED) {
     for (auto it = logs_.begin(); it != logs_.end(); ++it) {
       auto& promiseRef = std::get<4>(*it);