mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-11-30 00:56:44 +01:00
Code Issues Releases Activity

Change how smoke.py waits for replication for smallOplog tests.

Browse Source
This commit is contained in:
Richard Kreuter 2010-08-18 10:52:20 -04:00
parent 5663169f5f
commit ff4dd59c5d
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
buildscripts/smoke.py
View File

@ -212,15 +212,9 @@ def checkDbHashes(master, slave):
print "waiting for slave to catch up..."
ARB=10 # ARBITRARY
time.sleep(ARB)
while True:
# FIXME: it's probably better to do an empty insert and a
# getLastError() to force a sync.
argv = [shellExecutable, "--port", str(slave.port), "--quiet", "--eval", 'db.printSlaveReplicationInfo()']
res = Popen(argv, stdout=PIPE).communicate()[0]
m = re.search('(\d+)secs ', res)
if int(m.group(1)) > ARB: #res.find('initial sync') < 0:
break
time.sleep(3)
argv = [shellExecutable, "--port", str(slave.port), "--quiet", "--eval", 'db.getLastError(2, 30000)']
res = Popen(argv, stdout=PIPE).wait() #.communicate()[0]
# FIXME: maybe assert that that res == 0?
# FIXME: maybe make this run dbhash on all databases?
for mongod in [master, slave]: