Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

sleep a little longer on dev

  • Loading branch information...
commit 7ac57c56e42c0235d20e836025cd35d404a9c759 1 parent a991965
@dwight dwight authored
Showing with 15 additions and 1 deletion.
  1. +4 −1 db/instance.cpp
  2. +9 −0 db/oplogreader.h
  3. +2 −0  db/query.cpp
View
5 db/instance.cpp
@@ -509,7 +509,10 @@ namespace mongo {
exhaust = false;
massert(13073, "shutting down", !inShutdown() );
pass++;
- sleepmillis(2);
+ DEV
+ sleepmillis(20);
+ else
+ sleepmillis(2);
continue;
}
catch ( AssertionException& e ) {
View
9 db/oplogreader.h
@@ -16,10 +16,19 @@ namespace mongo {
auto_ptr<DBClientCursor> cursor;
public:
+ OplogReader() {
+ DEV log() << "TEMP *** OplogReader()" << endl;
+ }
+ ~OplogReader() {
+ DEV log() << "TEMP *** ~OplogReader()" << endl;
+ }
+
void resetCursor() {
+ DEV log() << "TEMP *** OplogReader::resetCursor" << endl;
cursor.reset();
}
void resetConnection() {
+ DEV log() << "TEMP *** OplogReader::resetConnection" << endl;
cursor.reset();
_conn.reset();
}
View
2  db/query.cpp
@@ -271,6 +271,7 @@ namespace mongo {
}
QueryResult* processGetMore(const char *ns, int ntoreturn, long long cursorid , CurOp& curop, int pass, bool& exhaust ) {
+// log() << "TEMP GETMORE " << ns << ' ' << cursorid << ' ' << pass << endl;
exhaust = false;
ClientCursor::Pointer p(cursorid);
ClientCursor *cc = p._c;
@@ -312,6 +313,7 @@ namespace mongo {
while ( 1 ) {
if ( !c->ok() ) {
+// log() << "TEMP Tailable : " << c->tailable() << ' ' << (queryOptions & QueryOption_AwaitData) << endl;
if ( c->tailable() ) {
/* when a tailable cursor hits "EOF", ok() goes false, and current() is null. however
advance() can still be retries as a reactivation attempt. when there is new data, it will
Please sign in to comment.
Something went wrong with that request. Please try again.