summaryrefslogtreecommitdiff
path: root/cpp/demo/IceStorm/replicated/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/replicated/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/replicated/expect.py')
-rwxr-xr-xcpp/demo/IceStorm/replicated/expect.py124
1 files changed, 0 insertions, 124 deletions
diff --git a/cpp/demo/IceStorm/replicated/expect.py b/cpp/demo/IceStorm/replicated/expect.py
deleted file mode 100755
index 58c95973c81..00000000000
--- a/cpp/demo/IceStorm/replicated/expect.py
+++ /dev/null
@@ -1,124 +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
-
-desc = 'application.xml'
-fi = open(desc, "r")
-desc = 'tmp_application.xml'
-fo = open(desc, "w")
-for l in fi:
- if l.find('exe="icebox"') != -1:
- l = l.replace('exe="icebox"', 'exe="%s"' % Util.getIceBox())
- fo.write(l)
-fi.close()
-fo.close()
-
-sys.stdout.write("cleaning databases... ")
-sys.stdout.flush()
-Util.cleanDbDir("db/node")
-Util.cleanDbDir("db/registry")
-print("ok")
-
-sys.stdout.write("cleaning old log files... ")
-for f in ["db/DemoIceStorm-1.out", "db/DemoIceStorm-2.out", "db/DemoIceStorm-3.out"]:
- try:
- os.remove(f)
- except:
- pass
-print("ok")
-
-if Util.defaultHost:
- args = ' --IceGrid.Node.PropertiesOverride="Ice.Default.Host=127.0.0.1"'
-else:
- args = ''
-
-sys.stdout.write("starting icegridnode... ")
-sys.stdout.flush()
-node = Util.spawn(Util.getIceGridNode() + ' --Ice.Config=config.grid --IceGrid.Node.Output=db --IceGrid.Node.RedirectErrToOut --Ice.PrintAdapterReady %s' % (args))
-node.expect('IceGrid.Registry.Server ready\nIceGrid.Registry.Client ready\nIceGrid.Registry.Discovery ready\nIceGrid.Node ready')
-print("ok")
-
-sys.stdout.write("deploying application... ")
-sys.stdout.flush()
-admin = Util.spawn(Util.getIceGridAdmin() + ' --Ice.Config=config.grid')
-admin.expect('>>>')
-admin.sendline("application add \'%s\'" %(desc))
-admin.expect('>>>')
-admin.sendline("server start DemoIceStorm-1")
-admin.expect('>>>')
-admin.sendline("server start DemoIceStorm-2")
-admin.expect('>>>')
-admin.sendline("server start DemoIceStorm-3")
-admin.expect('>>>')
-print("ok")
-
-sys.stdout.write("testing pub/sub... ")
-sys.stdout.flush()
-sub = Util.spawn('./subscriber --Ice.PrintAdapterReady')
-
-icestorm1 = Util.watch("db/DemoIceStorm-1.out")
-icestorm2 = Util.watch("db/DemoIceStorm-2.out")
-icestorm3 = Util.watch("db/DemoIceStorm-3.out")
-
-icestorm1.expect('Election: node 1: reporting for duty in group 3:[-0-9A-Fa-f]+ with coordinator 3', timeout = 60)
-icestorm2.expect('Election: node 2: reporting for duty in group 3:[-0-9A-Fa-f]+ with coordinator 3', timeout = 60)
-icestorm3.expect('Election: node 3: reporting for duty in group 3:[-0-9A-Fa-f]+ as coordinator', timeout = 60)
-
-icestorm3.expect('DemoIceStorm-3-IceStorm: Topic: time: subscribeAndGetPublisher: [-0-9A-Fa-f]+', timeout = 60)
-icestorm1.expect('DemoIceStorm-1-IceStorm: Topic: time: add replica observer: [-0-9A-Fa-f]+', timeout = 60)
-icestorm2.expect('DemoIceStorm-2-IceStorm: Topic: time: add replica observer: [-0-9A-Fa-f]+', timeout = 60)
-
-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... ")
-sub.kill(signal.SIGINT)
-sub.waitTestSuccess()
-pub.kill(signal.SIGINT)
-pub.waitTestSuccess()
-
-admin.sendline("server stop DemoIceStorm-1")
-admin.expect('>>>')
-admin.sendline("server stop DemoIceStorm-2")
-admin.expect('>>>')
-admin.sendline("server stop DemoIceStorm-3")
-admin.expect('>>>')
-
-icestorm1.expect('DemoIceStorm-1-IceStorm: Topic: time: remove replica observer: [-0-9A-Fa-f]+')
-icestorm2.expect('DemoIceStorm-2-IceStorm: Topic: time: remove replica observer: [-0-9A-Fa-f]+')
-icestorm3.expect('DemoIceStorm-3-IceStorm: Topic: time: unsubscribe: [-0-9A-Fa-f]+')
-
-icestorm1.terminate()
-icestorm2.terminate()
-icestorm3.terminate()
-
-admin.sendline('registry shutdown Master')
-admin.sendline('exit')
-admin.waitTestSuccess()
-node.waitTestSuccess()
-print("ok")