test/journal: always close object

otherwise when we destruct `TestObjectRecorder::Handler::lock` or
`journal::JournalRecorder::m_object_locks`, it/they would be still
being waited by some condition variable.

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/test/journal/test_ObjectRecorder.cc b/src/test/journal/test_ObjectRecorder.cc
index 2df5bf0faaf2e21550d758e5a7b3f65876665e8f..87efca571a6f12dcbc437eb5abd6d0fe0289b70b 100644 (file)
--- a/src/test/journal/test_ObjectRecorder.cc
+++ b/src/test/journal/test_ObjectRecorder.cc
@@ -66,10 +66,14 @@ public:
                                static_cast<uint64_t>(max_in_flight)}
     {}
     ~ObjectRecorderFlusher() {
-      for (auto& object_recorder : m_object_recorders) {
+      for (auto& [object_recorder, m] : m_object_recorders) {
        C_SaferCond cond;
        object_recorder->flush(&cond);
        cond.wait();
+       std::scoped_lock l{*m};
+       if (!object_recorder->is_closed()) {
+         object_recorder->close();
+       }
       }
     }
     journal::ObjectRecorderPtr create_object(const std::string& oid,
@@ -84,7 +88,7 @@ public:
                                         m_flush_bytes,
                                         m_flush_age);
       }
-      m_object_recorders.push_back(object);
+      m_object_recorders.emplace_back(object, lock);
       m_handler.object_lock = lock;
       return object;
     }
@@ -110,7 +114,8 @@ public:
     uint64_t m_flush_bytes = std::numeric_limits<uint64_t>::max();
     double m_flush_age = 600;
     uint64_t m_max_in_flight_appends = 0;
-    using ObjectRecorders = std::list<journal::ObjectRecorderPtr>;
+    using ObjectRecorders =
+      std::list<std::pair<journal::ObjectRecorderPtr, ceph::mutex*>>;
     ObjectRecorders m_object_recorders;
     Handler m_handler;
   };