summaryrefslogtreecommitdiff
path: root/java/test/IceGrid/simple/AllTests.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/test/IceGrid/simple/AllTests.java')
-rw-r--r--java/test/IceGrid/simple/AllTests.java418
1 files changed, 209 insertions, 209 deletions
diff --git a/java/test/IceGrid/simple/AllTests.java b/java/test/IceGrid/simple/AllTests.java
index 064298fc6a5..2bc7f9bd774 100644
--- a/java/test/IceGrid/simple/AllTests.java
+++ b/java/test/IceGrid/simple/AllTests.java
@@ -14,15 +14,15 @@ public class AllTests
static private class SessionKeepAliveThread extends Thread
{
SessionKeepAliveThread(IceGrid.AdminSessionPrx session, long timeout)
- {
- _session = session;
- _timeout = timeout;
- _terminated = false;
- }
+ {
+ _session = session;
+ _timeout = timeout;
+ _terminated = false;
+ }
- synchronized public void
- run()
- {
+ synchronized public void
+ run()
+ {
while(!_terminated)
{
try
@@ -34,29 +34,29 @@ public class AllTests
}
if(_terminated)
{
- break;
- }
+ break;
+ }
try
{
_session.keepAlive();
}
catch(Ice.LocalException ex)
{
- break;
+ break;
}
}
- }
+ }
- synchronized private void
- terminate()
- {
- _terminated = true;
- notify();
- }
+ synchronized private void
+ terminate()
+ {
+ _terminated = true;
+ notify();
+ }
- final private IceGrid.AdminSessionPrx _session;
- final private long _timeout;
- private boolean _terminated;
+ final private IceGrid.AdminSessionPrx _session;
+ final private long _timeout;
+ private boolean _terminated;
}
private static void
test(boolean b)
@@ -70,210 +70,210 @@ public class AllTests
public static void
allTests(Ice.Communicator communicator)
{
- System.out.print("testing stringToProxy... ");
- System.out.flush();
- String ref = "test @ TestAdapter";
- Ice.ObjectPrx base = communicator.stringToProxy(ref);
- test(base != null);
- System.out.println("ok");
+ System.out.print("testing stringToProxy... ");
+ System.out.flush();
+ String ref = "test @ TestAdapter";
+ Ice.ObjectPrx base = communicator.stringToProxy(ref);
+ test(base != null);
+ System.out.println("ok");
- System.out.print("testing checked cast... ");
- System.out.flush();
- TestIntfPrx obj = TestIntfPrxHelper.checkedCast(base);
- test(obj != null);
- test(obj.equals(base));
- System.out.println("ok");
-
- System.out.print("pinging server... ");
- System.out.flush();
- obj.ice_ping();
- System.out.println("ok");
-
- System.out.print("shutting down server... ");
- System.out.flush();
- obj.shutdown();
- System.out.println("ok");
+ System.out.print("testing checked cast... ");
+ System.out.flush();
+ TestIntfPrx obj = TestIntfPrxHelper.checkedCast(base);
+ test(obj != null);
+ test(obj.equals(base));
+ System.out.println("ok");
+
+ System.out.print("pinging server... ");
+ System.out.flush();
+ obj.ice_ping();
+ System.out.println("ok");
+
+ System.out.print("shutting down server... ");
+ System.out.flush();
+ obj.shutdown();
+ System.out.println("ok");
}
public static void
allTestsWithDeploy(Ice.Communicator communicator)
{
- System.out.print("testing stringToProxy... ");
- System.out.flush();
- Ice.ObjectPrx base = communicator.stringToProxy("test @ TestAdapter");
- test(base != null);
- Ice.ObjectPrx base2 = communicator.stringToProxy("test");
- test(base2 != null);
- System.out.println("ok");
+ System.out.print("testing stringToProxy... ");
+ System.out.flush();
+ Ice.ObjectPrx base = communicator.stringToProxy("test @ TestAdapter");
+ test(base != null);
+ Ice.ObjectPrx base2 = communicator.stringToProxy("test");
+ test(base2 != null);
+ System.out.println("ok");
- System.out.print("testing checked cast... ");
- System.out.flush();
- TestIntfPrx obj = TestIntfPrxHelper.checkedCast(base);
- test(obj != null);
- test(obj.equals(base));
- TestIntfPrx obj2 = TestIntfPrxHelper.checkedCast(base2);
- test(obj2 != null);
- test(obj2.equals(base2));
- System.out.println("ok");
-
- System.out.print("pinging server... ");
- System.out.flush();
- obj.ice_ping();
- obj2.ice_ping();
- System.out.println("ok");
+ System.out.print("testing checked cast... ");
+ System.out.flush();
+ TestIntfPrx obj = TestIntfPrxHelper.checkedCast(base);
+ test(obj != null);
+ test(obj.equals(base));
+ TestIntfPrx obj2 = TestIntfPrxHelper.checkedCast(base2);
+ test(obj2 != null);
+ test(obj2.equals(base2));
+ System.out.println("ok");
+
+ System.out.print("pinging server... ");
+ System.out.flush();
+ obj.ice_ping();
+ obj2.ice_ping();
+ System.out.println("ok");
- System.out.print("testing reference with unknown identity... ");
- System.out.flush();
- try
- {
- communicator.stringToProxy("unknown/unknown").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 reference with unknown identity... ");
+ System.out.flush();
+ try
+ {
+ communicator.stringToProxy("unknown/unknown").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 reference with unknown adapter... ");
- System.out.flush();
- try
- {
- communicator.stringToProxy("test @ TestAdapterUnknown").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 reference with unknown adapter... ");
+ System.out.flush();
+ try
+ {
+ communicator.stringToProxy("test @ TestAdapterUnknown").ice_ping();
+ test(false);
+ }
+ catch(Ice.NotRegisteredException ex)
+ {
+ test(ex.kindOfObject.equals("object adapter"));
+ test(ex.id.equals("TestAdapterUnknown"));
+ }
+ System.out.println("ok");
- IceGrid.RegistryPrx registry = IceGrid.RegistryPrxHelper.checkedCast(
- communicator.stringToProxy("IceGrid/Registry"));
- test(registry != null);
- IceGrid.AdminSessionPrx session = null;
- try
- {
- session = registry.createAdminSession("foo", "bar");
- }
- catch(IceGrid.PermissionDeniedException e)
- {
- test(false);
- }
+ IceGrid.RegistryPrx registry = IceGrid.RegistryPrxHelper.checkedCast(
+ communicator.stringToProxy("IceGrid/Registry"));
+ test(registry != null);
+ IceGrid.AdminSessionPrx session = null;
+ try
+ {
+ session = registry.createAdminSession("foo", "bar");
+ }
+ catch(IceGrid.PermissionDeniedException e)
+ {
+ test(false);
+ }
- SessionKeepAliveThread keepAlive = new SessionKeepAliveThread(session, registry.getSessionTimeout()/2);
- keepAlive.start();
+ SessionKeepAliveThread keepAlive = new SessionKeepAliveThread(session, registry.getSessionTimeout()/2);
+ keepAlive.start();
- IceGrid.AdminPrx admin = session.getAdmin();
- test(admin != null);
+ IceGrid.AdminPrx admin = session.getAdmin();
+ test(admin != null);
- try
- {
- admin.enableServer("server", false);
- admin.stopServer("server");
- }
- catch(IceGrid.ServerNotExistException ex)
- {
- test(false);
- }
- catch(IceGrid.ServerStopException ex)
- {
- test(false);
- }
- catch(IceGrid.NodeUnreachableException ex)
- {
- test(false);
- }
- catch(IceGrid.DeploymentException ex)
- {
- test(false);
- }
+ try
+ {
+ admin.enableServer("server", false);
+ admin.stopServer("server");
+ }
+ catch(IceGrid.ServerNotExistException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.ServerStopException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.NodeUnreachableException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.DeploymentException ex)
+ {
+ test(false);
+ }
- System.out.print("testing whether server is still reachable... ");
- System.out.flush();
- try
- {
- obj = TestIntfPrxHelper.checkedCast(base);
- test(false);
- }
- catch(Ice.NoEndpointException ex)
- {
- }
- try
- {
- obj2 = TestIntfPrxHelper.checkedCast(base2);
- test(false);
- }
- catch(Ice.NoEndpointException ex)
- {
- }
-
- try
- {
- admin.enableServer("server", true);
- }
- catch(IceGrid.ServerNotExistException ex)
- {
- test(false);
- }
- catch(IceGrid.NodeUnreachableException ex)
- {
- test(false);
- }
- catch(IceGrid.DeploymentException ex)
- {
- test(false);
- }
+ System.out.print("testing whether server is still reachable... ");
+ System.out.flush();
+ try
+ {
+ obj = TestIntfPrxHelper.checkedCast(base);
+ test(false);
+ }
+ catch(Ice.NoEndpointException ex)
+ {
+ }
+ try
+ {
+ obj2 = TestIntfPrxHelper.checkedCast(base2);
+ test(false);
+ }
+ catch(Ice.NoEndpointException ex)
+ {
+ }
+
+ try
+ {
+ admin.enableServer("server", true);
+ }
+ catch(IceGrid.ServerNotExistException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.NodeUnreachableException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.DeploymentException ex)
+ {
+ test(false);
+ }
- try
- {
- obj = TestIntfPrxHelper.checkedCast(base);
- }
- catch(Ice.NoEndpointException ex)
- {
- test(false);
- }
- try
- {
- obj2 = TestIntfPrxHelper.checkedCast(base2);
- }
- catch(Ice.NoEndpointException ex)
- {
- test(false);
- }
- System.out.println("ok");
+ try
+ {
+ obj = TestIntfPrxHelper.checkedCast(base);
+ }
+ catch(Ice.NoEndpointException ex)
+ {
+ test(false);
+ }
+ try
+ {
+ obj2 = TestIntfPrxHelper.checkedCast(base2);
+ }
+ catch(Ice.NoEndpointException ex)
+ {
+ test(false);
+ }
+ System.out.println("ok");
- try
- {
- admin.stopServer("server");
- }
- catch(IceGrid.ServerNotExistException ex)
- {
- test(false);
- }
- catch(IceGrid.ServerStopException ex)
- {
- test(false);
- }
- catch(IceGrid.NodeUnreachableException ex)
- {
- test(false);
- }
- catch(IceGrid.DeploymentException ex)
- {
- test(false);
- }
+ try
+ {
+ admin.stopServer("server");
+ }
+ catch(IceGrid.ServerNotExistException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.ServerStopException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.NodeUnreachableException ex)
+ {
+ test(false);
+ }
+ catch(IceGrid.DeploymentException ex)
+ {
+ test(false);
+ }
- keepAlive.terminate();
- try
- {
- keepAlive.join();
- }
- catch(InterruptedException e)
- {
- }
- session.destroy();
+ keepAlive.terminate();
+ try
+ {
+ keepAlive.join();
+ }
+ catch(InterruptedException e)
+ {
+ }
+ session.destroy();
}
}