SERVER-46640 The TTLMonitor should not remove the cached index information from the TTLCollectionCache when a collection is not yet visible

1 files changed, 15 insertions, 2 deletions

diff --git a/src/mongo/db/ttl_collection_cache.cpp b/src/mongo/db/ttl_collection_cache.cpp
index d4d9ffe7694..e959c5096c3 100644
--- a/src/mongo/db/ttl_collection_cache.cpp
+++ b/src/mongo/db/ttl_collection_cache.cpp
@@ -27,6 +27,8 @@
  *    it in the license file.
  */
 
+#define MONGO_LOG_DEFAULT_COMPONENT ::mongo::logger::LogComponent::kStorage
+
 #include "mongo/platform/basic.h"
 
 #include "mongo/db/ttl_collection_cache.h"
@@ -34,9 +36,13 @@
 #include <algorithm>
 
 #include "mongo/db/service_context.h"
+#include "mongo/logv2/log.h"
+#include "mongo/util/fail_point.h"
 
 namespace mongo {
 
+MONGO_FAIL_POINT_DEFINE(hangTTLCollectionCacheAfterRegisteringInfo);
+
 namespace {
 const auto getTTLCollectionCache = ServiceContext::declareDecoration<TTLCollectionCache>();
 }
@@ -46,8 +52,15 @@ TTLCollectionCache& TTLCollectionCache::get(ServiceContext* ctx) {
 }
 
 void TTLCollectionCache::registerTTLInfo(std::pair<UUID, std::string>&& ttlInfo) {
-    stdx::lock_guard<Latch> lock(_ttlInfosLock);
-    _ttlInfos.push_back(std::move(ttlInfo));
+    {
+        stdx::lock_guard<Latch> lock(_ttlInfosLock);
+        _ttlInfos.push_back(std::move(ttlInfo));
+    }
+
+    if (MONGO_unlikely(hangTTLCollectionCacheAfterRegisteringInfo.shouldFail())) {
+        LOGV2(4664000, "Hanging due to hangTTLCollectionCacheAfterRegisteringInfo fail point");
+        hangTTLCollectionCacheAfterRegisteringInfo.pauseWhileSet();
+    }
 }
 
 void TTLCollectionCache::deregisterTTLInfo(const std::pair<UUID, std::string>& ttlInfo) {