diff options
Diffstat (limited to 'java/test/Ice/location/AllTests.java')
-rw-r--r-- | java/test/Ice/location/AllTests.java | 576 |
1 files changed, 288 insertions, 288 deletions
diff --git a/java/test/Ice/location/AllTests.java b/java/test/Ice/location/AllTests.java index a73a8a6a2e2..9918e8e11cd 100644 --- a/java/test/Ice/location/AllTests.java +++ b/java/test/Ice/location/AllTests.java @@ -23,335 +23,335 @@ public class AllTests public static void allTests(Ice.Communicator communicator) { - ServerManagerPrx manager = ServerManagerPrxHelper.checkedCast( - communicator.stringToProxy("ServerManager :default -t 10000 -p 12010")); - test(manager != null); - TestLocatorPrx locator = TestLocatorPrxHelper.uncheckedCast(communicator.getDefaultLocator()); - test(locator != null); + ServerManagerPrx manager = ServerManagerPrxHelper.checkedCast( + communicator.stringToProxy("ServerManager :default -t 10000 -p 12010")); + test(manager != null); + TestLocatorPrx locator = TestLocatorPrxHelper.uncheckedCast(communicator.getDefaultLocator()); + test(locator != null); - System.out.print("testing stringToProxy... "); + System.out.print("testing stringToProxy... "); System.out.flush(); - Ice.ObjectPrx base = communicator.stringToProxy("test @ TestAdapter"); - Ice.ObjectPrx base2 = communicator.stringToProxy("test @ TestAdapter"); - Ice.ObjectPrx base3 = communicator.stringToProxy("test"); - Ice.ObjectPrx base4 = communicator.stringToProxy("ServerManager"); - Ice.ObjectPrx base5 = communicator.stringToProxy("test2"); - Ice.ObjectPrx base6 = communicator.stringToProxy("test @ ReplicatedAdapter"); - System.out.println("ok"); + Ice.ObjectPrx base = communicator.stringToProxy("test @ TestAdapter"); + Ice.ObjectPrx base2 = communicator.stringToProxy("test @ TestAdapter"); + Ice.ObjectPrx base3 = communicator.stringToProxy("test"); + Ice.ObjectPrx base4 = communicator.stringToProxy("ServerManager"); + Ice.ObjectPrx base5 = communicator.stringToProxy("test2"); + Ice.ObjectPrx base6 = communicator.stringToProxy("test @ ReplicatedAdapter"); + System.out.println("ok"); - System.out.print("testing ice_locator and ice_getLocator... "); - test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), communicator.getDefaultLocator()) == 0); - Ice.LocatorPrx anotherLocator = - Ice.LocatorPrxHelper.uncheckedCast(communicator.stringToProxy("anotherLocator")); - base = base.ice_locator(anotherLocator); - test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), anotherLocator) == 0); - communicator.setDefaultLocator(null); - base = communicator.stringToProxy("test @ TestAdapter"); - test(base.ice_getLocator() == null); - base = base.ice_locator(anotherLocator); - test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), anotherLocator) == 0); - communicator.setDefaultLocator(locator); - base = communicator.stringToProxy("test @ TestAdapter"); - test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), communicator.getDefaultLocator()) == 0); - - // - // We also test ice_router/ice_getRouter (perhaps we should add a - // test/Ice/router test?) - // - test(base.ice_getRouter() == null); - Ice.RouterPrx anotherRouter = Ice.RouterPrxHelper.uncheckedCast(communicator.stringToProxy("anotherRouter")); - base = base.ice_router(anotherRouter); - test(Ice.Util.proxyIdentityCompare(base.ice_getRouter(), anotherRouter) == 0); - Ice.RouterPrx router = Ice.RouterPrxHelper.uncheckedCast(communicator.stringToProxy("dummyrouter")); - communicator.setDefaultRouter(router); - base = communicator.stringToProxy("test @ TestAdapter"); - test(Ice.Util.proxyIdentityCompare(base.ice_getRouter(), communicator.getDefaultRouter()) == 0); - communicator.setDefaultRouter(null); - base = communicator.stringToProxy("test @ TestAdapter"); - test(base.ice_getRouter() == null); - System.out.println("ok"); + System.out.print("testing ice_locator and ice_getLocator... "); + test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), communicator.getDefaultLocator()) == 0); + Ice.LocatorPrx anotherLocator = + Ice.LocatorPrxHelper.uncheckedCast(communicator.stringToProxy("anotherLocator")); + base = base.ice_locator(anotherLocator); + test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), anotherLocator) == 0); + communicator.setDefaultLocator(null); + base = communicator.stringToProxy("test @ TestAdapter"); + test(base.ice_getLocator() == null); + base = base.ice_locator(anotherLocator); + test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), anotherLocator) == 0); + communicator.setDefaultLocator(locator); + base = communicator.stringToProxy("test @ TestAdapter"); + test(Ice.Util.proxyIdentityCompare(base.ice_getLocator(), communicator.getDefaultLocator()) == 0); + + // + // We also test ice_router/ice_getRouter (perhaps we should add a + // test/Ice/router test?) + // + test(base.ice_getRouter() == null); + Ice.RouterPrx anotherRouter = Ice.RouterPrxHelper.uncheckedCast(communicator.stringToProxy("anotherRouter")); + base = base.ice_router(anotherRouter); + test(Ice.Util.proxyIdentityCompare(base.ice_getRouter(), anotherRouter) == 0); + Ice.RouterPrx router = Ice.RouterPrxHelper.uncheckedCast(communicator.stringToProxy("dummyrouter")); + communicator.setDefaultRouter(router); + base = communicator.stringToProxy("test @ TestAdapter"); + test(Ice.Util.proxyIdentityCompare(base.ice_getRouter(), communicator.getDefaultRouter()) == 0); + communicator.setDefaultRouter(null); + base = communicator.stringToProxy("test @ TestAdapter"); + test(base.ice_getRouter() == null); + System.out.println("ok"); - // - // Start a server, get the port of the adapter it's listening on, - // and add it to the configuration so that the client can locate - // the TestAdapter adapter. - // - System.out.print("starting server... "); + // + // Start a server, get the port of the adapter it's listening on, + // and add it to the configuration so that the client can locate + // the TestAdapter adapter. + // + System.out.print("starting server... "); System.out.flush(); - manager.startServer(); - System.out.println("ok"); + manager.startServer(); + System.out.println("ok"); - System.out.print("testing checked cast... "); + System.out.print("testing checked cast... "); System.out.flush(); - TestIntfPrx obj = TestIntfPrxHelper.checkedCast(base); - test(obj != null); - TestIntfPrx obj2 = TestIntfPrxHelper.checkedCast(base2); - test(obj2 != null); - TestIntfPrx obj3 = TestIntfPrxHelper.checkedCast(base3); - test(obj3 != null); - ServerManagerPrx obj4 = ServerManagerPrxHelper.checkedCast(base4); - test(obj4 != null); - TestIntfPrx obj5 = TestIntfPrxHelper.checkedCast(base5); - test(obj5 != null); - TestIntfPrx obj6 = TestIntfPrxHelper.checkedCast(base6); - test(obj6 != null); - System.out.println("ok"); + TestIntfPrx obj = TestIntfPrxHelper.checkedCast(base); + test(obj != null); + TestIntfPrx obj2 = TestIntfPrxHelper.checkedCast(base2); + test(obj2 != null); + TestIntfPrx obj3 = TestIntfPrxHelper.checkedCast(base3); + test(obj3 != null); + ServerManagerPrx obj4 = ServerManagerPrxHelper.checkedCast(base4); + test(obj4 != null); + TestIntfPrx obj5 = TestIntfPrxHelper.checkedCast(base5); + test(obj5 != null); + TestIntfPrx obj6 = TestIntfPrxHelper.checkedCast(base6); + test(obj6 != null); + System.out.println("ok"); - System.out.print("testing id@AdapterId indirect proxy... "); + System.out.print("testing id@AdapterId indirect proxy... "); System.out.flush(); - obj.shutdown(); - manager.startServer(); - try - { - obj2.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - System.out.println("ok"); + obj.shutdown(); + manager.startServer(); + try + { + obj2.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + System.out.println("ok"); - System.out.print("testing id@ReplicaGroupId indirect proxy... "); + System.out.print("testing id@ReplicaGroupId indirect proxy... "); System.out.flush(); - obj.shutdown(); - manager.startServer(); - try - { - obj6 = TestIntfPrxHelper.checkedCast(base6); - obj6.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - System.out.println("ok"); + obj.shutdown(); + manager.startServer(); + try + { + obj6 = TestIntfPrxHelper.checkedCast(base6); + obj6.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + System.out.println("ok"); - System.out.print("testing identity indirect proxy... "); + System.out.print("testing identity indirect proxy... "); System.out.flush(); - obj.shutdown(); - manager.startServer(); - try - { - obj3 = TestIntfPrxHelper.checkedCast(base3); - obj3.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - try - { - obj2 = TestIntfPrxHelper.checkedCast(base2); - obj2.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - obj.shutdown(); - manager.startServer(); - try - { - obj2 = TestIntfPrxHelper.checkedCast(base2); - obj2.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - try - { - obj3 = TestIntfPrxHelper.checkedCast(base3); - obj3.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - obj.shutdown(); - manager.startServer(); - try - { - obj2 = TestIntfPrxHelper.checkedCast(base2); - obj2.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - obj.shutdown(); - manager.startServer(); - try - { - obj3 = TestIntfPrxHelper.checkedCast(base2); - obj3.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } - obj.shutdown(); - manager.startServer(); - try - { - obj5 = TestIntfPrxHelper.checkedCast(base5); - obj5.ice_ping(); - } - catch(Ice.LocalException ex) - { - test(false); - } + obj.shutdown(); + manager.startServer(); + try + { + obj3 = TestIntfPrxHelper.checkedCast(base3); + obj3.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + try + { + obj2 = TestIntfPrxHelper.checkedCast(base2); + obj2.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + obj.shutdown(); + manager.startServer(); + try + { + obj2 = TestIntfPrxHelper.checkedCast(base2); + obj2.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + try + { + obj3 = TestIntfPrxHelper.checkedCast(base3); + obj3.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + obj.shutdown(); + manager.startServer(); + try + { + obj2 = TestIntfPrxHelper.checkedCast(base2); + obj2.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + obj.shutdown(); + manager.startServer(); + try + { + obj3 = TestIntfPrxHelper.checkedCast(base2); + obj3.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } + obj.shutdown(); + manager.startServer(); + try + { + obj5 = TestIntfPrxHelper.checkedCast(base5); + obj5.ice_ping(); + } + catch(Ice.LocalException ex) + { + test(false); + } - System.out.println("ok"); + System.out.println("ok"); - System.out.print("testing proxy with unknown identity... "); - System.out.flush(); - try - { - base = communicator.stringToProxy("unknown/unknown"); - base.ice_ping(); - test(false); - } - catch(Ice.NotRegisteredException ex) - { - test(ex.kindOfObject.equals("object")); - test(ex.id.equals("unknown/unknown")); - } - System.out.println("ok"); + System.out.print("testing proxy with unknown identity... "); + System.out.flush(); + try + { + base = communicator.stringToProxy("unknown/unknown"); + base.ice_ping(); + test(false); + } + catch(Ice.NotRegisteredException ex) + { + test(ex.kindOfObject.equals("object")); + test(ex.id.equals("unknown/unknown")); + } + System.out.println("ok"); - System.out.print("testing proxy with unknown adapter... "); - System.out.flush(); - try - { - base = communicator.stringToProxy("test @ TestAdapterUnknown"); - base.ice_ping(); - test(false); - } - catch(Ice.NotRegisteredException ex) - { - test(ex.kindOfObject.equals("object adapter")); - test(ex.id.equals("TestAdapterUnknown")); - } - System.out.println("ok"); + System.out.print("testing proxy with unknown adapter... "); + System.out.flush(); + try + { + base = communicator.stringToProxy("test @ TestAdapterUnknown"); + base.ice_ping(); + test(false); + } + catch(Ice.NotRegisteredException ex) + { + test(ex.kindOfObject.equals("object adapter")); + test(ex.id.equals("TestAdapterUnknown")); + } + System.out.println("ok"); - System.out.print("testing locator cache timeout... "); - System.out.flush(); - - int count = locator.getRequestCount(); - communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(0).ice_ping(); // No locator cache. - test(++count == locator.getRequestCount()); - communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(0).ice_ping(); // No locator cache. - test(++count == locator.getRequestCount()); - communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout. - test(count == locator.getRequestCount()); - try - { - Thread.sleep(1200); + System.out.print("testing locator cache timeout... "); + System.out.flush(); + + int count = locator.getRequestCount(); + communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(0).ice_ping(); // No locator cache. + test(++count == locator.getRequestCount()); + communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(0).ice_ping(); // No locator cache. + test(++count == locator.getRequestCount()); + communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout. + test(count == locator.getRequestCount()); + try + { + Thread.sleep(1200); } catch(InterruptedException ex) { } - communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout. - test(++count == locator.getRequestCount()); - - communicator.stringToProxy("test").ice_locatorCacheTimeout(0).ice_ping(); // No locator cache. - count += 2; - test(count == locator.getRequestCount()); - communicator.stringToProxy("test").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout - test(count == locator.getRequestCount()); - try - { - Thread.sleep(1200); + communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout. + test(++count == locator.getRequestCount()); + + communicator.stringToProxy("test").ice_locatorCacheTimeout(0).ice_ping(); // No locator cache. + count += 2; + test(count == locator.getRequestCount()); + communicator.stringToProxy("test").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout + test(count == locator.getRequestCount()); + try + { + Thread.sleep(1200); } catch(InterruptedException ex) { } - communicator.stringToProxy("test").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout - count += 2; - test(count == locator.getRequestCount()); - - communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(-1).ice_ping(); - test(count == locator.getRequestCount()); - communicator.stringToProxy("test").ice_locatorCacheTimeout(-1).ice_ping(); - test(count == locator.getRequestCount()); - communicator.stringToProxy("test@TestAdapter").ice_ping(); - test(count == locator.getRequestCount()); - communicator.stringToProxy("test").ice_ping(); - test(count == locator.getRequestCount()); + communicator.stringToProxy("test").ice_locatorCacheTimeout(1).ice_ping(); // 1s timeout + count += 2; + test(count == locator.getRequestCount()); + + communicator.stringToProxy("test@TestAdapter").ice_locatorCacheTimeout(-1).ice_ping(); + test(count == locator.getRequestCount()); + communicator.stringToProxy("test").ice_locatorCacheTimeout(-1).ice_ping(); + test(count == locator.getRequestCount()); + communicator.stringToProxy("test@TestAdapter").ice_ping(); + test(count == locator.getRequestCount()); + communicator.stringToProxy("test").ice_ping(); + test(count == locator.getRequestCount()); - test(communicator.stringToProxy("test").ice_locatorCacheTimeout(99).ice_getLocatorCacheTimeout() == 99); - - System.out.println("ok"); + test(communicator.stringToProxy("test").ice_locatorCacheTimeout(99).ice_getLocatorCacheTimeout() == 99); + + System.out.println("ok"); - System.out.print("testing proxy from server... "); + System.out.print("testing proxy from server... "); System.out.flush(); - HelloPrx hello = obj.getHello(); - test(hello.ice_getAdapterId().equals("TestAdapter")); - hello = obj.getReplicatedHello(); - test(hello.ice_getAdapterId().equals("ReplicatedAdapter")); - hello.sayHello(); - System.out.println("ok"); + HelloPrx hello = obj.getHello(); + test(hello.ice_getAdapterId().equals("TestAdapter")); + hello = obj.getReplicatedHello(); + test(hello.ice_getAdapterId().equals("ReplicatedAdapter")); + hello.sayHello(); + System.out.println("ok"); - System.out.print("testing proxy from server after shutdown... "); + System.out.print("testing proxy from server after shutdown... "); System.out.flush(); - obj.shutdown(); - manager.startServer(); - hello.sayHello(); - System.out.println("ok"); + obj.shutdown(); + manager.startServer(); + hello.sayHello(); + System.out.println("ok"); - System.out.print("testing object migration..."); - System.out.flush(); - hello = HelloPrxHelper.checkedCast(communicator.stringToProxy("hello")); - obj.migrateHello(); - hello.sayHello(); - obj.migrateHello(); - hello.sayHello(); - obj.migrateHello(); - hello.sayHello(); - System.out.println("ok"); + System.out.print("testing object migration..."); + System.out.flush(); + hello = HelloPrxHelper.checkedCast(communicator.stringToProxy("hello")); + obj.migrateHello(); + hello.sayHello(); + obj.migrateHello(); + hello.sayHello(); + obj.migrateHello(); + hello.sayHello(); + System.out.println("ok"); - System.out.print("testing whether server is gone... "); + System.out.print("testing whether server is gone... "); System.out.flush(); - obj.shutdown(); - try - { - obj2.ice_ping(); - test(false); - } + obj.shutdown(); + try + { + obj2.ice_ping(); + test(false); + } catch(Ice.LocalException ex) { System.out.println("ok"); } - System.out.print("testing indirect proxies to collocated objects... "); - Ice.Properties properties = communicator.getProperties(); - properties.setProperty("Ice.PrintAdapterReady", "0"); - Ice.ObjectAdapter adapter = communicator.createObjectAdapterWithEndpoints("Hello", "default"); - adapter.setLocator(locator); - TestLocatorRegistryPrx registry = TestLocatorRegistryPrxHelper.checkedCast(locator.getRegistry()); - test(registry != null); + System.out.print("testing indirect proxies to collocated objects... "); + Ice.Properties properties = communicator.getProperties(); + properties.setProperty("Ice.PrintAdapterReady", "0"); + Ice.ObjectAdapter adapter = communicator.createObjectAdapterWithEndpoints("Hello", "default"); + adapter.setLocator(locator); + TestLocatorRegistryPrx registry = TestLocatorRegistryPrxHelper.checkedCast(locator.getRegistry()); + test(registry != null); - Ice.Identity id = new Ice.Identity(); - id.name = Ice.Util.generateUUID(); - registry.addObject(adapter.add(new HelloI(), id)); - adapter.activate(); + Ice.Identity id = new Ice.Identity(); + id.name = Ice.Util.generateUUID(); + registry.addObject(adapter.add(new HelloI(), id)); + adapter.activate(); - try - { - HelloPrx helloPrx = HelloPrxHelper.checkedCast( - communicator.stringToProxy("\"" + communicator.identityToString(id) + "\"")); - Ice.Connection connection = helloPrx.ice_getConnection(); - test(false); - } - catch(Ice.CollocationOptimizationException ex) - { - System.out.println("ok"); - } - adapter.deactivate(); + try + { + HelloPrx helloPrx = HelloPrxHelper.checkedCast( + communicator.stringToProxy("\"" + communicator.identityToString(id) + "\"")); + Ice.Connection connection = helloPrx.ice_getConnection(); + test(false); + } + catch(Ice.CollocationOptimizationException ex) + { + System.out.println("ok"); + } + adapter.deactivate(); - System.out.print("shutdown server manager... "); + System.out.print("shutdown server manager... "); System.out.flush(); - manager.shutdown(); - System.out.println("ok"); + manager.shutdown(); + System.out.println("ok"); } } |