summaryrefslogtreecommitdiff
path: root/java/test/Ice/faultTolerance/AllTests.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/test/Ice/faultTolerance/AllTests.java')
-rw-r--r--java/test/Ice/faultTolerance/AllTests.java524
1 files changed, 262 insertions, 262 deletions
diff --git a/java/test/Ice/faultTolerance/AllTests.java b/java/test/Ice/faultTolerance/AllTests.java
index 4f3eb09b2ea..937fb4aa99e 100644
--- a/java/test/Ice/faultTolerance/AllTests.java
+++ b/java/test/Ice/faultTolerance/AllTests.java
@@ -22,186 +22,186 @@ public class AllTests
private static class Callback
{
- Callback()
- {
- _called = false;
- }
+ Callback()
+ {
+ _called = false;
+ }
- public synchronized boolean
- check()
- {
- while(!_called)
- {
- try
- {
- wait(30000);
- }
- catch(InterruptedException ex)
- {
- continue;
- }
+ public synchronized boolean
+ check()
+ {
+ while(!_called)
+ {
+ try
+ {
+ wait(30000);
+ }
+ catch(InterruptedException ex)
+ {
+ continue;
+ }
- if(!_called)
- {
- return false; // Must be timeout.
- }
- }
-
- _called = false;
- return true;
- }
-
- public synchronized void
- called()
- {
- assert(!_called);
- _called = true;
- notify();
- }
+ if(!_called)
+ {
+ return false; // Must be timeout.
+ }
+ }
+
+ _called = false;
+ return true;
+ }
+
+ public synchronized void
+ called()
+ {
+ assert(!_called);
+ _called = true;
+ notify();
+ }
- private boolean _called;
+ private boolean _called;
}
private static class AMI_Test_pidI extends AMI_TestIntf_pid
{
- public void
- ice_response(int pid)
- {
- _pid = pid;
- callback.called();
- }
-
- public void
- ice_exception(Ice.LocalException ex)
- {
- test(false);
- }
-
- public void
- ice_exception(Ice.UserException ex)
- {
- test(false);
- }
-
- public int
- pid()
- {
- return _pid;
- }
-
- public boolean
- check()
- {
- return callback.check();
- }
+ public void
+ ice_response(int pid)
+ {
+ _pid = pid;
+ callback.called();
+ }
+
+ public void
+ ice_exception(Ice.LocalException ex)
+ {
+ test(false);
+ }
+
+ public void
+ ice_exception(Ice.UserException ex)
+ {
+ test(false);
+ }
+
+ public int
+ pid()
+ {
+ return _pid;
+ }
+
+ public boolean
+ check()
+ {
+ return callback.check();
+ }
- private int _pid;
-
- private Callback callback = new Callback();
+ private int _pid;
+
+ private Callback callback = new Callback();
}
private static class AMI_Test_shutdownI extends AMI_TestIntf_shutdown
{
- public void
- ice_response()
- {
- callback.called();
- }
-
- public void
- ice_exception(Ice.LocalException ex)
- {
- test(false);
- }
-
- public void
- ice_exception(Ice.UserException ex)
- {
- test(false);
- }
-
- public boolean
- check()
- {
- return callback.check();
- }
+ public void
+ ice_response()
+ {
+ callback.called();
+ }
+
+ public void
+ ice_exception(Ice.LocalException ex)
+ {
+ test(false);
+ }
+
+ public void
+ ice_exception(Ice.UserException ex)
+ {
+ test(false);
+ }
+
+ public boolean
+ check()
+ {
+ return callback.check();
+ }
- private Callback callback = new Callback();
+ private Callback callback = new Callback();
}
private static class AMI_Test_abortI extends AMI_TestIntf_abort
{
- public void
- ice_response()
- {
- test(false);
- }
-
- public void
- ice_exception(Ice.LocalException ex)
- {
- try
- {
- throw ex;
- }
- catch(Ice.ConnectionLostException exc)
- {
- }
- catch(Ice.ConnectFailedException exc)
- {
- }
- catch(Ice.SocketException exc)
- {
- }
- catch(Exception exc)
- {
- test(false);
- }
- callback.called();
- }
-
- public void
- ice_exception(Ice.UserException ex)
- {
- test(false);
- }
-
- public boolean
- check()
- {
- return callback.check();
- }
+ public void
+ ice_response()
+ {
+ test(false);
+ }
+
+ public void
+ ice_exception(Ice.LocalException ex)
+ {
+ try
+ {
+ throw ex;
+ }
+ catch(Ice.ConnectionLostException exc)
+ {
+ }
+ catch(Ice.ConnectFailedException exc)
+ {
+ }
+ catch(Ice.SocketException exc)
+ {
+ }
+ catch(Exception exc)
+ {
+ test(false);
+ }
+ callback.called();
+ }
+
+ public void
+ ice_exception(Ice.UserException ex)
+ {
+ test(false);
+ }
+
+ public boolean
+ check()
+ {
+ return callback.check();
+ }
- private Callback callback = new Callback();
+ private Callback callback = new Callback();
}
private static class AMI_Test_idempotentAbortI extends AMI_TestIntf_idempotentAbort
{
- public void
- ice_response()
- {
- test(false);
- }
-
- public void
- ice_exception(Ice.LocalException ex)
- {
- delegate.ice_exception(ex);
- }
-
- public void
- ice_exception(Ice.UserException ex)
- {
- delegate.ice_exception(ex);
- }
-
- public boolean
- check()
- {
- return delegate.check();
- }
+ public void
+ ice_response()
+ {
+ test(false);
+ }
+
+ public void
+ ice_exception(Ice.LocalException ex)
+ {
+ delegate.ice_exception(ex);
+ }
+
+ public void
+ ice_exception(Ice.UserException ex)
+ {
+ delegate.ice_exception(ex);
+ }
+
+ public boolean
+ check()
+ {
+ return delegate.check();
+ }
- private AMI_Test_abortI delegate = new AMI_Test_abortI();
+ private AMI_Test_abortI delegate = new AMI_Test_abortI();
}
public static void
@@ -226,123 +226,123 @@ public class AllTests
System.out.println("ok");
int oldPid = 0;
- boolean ami = false;
+ boolean ami = false;
for(int i = 1, j = 0; i <= ports.length; ++i, ++j)
{
- if(j > 3)
- {
- j = 0;
- ami = !ami;
- }
+ if(j > 3)
+ {
+ j = 0;
+ ami = !ami;
+ }
- if(!ami)
- {
- System.out.print("testing server #" + i + "... ");
- System.out.flush();
- int pid = obj.pid();
- test(pid != oldPid);
- System.out.println("ok");
- oldPid = pid;
- }
- else
- {
- System.out.print("testing server #" + i + " with AMI... ");
- System.out.flush();
- AMI_Test_pidI cb = new AMI_Test_pidI();
- obj.pid_async(cb);
- test(cb.check());
- int pid = cb.pid();
- test(pid != oldPid);
- System.out.println("ok");
- oldPid = pid;
- }
+ if(!ami)
+ {
+ System.out.print("testing server #" + i + "... ");
+ System.out.flush();
+ int pid = obj.pid();
+ test(pid != oldPid);
+ System.out.println("ok");
+ oldPid = pid;
+ }
+ else
+ {
+ System.out.print("testing server #" + i + " with AMI... ");
+ System.out.flush();
+ AMI_Test_pidI cb = new AMI_Test_pidI();
+ obj.pid_async(cb);
+ test(cb.check());
+ int pid = cb.pid();
+ test(pid != oldPid);
+ System.out.println("ok");
+ oldPid = pid;
+ }
if(j == 0)
{
- if(!ami)
- {
- System.out.print("shutting down server #" + i + "... ");
- System.out.flush();
- obj.shutdown();
- System.out.println("ok");
- }
- else
- {
- System.out.print("shutting down server #" + i + " with AMI... ");
- System.out.flush();
- AMI_Test_shutdownI cb = new AMI_Test_shutdownI();
- obj.shutdown_async(cb);
- test(cb.check());
- System.out.println("ok");
- }
+ if(!ami)
+ {
+ System.out.print("shutting down server #" + i + "... ");
+ System.out.flush();
+ obj.shutdown();
+ System.out.println("ok");
+ }
+ else
+ {
+ System.out.print("shutting down server #" + i + " with AMI... ");
+ System.out.flush();
+ AMI_Test_shutdownI cb = new AMI_Test_shutdownI();
+ obj.shutdown_async(cb);
+ test(cb.check());
+ System.out.println("ok");
+ }
}
else if(j == 1 || i + 1 > ports.length)
{
- if(!ami)
- {
- System.out.print("aborting server #" + i + "... ");
- System.out.flush();
- try
- {
- obj.abort();
- test(false);
- }
- catch(Ice.ConnectionLostException ex)
- {
- System.out.println("ok");
- }
- catch(Ice.ConnectFailedException exc)
- {
- System.out.println("ok");
- }
- catch(Ice.SocketException ex)
- {
- System.out.println("ok");
- }
- }
- else
- {
- System.out.print("aborting server #" + i + " with AMI... ");
- System.out.flush();
- AMI_Test_abortI cb = new AMI_Test_abortI();
- obj.abort_async(cb);
- test(cb.check());
- System.out.println("ok");
- }
+ if(!ami)
+ {
+ System.out.print("aborting server #" + i + "... ");
+ System.out.flush();
+ try
+ {
+ obj.abort();
+ test(false);
+ }
+ catch(Ice.ConnectionLostException ex)
+ {
+ System.out.println("ok");
+ }
+ catch(Ice.ConnectFailedException exc)
+ {
+ System.out.println("ok");
+ }
+ catch(Ice.SocketException ex)
+ {
+ System.out.println("ok");
+ }
+ }
+ else
+ {
+ System.out.print("aborting server #" + i + " with AMI... ");
+ System.out.flush();
+ AMI_Test_abortI cb = new AMI_Test_abortI();
+ obj.abort_async(cb);
+ test(cb.check());
+ System.out.println("ok");
+ }
}
else if(j == 2 || j == 3)
{
- if(!ami)
- {
- System.out.print("aborting server #" + i + " and #" + (i + 1) + " with idempotent call... ");
- System.out.flush();
- try
- {
- obj.idempotentAbort();
- test(false);
- }
- catch(Ice.ConnectionLostException ex)
- {
- System.out.println("ok");
- }
- catch(Ice.ConnectFailedException exc)
- {
- System.out.println("ok");
- }
- catch(Ice.SocketException ex)
- {
- System.out.println("ok");
- }
- }
- else
- {
- System.out.print("aborting server #" + i + " and #" + (i + 1) + " with idempotent AMI call... ");
- System.out.flush();
- AMI_Test_idempotentAbortI cb = new AMI_Test_idempotentAbortI();
- obj.idempotentAbort_async(cb);
- test(cb.check());
- System.out.println("ok");
- }
+ if(!ami)
+ {
+ System.out.print("aborting server #" + i + " and #" + (i + 1) + " with idempotent call... ");
+ System.out.flush();
+ try
+ {
+ obj.idempotentAbort();
+ test(false);
+ }
+ catch(Ice.ConnectionLostException ex)
+ {
+ System.out.println("ok");
+ }
+ catch(Ice.ConnectFailedException exc)
+ {
+ System.out.println("ok");
+ }
+ catch(Ice.SocketException ex)
+ {
+ System.out.println("ok");
+ }
+ }
+ else
+ {
+ System.out.print("aborting server #" + i + " and #" + (i + 1) + " with idempotent AMI call... ");
+ System.out.flush();
+ AMI_Test_idempotentAbortI cb = new AMI_Test_idempotentAbortI();
+ obj.idempotentAbort_async(cb);
+ test(cb.check());
+ System.out.println("ok");
+ }
++i;
}