diff options
Diffstat (limited to 'cpp/test/IceStorm/federation2/run.py')
-rwxr-xr-x | cpp/test/IceStorm/federation2/run.py | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/cpp/test/IceStorm/federation2/run.py b/cpp/test/IceStorm/federation2/run.py index 3b23c919088..0f239ca7f28 100755 --- a/cpp/test/IceStorm/federation2/run.py +++ b/cpp/test/IceStorm/federation2/run.py @@ -64,7 +64,7 @@ def doTest(batch): print "starting " + name + "...", command = subscriber + batchOptions + TestUtil.clientServerOptions + iceStormReference + r' ' + subscriberLockFile + " 2>&1" - subscriberPipe = os.popen(command) + subscriberPipe = os.popen(command, "r", 0) TestUtil.getServerPid(subscriberPipe) TestUtil.getAdapterReady(subscriberPipe) print "ok" @@ -86,7 +86,7 @@ def doTest(batch): # print "starting publisher...", command = publisher + TestUtil.clientOptions + iceStormReference + " 2>&1" - publisherPipe = os.popen(command) + publisherPipe = os.popen(command, "r", 0) print "ok" TestUtil.printOutputFromPipe(publisherPipe) @@ -116,14 +116,14 @@ iceStormDBEnv=" --Freeze.DbEnv.IceStorm.DbHome=" + dbHome print "starting icestorm service...", command = iceBox + TestUtil.clientServerOptions + iceBoxEndpoints + iceStormService + iceStormDBEnv + " 2>&1" -iceBoxPipe = os.popen(command) +iceBoxPipe = os.popen(command, "r", 0) TestUtil.getServerPid(iceBoxPipe) TestUtil.waitServiceReady(iceBoxPipe, "IceStorm") print "ok" print "creating topics...", command = iceStormAdmin + TestUtil.clientOptions + iceStormReference + r' -e "create fed1 fed2 fed3"' + " 2>&1" -iceStormAdminPipe = os.popen(command) +iceStormAdminPipe = os.popen(command, "r", 0) iceStormAdminStatus = iceStormAdminPipe.close() if iceStormAdminStatus: TestUtil.killServers() @@ -133,7 +133,7 @@ print "ok" print "linking topics...", graph = os.path.join(testdir, "fed.xml"); command = iceStormAdmin + TestUtil.clientOptions + iceStormReference + r' -e "graph ' + graph + r' 10"' + " 2>&1" -iceStormAdminPipe = os.popen(command) +iceStormAdminPipe = os.popen(command, "r", 0) # # The graph command generates output. We must read it otherwise # closing the pipe might return a non-zero status. @@ -161,7 +161,7 @@ batchStatus = doTest(1) # print "destroying topics...", command = iceStormAdmin + TestUtil.clientOptions + iceStormReference + r' -e "destroy fed1 fed2 fed3"' + " 2>&1" -iceStormAdminPipe = os.popen(command) +iceStormAdminPipe = os.popen(command, "r", 0) iceStormAdminStatus = iceStormAdminPipe.close() if iceStormAdminStatus: TestUtil.killServers() @@ -173,7 +173,7 @@ print "ok" # print "shutting down icestorm service...", command = iceBoxAdmin + TestUtil.clientOptions + iceBoxEndpoints + r' shutdown' + " 2>&1" -iceBoxAdminPipe = os.popen(command) +iceBoxAdminPipe = os.popen(command, "r", 0) iceBoxAdminStatus = iceBoxAdminPipe.close() if iceBoxAdminStatus: TestUtil.killServers() |