diff options
author | Mark Spruiell <mes@zeroc.com> | 2005-10-04 22:26:01 +0000 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2005-10-04 22:26:01 +0000 |
commit | 6f1d866747c0ea2077d72586070511b9fd3a1a42 (patch) | |
tree | 6f6b71cea06281de0937b88165544512c88df857 /cpp/config/IcePackAdmin.py | |
parent | bug 475 - removing IcePack (yet again) (diff) | |
download | ice-6f1d866747c0ea2077d72586070511b9fd3a1a42.tar.bz2 ice-6f1d866747c0ea2077d72586070511b9fd3a1a42.tar.xz ice-6f1d866747c0ea2077d72586070511b9fd3a1a42.zip |
bug 475 - removing IcePack
Diffstat (limited to 'cpp/config/IcePackAdmin.py')
-rw-r--r-- | cpp/config/IcePackAdmin.py | 279 |
1 files changed, 0 insertions, 279 deletions
diff --git a/cpp/config/IcePackAdmin.py b/cpp/config/IcePackAdmin.py deleted file mode 100644 index 28ec571bf54..00000000000 --- a/cpp/config/IcePackAdmin.py +++ /dev/null @@ -1,279 +0,0 @@ -#!/usr/bin/env python -# ********************************************************************** -# -# Copyright (c) 2003-2005 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, TestUtil -import time -from threading import Thread - -for toplevel in [".", "..", "../..", "../../..", "../../../.."]: - toplevel = os.path.normpath(toplevel) - if os.path.exists(os.path.join(toplevel, "config", "TestUtil.py")): - break -else: - raise "can't find toplevel directory!" - -icePackPort = "0"; - -class ReaderThread(Thread): - def __init__(self, pipe, token): - self.pipe = pipe - self.token = token - Thread.__init__(self) - - def run(self): - - try: - while 1: - line = self.pipe.readline() - if not line: break - print self.token + ": " + line, - except IOError: - pass - - try: - self.pipe.close() - except IOError: - pass - -def startIcePackRegistry(port, testdir): - - global icePackPort - - icePackPort = port - - icePack = os.path.join(toplevel, "bin", "icepackregistry") - - dataDir = os.path.join(testdir, "db", "registry") - if not os.path.exists(dataDir): - os.mkdir(dataDir) - - print "starting icepack registry...", - command = icePack + TestUtil.clientServerOptions + ' --nowarn ' + \ - r' --IcePack.Registry.Client.Endpoints="default -p ' + icePackPort + ' -t 5000" ' + \ - r' --Ice.Warn.Connections=0' + \ - r' --IcePack.Registry.Server.Endpoints=default' + \ - r' --IcePack.Registry.Internal.Endpoints=default' + \ - r' --IcePack.Registry.Admin.Endpoints=default' + \ - r' --IcePack.Registry.Data=' + dataDir + \ - r' --IcePack.Registry.DynamicRegistration' + \ - r' --IcePack.Registry.Trace.ServerRegistry=0' + \ - r' --IcePack.Registry.Trace.AdapterRegistry=0' + \ - r' --IcePack.Registry.Trace.ObjectRegistry=0' + \ - r' --IcePack.Registry.Trace.NodeRegistry=0' + \ - r' --Ice.ProgramName=icepackregistry' - - (stdin, icePackPipe) = os.popen4(command) - TestUtil.getServerPid(icePackPipe) - TestUtil.getAdapterReady(icePackPipe) - TestUtil.getAdapterReady(icePackPipe) - TestUtil.getAdapterReady(icePackPipe) - TestUtil.getAdapterReady(icePackPipe) - print "ok" - - readerThread = ReaderThread(icePackPipe, "IcePackRegistry") - readerThread.start() - return readerThread - -def startIcePackNode(testdir): - - icePack = os.path.join(toplevel, "bin", "icepacknode") - - dataDir = os.path.join(testdir, "db", "node") - if not os.path.exists(dataDir): - os.mkdir(dataDir) - - overrideOptions = '"' + TestUtil.clientServerOptions.replace("--", "") + \ - ' Ice.ServerIdleTime=0 Ice.PrintProcessId=0 Ice.PrintAdapterReady=0' + '"' - - print "starting icepack node...", - command = icePack + TestUtil.clientServerOptions + ' --nowarn ' + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' --Ice.Warn.Connections=0' + \ - r' --IcePack.Node.Endpoints=default' + \ - r' --IcePack.Node.WaitTime=30' + \ - r' --IcePack.Node.Data=' + dataDir + \ - r' --IcePack.Node.Name=localnode' + \ - r' --IcePack.Node.PropertiesOverride=' + overrideOptions + \ - r' --Ice.ProgramName=icepacknode' + \ - r' --IcePack.Node.Trace.Activator=0' + \ - r' --IcePack.Node.Trace.Adapter=0' + \ - r' --IcePack.Node.Trace.Server=0' + \ - r' --IcePack.Node.PrintServersReady=node' - - (stdin, icePackPipe) = os.popen4(command) - TestUtil.getServerPid(icePackPipe) - TestUtil.getAdapterReady(icePackPipe) - TestUtil.waitServiceReady(icePackPipe, 'node') - - print "ok" - - readerThread = ReaderThread(icePackPipe, "IcePackNode") - readerThread.start() - return readerThread - -def shutdownIcePackRegistry(): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - print "shutting down icepack registry...", - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "shutdown" ' + " 2>&1" - - icePackAdminPipe = os.popen(command) - TestUtil.printOutputFromPipe(icePackAdminPipe) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - TestUtil.killServers() - sys.exit(1) - print "ok" - -def shutdownIcePackNode(): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - print "shutting down icepack node...", - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "node shutdown localnode" ' + " 2>&1" - - icePackAdminPipe = os.popen(command) - TestUtil.printOutputFromPipe(icePackAdminPipe) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - TestUtil.killServers() - sys.exit(1) - print "ok" - -def addApplication(descriptor, options): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - descriptor = descriptor.replace("\\", "/") - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "application add \"' + descriptor + '\\" ' + options + ' \"' + " 2>&1" - - icePackAdminPipe = os.popen(command) - TestUtil.printOutputFromPipe(icePackAdminPipe) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - TestUtil.killServers() - sys.exit(1) - -def removeApplication(name): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "application remove \"' + name + '\\" \"' + " 2>&1" - - icePackAdminPipe = os.popen(command) - TestUtil.printOutputFromPipe(icePackAdminPipe) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - TestUtil.killServers() - sys.exit(1) - -def addServer(serverDescriptor, options): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - serverDescriptor = serverDescriptor.replace("\\", "/"); - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "server add ' + serverDescriptor + ' localnode ' + \ - r' ' + options + '\"' + " 2>&1" - - icePackAdminPipe = os.popen(command) - TestUtil.printOutputFromPipe(icePackAdminPipe) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - print "bailing out" - TestUtil.killServers() - sys.exit(1) - -def removeServer(name): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "server remove \"' + name + '\\" \"' + " 2>&1" - - icePackAdminPipe = os.popen(command) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - TestUtil.killServers() - sys.exit(1) - -def startServer(name): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "server start \"' + name + '\\""' + " 2>&1" - - icePackAdminPipe = os.popen(command) - icePackAdminStatus = icePackAdminPipe.close() - if icePackAdminStatus: - TestUtil.killServers() - sys.exit(1) - -def listAdapters(): - - global icePackPort - icePackAdmin = os.path.join(toplevel, "bin", "icepackadmin") - - command = icePackAdmin + TestUtil.clientOptions + \ - r' "--Ice.Default.Locator=IcePack/Locator:default -p ' + icePackPort + '" ' + \ - r' -e "adapter list"' + " 2>&1" - - icePackAdminPipe = os.popen(command) - return icePackAdminPipe - -def cleanDbDir(path): - - try: - cleanServerDir(os.path.join(path, "node", "servers")) - except: - pass - - try: - TestUtil.cleanDbDir(os.path.join(path, "node", "db")) - except: - pass - - try: - TestUtil.cleanDbDir(os.path.join(path, "registry")) - except: - pass - -def cleanServerDir(path): - - files = os.listdir(path) - - for filename in files: - fullpath = os.path.join(path, filename); - if os.path.isdir(fullpath): - cleanServerDir(fullpath) - os.rmdir(fullpath) - else: - os.remove(fullpath) - |