SERVER-29202 Add a refreshLogicalSessionCacheNow test command

1 files changed, 11 insertions, 2 deletions

diff --git a/src/mongo/db/logical_session_cache.cpp b/src/mongo/db/logical_session_cache.cpp
index 7baeb66593d..fb3518ada63 100644
--- a/src/mongo/db/logical_session_cache.cpp
+++ b/src/mongo/db/logical_session_cache.cpp
@@ -226,8 +226,17 @@ void LogicalSessionCache::_refresh(Client* client) {
     // failed to refresh, it means their authoritative records were removed, and
     // we should remove such records from our cache as well.
     {
-        auto opCtx = client->makeOperationContext();
-        auto res = _sessionsColl->refreshSessions(opCtx.get(), std::move(activeSessions), time);
+        boost::optional<ServiceContext::UniqueOperationContext> uniqueCtx;
+        auto* const opCtx = [&client, &uniqueCtx] {
+            if (client->getOperationContext()) {
+                return client->getOperationContext();
+            }
+
+            uniqueCtx.emplace(client->makeOperationContext());
+            return uniqueCtx->get();
+        }();
+
+        auto res = _sessionsColl->refreshSessions(opCtx, std::move(activeSessions), time);
         if (!res.isOK()) {
             // TODO SERVER-29709: handle network errors here.
             return;