summaryrefslogtreecommitdiff
path: root/java/test/Ice/location/AllTests.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/test/Ice/location/AllTests.java')
-rw-r--r--java/test/Ice/location/AllTests.java576
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");
}
}