diff options
Diffstat (limited to 'src/mongo/db/service_liason_mongos.cpp')
-rw-r--r-- | src/mongo/db/service_liason_mongos.cpp | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/src/mongo/db/service_liason_mongos.cpp b/src/mongo/db/service_liason_mongos.cpp index bf0bb81b70a..37c5420d28d 100644 --- a/src/mongo/db/service_liason_mongos.cpp +++ b/src/mongo/db/service_liason_mongos.cpp @@ -39,7 +39,7 @@ namespace mongo { -LogicalSessionIdSet ServiceLiasonMongos::getActiveSessions() const { +LogicalSessionIdSet ServiceLiasonMongos::getActiveOpSessions() const { LogicalSessionIdSet activeSessions; invariant(hasGlobalServiceContext()); @@ -51,6 +51,12 @@ LogicalSessionIdSet ServiceLiasonMongos::getActiveSessions() const { return activeSessions; } +LogicalSessionIdSet ServiceLiasonMongos::getOpenCursorSessions() const { + LogicalSessionIdSet openCursorSessions; + + return openCursorSessions; +} + void ServiceLiasonMongos::scheduleJob(PeriodicRunner::PeriodicJob job) { invariant(hasGlobalServiceContext()); getGlobalServiceContext()->getPeriodicRunner()->scheduleJob(std::move(job)); @@ -70,4 +76,10 @@ ServiceContext* ServiceLiasonMongos::_context() { return getGlobalServiceContext(); } +Status ServiceLiasonMongos::killCursorsWithMatchingSessions(OperationContext* opCtx, + const SessionKiller::Matcher& matcher) { + auto cursorManager = Grid::get(getGlobalServiceContext())->getCursorManager(); + return cursorManager->killCursorsWithMatchingSessions(opCtx, matcher); +} + } // namespace mongo |