SERVER-8188: make cursor timeout configurable on server

mongodb · Mar 13, 2015 · 4d7b131 · 4d7b131
1 parent ae97946
commit 4d7b131
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 2 deletions.
diff --git a/src/mongo/bson/bsonelement.cpp b/src/mongo/bson/bsonelement.cpp
@@ -746,6 +746,13 @@ namespace mongo {
         return true;
     }
 
+    template<> bool BSONElement::coerce<long long>( long long* out ) const {
+        if ( !isNumber() )
+            return false;
+        *out = numberLong();
+        return true;
+    }
+
     template<> bool BSONElement::coerce<double>( double* out ) const {
         if ( !isNumber() )
             return false;

diff --git a/src/mongo/db/clientcursor.cpp b/src/mongo/db/clientcursor.cpp
@@ -48,6 +48,7 @@
 #include "mongo/db/jsobj.h"
 #include "mongo/db/operation_context_impl.h"
 #include "mongo/db/repl/replication_coordinator_global.h"
+#include "mongo/db/server_parameters.h"
 #include "mongo/util/exit.h"
 
 namespace mongo {
@@ -69,6 +70,8 @@ namespace mongo {
     static ServerStatusMetricField<Counter64> dCursorStatusTimedout( "cursor.timedOut",
                                                                      &cursorStatsTimedOut );
 
+    MONGO_EXPORT_SERVER_PARAMETER(cursorTimeoutMillis, int, 10 * 60 * 1000 /* 10 minutes */);
+
     long long ClientCursor::totalOpen() {
         return cursorStatsOpen.get();
     }
@@ -171,7 +174,7 @@ namespace mongo {
         if (_isNoTimeout || _isPinned) {
             return false;
         }
-        return _idleAgeMillis > 600000;
+        return _idleAgeMillis > cursorTimeoutMillis;
     }
 
     void ClientCursor::setIdleTime( int millis ) {

diff --git a/src/mongo/s/cursors.cpp b/src/mongo/s/cursors.cpp
@@ -47,6 +47,7 @@
 #include "mongo/db/commands.h"
 #include "mongo/db/jsobj.h"
 #include "mongo/db/max_time.h"
+#include "mongo/db/server_parameters.h"
 #include "mongo/util/concurrency/task.h"
 #include "mongo/util/log.h"
 #include "mongo/util/net/listen.h"
@@ -218,7 +219,11 @@ namespace mongo {
 
     // ---- CursorCache -----
 
-    long long CursorCache::TIMEOUT = 600000;
+    long long CursorCache::TIMEOUT = 10 * 60 * 1000 /* 10 minutes */;
+    ExportedServerParameter<long long> cursorCacheTimeoutConfig(ServerParameterSet::getGlobal(),
+                                                                "cursorTimeoutMillis",
+                                                                &CursorCache::TIMEOUT,
+                                                                true, true);
 
     unsigned getCCRandomSeed() {
         scoped_ptr<SecureRandom> sr( SecureRandom::create() );