diff options
Diffstat (limited to 'py/demo/Glacier2/callback/Client.py')
| -rw-r--r-- | py/demo/Glacier2/callback/Client.py | 110 |
1 files changed, 55 insertions, 55 deletions
diff --git a/py/demo/Glacier2/callback/Client.py b/py/demo/Glacier2/callback/Client.py index c39b818c2a2..4aae7ed161e 100644 --- a/py/demo/Glacier2/callback/Client.py +++ b/py/demo/Glacier2/callback/Client.py @@ -34,37 +34,37 @@ class CallbackReceiverI(Demo.CallbackReceiver): class Client(Ice.Application): def run(self, args): defaultRouter = self.communicator().getDefaultRouter() - if not defaultRouter: - print self.appName() + ": no default router set" - return 1 + if not defaultRouter: + print self.appName() + ": no default router set" + return 1 - router = Glacier2.RouterPrx.checkedCast(defaultRouter) - if not router: - print self.appName() + ": configured router is not a Glacier2 router" - return 1 + router = Glacier2.RouterPrx.checkedCast(defaultRouter) + if not router: + print self.appName() + ": configured router is not a Glacier2 router" + return 1 - while True: - print "This demo accepts any user-id / password combination." + while True: + print "This demo accepts any user-id / password combination." id = raw_input("user id: ") pw = raw_input("password: ") - try: - router.createSession(id, pw) - break - except Glacier2.PermissionDeniedException, ex: - print "permission denied:\n" + ex.reason - - category = router.getCategoryForClient() - callbackReceiverIdent = Ice.Identity() - callbackReceiverIdent.name = "callbackReceiver" - callbackReceiverIdent.category = category - callbackReceiverFakeIdent = Ice.Identity() - callbackReceiverFakeIdent.name = "callbackReceiver" - callbackReceiverFakeIdent.category = "fake" + try: + router.createSession(id, pw) + break + except Glacier2.PermissionDeniedException, ex: + print "permission denied:\n" + ex.reason + + category = router.getCategoryForClient() + callbackReceiverIdent = Ice.Identity() + callbackReceiverIdent.name = "callbackReceiver" + callbackReceiverIdent.category = category + callbackReceiverFakeIdent = Ice.Identity() + callbackReceiverFakeIdent.name = "callbackReceiver" + callbackReceiverFakeIdent.category = "fake" base = self.communicator().propertyToProxy('Callback.Proxy') twoway = Demo.CallbackPrx.checkedCast(base) - oneway = Demo.CallbackPrx.uncheckedCast(twoway.ice_oneway()) - batchOneway = Demo.CallbackPrx.uncheckedCast(twoway.ice_batchOneway()) + oneway = Demo.CallbackPrx.uncheckedCast(twoway.ice_oneway()) + batchOneway = Demo.CallbackPrx.uncheckedCast(twoway.ice_batchOneway()) adapter = self.communicator().createObjectAdapter("Callback.Client") adapter.add(CallbackReceiverI(), callbackReceiverIdent) @@ -75,7 +75,7 @@ class Client(Ice.Application): onewayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_oneway()) override = '' - fake = False + fake = False menu() @@ -84,41 +84,41 @@ class Client(Ice.Application): try: c = raw_input("==> ") if c == 't': - context = {} - context["_fwd"] = "t" - if not len(override) == 0: - context["_ovrd"] = override + context = {} + context["_fwd"] = "t" + if not len(override) == 0: + context["_ovrd"] = override twoway.initiateCallback(twowayR, context) elif c == 'o': - context = {} - context["_fwd"] = "o" - if not len(override) == 0: - context["_ovrd"] = override + context = {} + context["_fwd"] = "o" + if not len(override) == 0: + context["_ovrd"] = override oneway.initiateCallback(onewayR, context) elif c == 'O': - context = {} - context["_fwd"] = "O" - if not len(override) == 0: - context["_ovrd"] = override + context = {} + context["_fwd"] = "O" + if not len(override) == 0: + context["_ovrd"] = override batchOneway.initiateCallback(onewayR, context) - elif c == 'f': - self.communicator().flushBatchRequests() - elif c == 'v': - if len(override) == 0: - override = "some_value" - print "override context field is now `" + override + "'" - else: - override = '' - print "override context field is empty" - elif c == 'F': - fake = not fake - - if fake: - twowayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_identity(callbackReceiverFakeIdent)) - onewayR = Demo.CallbackReceiverPrx.uncheckedCast(onewayR.ice_identity(callbackReceiverFakeIdent)) - else: - twowayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_identity(callbackReceiverIdent)) - onewayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_identity(callbackReceiverIdent)) + elif c == 'f': + self.communicator().flushBatchRequests() + elif c == 'v': + if len(override) == 0: + override = "some_value" + print "override context field is now `" + override + "'" + else: + override = '' + print "override context field is empty" + elif c == 'F': + fake = not fake + + if fake: + twowayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_identity(callbackReceiverFakeIdent)) + onewayR = Demo.CallbackReceiverPrx.uncheckedCast(onewayR.ice_identity(callbackReceiverFakeIdent)) + else: + twowayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_identity(callbackReceiverIdent)) + onewayR = Demo.CallbackReceiverPrx.uncheckedCast(twowayR.ice_identity(callbackReceiverIdent)) elif c == 's': twoway.shutdown() elif c == 'x': |