py/test/Ice/blobject/Client.py

   1 #!/usr/bin/env python
   2 # **********************************************************************
   3 #
   4 # Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   5 #
   6 # This copy of Ice is licensed to you under the terms described in the
   7 # ICE_LICENSE file included in this distribution.
   8 #
   9 # **********************************************************************
  10
  11 import os, sys, traceback
  12
  13 import Ice
  14 Ice.loadSlice('Test.ice')
  15 import Test
  16 import RouterI
  17
  18 def test(b):
  19     if not b:
  20         raise RuntimeError('test assertion failed')
  21
  22 def run(args, communicator, sync):
  23     hello = Test.HelloPrx.checkedCast(communicator.stringToProxy("test:default -p 12010"))
  24     hello.sayHello(False)
  25     hello.sayHello(False, { "_fwd":"o" } )
  26     test(hello.add(10, 20) == 30)
  27     try:
  28         hello.raiseUE()
  29         test(False)
  30     except Test.UE:
  31         pass
  32
  33     try:
  34         Test.HelloPrx.checkedCast(communicator.stringToProxy("unknown:default -p 12010 -t 10000"))
  35         test(False)
  36     except Ice.ObjectNotExistException:
  37         pass
  38
  39     # First try an object at a non-existent endpoint.
  40     try:
  41         Test.HelloPrx.checkedCast(communicator.stringToProxy("missing:default -p 12000 -t 10000"))
  42         test(False)
  43     except Ice.UnknownLocalException, e:
  44         test(e.unknown.find('ConnectionRefusedException'))
  45     if sync:
  46         hello.shutdown()
  47     return True
  48
  49 argv = sys.argv[:]  # Clone the arguments to use again later
  50
  51 try:
  52     initData = Ice.InitializationData()
  53     initData.properties = Ice.createProperties(argv)
  54     initData.properties.setProperty('Ice.Warn.Dispatch', '0')
  55     communicator = Ice.initialize(argv, initData)
  56     router = RouterI.RouterI(communicator, False)
  57     print "testing async blobject...",
  58     sys.stdout.flush()
  59     status = run(sys.argv, communicator, False)
  60     print "ok"
  61     router.destroy()
  62 except:
  63     traceback.print_exc()
  64     status = False
  65
  66 if communicator:
  67     try:
  68         communicator.destroy()
  69     except:
  70         traceback.print_exc()
  71         status = False
  72
  73 if status:
  74     try:
  75         initData = Ice.InitializationData()
  76         initData.properties = Ice.createProperties(sys.argv)
  77         initData.properties.setProperty('Ice.Warn.Dispatch', '0')
  78         communicator = Ice.initialize(sys.argv, initData)
  79         router = RouterI.RouterI(communicator, True)
  80         print "testing sync blobject...",
  81         sys.stdout.flush()
  82         status = run(sys.argv, communicator, True)
  83         print "ok"
  84         router.destroy()
  85     except:
  86         traceback.print_exc()
  87         status = False
  88
  89     if communicator:
  90         try:
  91             communicator.destroy()
  92         except:
  93             traceback.print_exc()
  94             status = False
  95
  96 sys.exit(not status)