summaryrefslogtreecommitdiff
path: root/cpp/demo/IceStorm/replicated2/expect.py
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2015-03-18 12:58:16 -0230
committerMatthew Newhook <matthew@zeroc.com>2015-03-18 12:58:16 -0230
commit9b7668c7c92cf9cb311fe444cdddb489cd2a219d (patch)
tree5016567c58c81f5654e9d01935e199c6bf4761d2 /cpp/demo/IceStorm/replicated2/expect.py
parentVS add-in & build updates: (diff)
downloadice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.tar.bz2
ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.tar.xz
ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.zip
Removed demos.
Moved demoscript to distribution.
Diffstat (limited to 'cpp/demo/IceStorm/replicated2/expect.py')
-rwxr-xr-xcpp/demo/IceStorm/replicated2/expect.py98
1 files changed, 0 insertions, 98 deletions
diff --git a/cpp/demo/IceStorm/replicated2/expect.py b/cpp/demo/IceStorm/replicated2/expect.py
deleted file mode 100755
index e885194745a..00000000000
--- a/cpp/demo/IceStorm/replicated2/expect.py
+++ /dev/null
@@ -1,98 +0,0 @@
-#!/usr/bin/env python
-# **********************************************************************
-#
-# Copyright (c) 2003-2015 ZeroC, Inc. All rights reserved.
-#
-# This copy of Ice is licensed to you under the terms described in the
-# ICE_LICENSE file included in this distribution.
-#
-# **********************************************************************
-
-import sys, os
-
-path = [ ".", "..", "../..", "../../..", "../../../.." ]
-head = os.path.dirname(sys.argv[0])
-if len(head) > 0:
- path = [os.path.join(head, p) for p in path]
-path = [os.path.abspath(p) for p in path if os.path.exists(os.path.join(p, "demoscript")) ]
-if len(path) == 0:
- raise RuntimeError("can't find toplevel directory!")
-sys.path.append(path[0])
-
-from demoscript import Util
-import time, signal
-
-sys.stdout.write("cleaning databases... ")
-sys.stdout.flush()
-Util.cleanDbDir("db1");
-Util.cleanDbDir("db2")
-Util.cleanDbDir("db3")
-print("ok")
-
-if Util.defaultHost:
- a1 = ' --IceBox.Service.IceStorm="IceStormService,36:createIceStorm --Ice.Config=config.s1 %s"' \
- % Util.defaultHost
- a2 = ' --IceBox.Service.IceStorm="IceStormService,36:createIceStorm --Ice.Config=config.s2 %s"' \
- % Util.defaultHost
- a3 = ' --IceBox.Service.IceStorm="IceStormService,36:createIceStorm --Ice.Config=config.s3 %s"' \
- % Util.defaultHost
-else:
- a1 = ''
- a2 = ''
- a3 = ''
-
-sys.stdout.write("starting replicas... ")
-sys.stdout.flush()
-ib1 = Util.spawn('%s --Ice.Config=config.ib1 --Ice.PrintAdapterReady %s' % (Util.getIceBox(), a1))
-ib1.expect('.* ready')
-ib2 = Util.spawn('%s --Ice.Config=config.ib2 --Ice.PrintAdapterReady %s' % (Util.getIceBox(), a2))
-ib2.expect('.* ready')
-ib3 = Util.spawn('%s --Ice.Config=config.ib3 --Ice.PrintAdapterReady %s' % (Util.getIceBox(), a3))
-ib3.expect('.* ready')
-print("ok")
-
-ib3.expect('Election: node 2: reporting for duty in group 2:[-0-9A-Fa-f]+ as coordinator' , timeout=20)
-ib2.expect('Election: node 1: reporting for duty in group 2:[-0-9A-Fa-f]+ with coordinator 2', timeout=20)
-ib1.expect('Election: node 0: reporting for duty in group 2:[-0-9A-Fa-f]+ with coordinator 2', timeout=20)
-
-sys.stdout.write("testing pub/sub... ")
-sys.stdout.flush()
-sub = Util.spawn('./subscriber --Ice.PrintAdapterReady')
-
-ib1.expect('Topic: time: add replica observer: [-0-9A-Fa-f]+')
-ib2.expect('Topic: time: add replica observer: [-0-9A-Fa-f]+' )
-ib3.expect('Topic: time: subscribeAndGetPublisher: [-0-9A-Fa-f]+')
-
-sub.expect('.* ready')
-
-pub = Util.spawn('./publisher')
-
-time.sleep(3)
-sub.expect('[0-9][0-9]/[0-9][0-9].*\n[0-9][0-9]/[0-9][0-9]')
-print("ok")
-
-sys.stdout.write("shutting down... ")
-sys.stdout.flush()
-sub.kill(signal.SIGINT)
-sub.waitTestSuccess()
-pub.kill(signal.SIGINT)
-pub.waitTestSuccess()
-
-ib1.expect('Topic: time: remove replica observer: [-0-9A-Fa-f]+')
-ib2.expect('Topic: time: remove replica observer: [-0-9A-Fa-f]+')
-ib3.expect('Topic: time: unsubscribe: [-0-9A-Fa-f]+')
-
-admin = Util.spawn(Util.getIceBoxAdmin() + ' --IceBoxAdmin.ServiceManager.Proxy="icebox1/admin \
- -f IceBox.ServiceManager:tcp -p 9991 -h 127.0.0.1" shutdown')
-admin.waitTestSuccess()
-admin = Util.spawn(Util.getIceBoxAdmin() + ' --IceBoxAdmin.ServiceManager.Proxy="icebox2/admin \
- -f IceBox.ServiceManager:tcp -p 9992 -h 127.0.0.1" shutdown')
-admin.waitTestSuccess()
-admin = Util.spawn(Util.getIceBoxAdmin() + ' --IceBoxAdmin.ServiceManager.Proxy="icebox3/admin \
- -f IceBox.ServiceManager:tcp -p 9993 -h 127.0.0.1" shutdown')
-admin.waitTestSuccess()
-
-ib1.waitTestSuccess()
-ib2.waitTestSuccess()
-ib3.waitTestSuccess()
-print("ok")