summaryrefslogtreecommitdiff
path: root/src/mongo/db/service_liason_mongos.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/service_liason_mongos.cpp')
-rw-r--r--src/mongo/db/service_liason_mongos.cpp14
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