diff options
Diffstat (limited to 'py/demo/IceGrid/allocate/Client.py')
-rw-r--r-- | py/demo/IceGrid/allocate/Client.py | 110 |
1 files changed, 55 insertions, 55 deletions
diff --git a/py/demo/IceGrid/allocate/Client.py b/py/demo/IceGrid/allocate/Client.py index 49e89489524..8614d638c5f 100644 --- a/py/demo/IceGrid/allocate/Client.py +++ b/py/demo/IceGrid/allocate/Client.py @@ -36,11 +36,11 @@ class SessionKeepAliveThread(threading.Thread): while not self._terminated: self._cond.wait(self._timeout) if self._terminated: - break + break try: self._session.keepAlive() except Ice.LocalException, ex: - break + break finally: self._cond.release() @@ -54,70 +54,70 @@ class SessionKeepAliveThread(threading.Thread): class Client(Ice.Application): def run(self, args): - status = True - registry = IceGrid.RegistryPrx.checkedCast(self.communicator().stringToProxy("DemoIceGrid/Registry")) - if registry == None: - print self.appName() + ": could not contact registry" - return False + status = True + registry = IceGrid.RegistryPrx.checkedCast(self.communicator().stringToProxy("DemoIceGrid/Registry")) + if registry == None: + print self.appName() + ": could not contact registry" + return False - while True: - print "This demo accepts any user-id / password combination." - id = raw_input("user id: ").strip() - pw = raw_input("password: ").strip() - try: - session = registry.createSession(id, pw) - break - except IceGrid.PermissionDeniedException, ex: - print "permission denied:\n" + ex.reason + while True: + print "This demo accepts any user-id / password combination." + id = raw_input("user id: ").strip() + pw = raw_input("password: ").strip() + try: + session = registry.createSession(id, pw) + break + except IceGrid.PermissionDeniedException, ex: + print "permission denied:\n" + ex.reason - keepAlive = SessionKeepAliveThread(session, registry.getSessionTimeout() / 2) - keepAlive.start() + keepAlive = SessionKeepAliveThread(session, registry.getSessionTimeout() / 2) + keepAlive.start() - try: - try: - hello = Demo.HelloPrx.checkedCast(\ - session.allocateObjectById(self.communicator().stringToIdentity("hello"))) - except IceGrid.ObjectNotRegisteredException: - hello = Demo.HelloPrx.checkedCast(session.allocateObjectByType("::Demo::Hello")) + try: + try: + hello = Demo.HelloPrx.checkedCast(\ + session.allocateObjectById(self.communicator().stringToIdentity("hello"))) + except IceGrid.ObjectNotRegisteredException: + hello = Demo.HelloPrx.checkedCast(session.allocateObjectByType("::Demo::Hello")) - menu() + menu() - c = None - while c != 'x': - try: - c = raw_input("==> ") - if c == 't': - hello.sayHello() - elif c == 's': - hello.shutdown() - elif c == 'x': - pass # Nothing to do - elif c == '?': - menu() - else: - print "unknown command `" + c + "'" - menu() - except EOFError: - break - except KeyboardInterrupt: - break - except IceGrid.AllocationException, ex: + c = None + while c != 'x': + try: + c = raw_input("==> ") + if c == 't': + hello.sayHello() + elif c == 's': + hello.shutdown() + elif c == 'x': + pass # Nothing to do + elif c == '?': + menu() + else: + print "unknown command `" + c + "'" + menu() + except EOFError: + break + except KeyboardInterrupt: + break + except IceGrid.AllocationException, ex: print self.appName() + ": could not allocate object: " + ex.reason status = False - except: + except: print self.appName() + ": could not allocate object: " + str(sys.exc_info()[0]) status = False - # - # Destroy the keepAlive thread and the sesion object otherwise - # the session will be kept allocated until the timeout occurs. - # Destroying the session will release all allocated objects. - # - keepAlive.terminate() - keepAlive.join() - session.destroy(); + # + # Destroy the keepAlive thread and the sesion object otherwise + # the session will be kept allocated until the timeout occurs. + # Destroying the session will release all allocated objects. + # + keepAlive.terminate() + keepAlive.join() + session.destroy(); - return status + return status app = Client() sys.exit(app.main(sys.argv, "config.client")) |