summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordwight <dwight@10gen.com>2010-07-30 11:57:30 -0400
committerdwight <dwight@10gen.com>2010-07-30 11:57:30 -0400
commit27c027913fd5dfc56818067ae6558c342a15f55f (patch)
treea76f5ee555baff1161102e904e670e51dc08cd26
parentf3fbd835d92f5bff7bf5df0294192bd98c473797 (diff)
downloadmongo-27c027913fd5dfc56818067ae6558c342a15f55f.tar.gz
rs minor
-rw-r--r--db/repl/rs.h3
-rw-r--r--db/repl/rs_sync.cpp6
2 files changed, 6 insertions, 3 deletions
diff --git a/db/repl/rs.h b/db/repl/rs.h
index ca77759b829..d9c0b80f710 100644
--- a/db/repl/rs.h
+++ b/db/repl/rs.h
@@ -268,7 +268,8 @@ namespace mongo {
_hbmsg[sz] = 0;
memcpy(_hbmsg, s.c_str(), sz);
}
- log(logLevel) << "replSet " << s << rsLog;
+ if( !s.empty() )
+ log(logLevel) << "replSet " << s << rsLog;
}
protected:
bool initFromConfig(ReplSetConfig& c); // true if ok; throws if config really bad; false if config doesn't include self
diff --git a/db/repl/rs_sync.cpp b/db/repl/rs_sync.cpp
index 2764a165e1a..672ac38a721 100644
--- a/db/repl/rs_sync.cpp
+++ b/db/repl/rs_sync.cpp
@@ -166,8 +166,10 @@ namespace mongo {
void ReplSetImpl::_syncThread() {
StateBox::SP sp = box.get();
- if( sp.state.primary() )
+ if( sp.state.primary() ) {
+ sleepsecs(1);
return;
+ }
/* later, we can sync from up secondaries if we want. tbd. */
if( sp.primary == 0 )
@@ -199,7 +201,7 @@ namespace mongo {
// TODO : SET NOT SECONDARY here.
sleepsecs(60);
}
- sleepsecs(2);
+ sleepsecs(1);
}
}