mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 09:32:32 +01:00
Code Issues Releases Activity

Revert "Revert "replace shelling out w/ pymongo calls in smoke.py""

Browse Source 
This reverts commit 465566855d.
This commit is contained in:
Mike Dirolf 2010-09-01 16:35:51 -04:00
parent 465566855d
commit 0920dbf991
1 changed files with 11 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
buildscripts/smoke.py
View File

@ -49,6 +49,8 @@ from subprocess import (Popen,
import sys
import time
from pymongo import Connection
import utils
# TODO clean this up so we don't need globals...
@ -159,11 +161,12 @@ class mongod(object):
raise Exception("Failed to start mongod")
if self.slave:
while True:
argv = [shell_executable, "--port", str(self.port), "--quiet", "--eval", 'db.printSlaveReplicationInfo()']
res = Popen(argv, stdout=PIPE).communicate()[0]
if res.find('initial sync') < 0:
break
local = Connection(port=self.port).local
synced = False
while not synced:
synced = True
for source in local.sources.find(fields=["syncedTo"]):
synced = synced and "syncedTo" in source and source["syncedTo"]
def stop(self):
if not self.proc:
@ -211,17 +214,12 @@ def check_db_hashes(master, slave):
if not slave.slave:
raise(Bug("slave instance doesn't have slave attribute set"))
print "waiting for slave to catch up..."
argv = [shell_executable, "--port", str(master.port), "--quiet", "--eval", 'db.smokeWait.insert( {} ); printjson( db.getLastErrorCmd(2, 120000) );']
res = Popen(argv, stdout=PIPE).communicate()
print "wait result: " + str( res[0] ) + "\t" + str( res[1] )
print "waiting for slave to catch up, result:"
print Connection(port=master.port).test.smokeWait.insert({}, w=2, wtimeout=120000)
# FIXME: maybe make this run dbhash on all databases?
for mongod in [master, slave]:
argv = [shell_executable, "--port", str(mongod.port), "--quiet", "--eval", "x=db.runCommand('dbhash'); printjson(x.collections)"]
hashstr = Popen(argv, stdout=PIPE).communicate()[0]
# WARNING FIXME KLUDGE et al.: this is sleazy and unsafe.
mongod.dict = eval(hashstr)
mongod.dict = Connection(port=mongod.port).test.command("dbhash")["collections"]
global lost_in_slave, lost_in_master, screwy_in_slave, replicated_dbs