diff options
Diffstat (limited to 'java/test/Ice/faultTolerance/AllTests.java')
-rw-r--r-- | java/test/Ice/faultTolerance/AllTests.java | 524 |
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; } |