diff options
Diffstat (limited to 'java/demo/IceGrid/sessionActivation/Client.java')
| -rw-r--r-- | java/demo/IceGrid/sessionActivation/Client.java | 336 |
1 files changed, 168 insertions, 168 deletions
diff --git a/java/demo/IceGrid/sessionActivation/Client.java b/java/demo/IceGrid/sessionActivation/Client.java index b77fbd9fa13..f16c19c13a0 100644 --- a/java/demo/IceGrid/sessionActivation/Client.java +++ b/java/demo/IceGrid/sessionActivation/Client.java @@ -13,33 +13,33 @@ public class Client extends Ice.Application { class ShutdownHook extends Thread { - public void - run() - { - cleanup(); - try - { - communicator().destroy(); - } - catch(Ice.LocalException ex) - { - ex.printStackTrace(); - } - } + public void + run() + { + cleanup(); + try + { + communicator().destroy(); + } + catch(Ice.LocalException ex) + { + ex.printStackTrace(); + } + } } static private class SessionKeepAliveThread extends Thread { SessionKeepAliveThread(IceGrid.SessionPrx 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 @@ -51,29 +51,29 @@ public class Client extends Ice.Application } 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.SessionPrx _session; - final private long _timeout; - private boolean _terminated; + final private IceGrid.SessionPrx _session; + final private long _timeout; + private boolean _terminated; } private void @@ -89,129 +89,129 @@ public class Client extends Ice.Application public int run(String[] args) { - // - // Since this is an interactive demo we want to clear the - // Application installed interrupt callback and install our - // own shutdown hook. - // - setInterruptHook(new ShutdownHook()); + // + // Since this is an interactive demo we want to clear the + // Application installed interrupt callback and install our + // own shutdown hook. + // + setInterruptHook(new ShutdownHook()); - int status = 0; + int status = 0; IceGrid.RegistryPrx registry = - IceGrid.RegistryPrxHelper.checkedCast(communicator().stringToProxy("DemoIceGrid/Registry")); - if(registry == null) - { + IceGrid.RegistryPrxHelper.checkedCast(communicator().stringToProxy("DemoIceGrid/Registry")); + if(registry == null) + { System.err.println("could not contact registry"); - return 1; - } + return 1; + } java.io.BufferedReader in = new java.io.BufferedReader(new java.io.InputStreamReader(System.in)); - while(true) - { - System.out.println("This demo accepts any user-id / password combination."); + while(true) + { + System.out.println("This demo accepts any user-id / password combination."); - try - { - String id; - System.out.print("user id: "); - System.out.flush(); - id = in.readLine(); - - String pw; - System.out.print("password: "); - System.out.flush(); - pw = in.readLine(); - - try - { - synchronized(this) - { - _session = registry.createSession(id, pw); - } - break; - } - catch(IceGrid.PermissionDeniedException ex) - { - System.out.println("permission denied:\n" + ex.reason); - } - } + try + { + String id; + System.out.print("user id: "); + System.out.flush(); + id = in.readLine(); + + String pw; + System.out.print("password: "); + System.out.flush(); + pw = in.readLine(); + + try + { + synchronized(this) + { + _session = registry.createSession(id, pw); + } + break; + } + catch(IceGrid.PermissionDeniedException ex) + { + System.out.println("permission denied:\n" + ex.reason); + } + } catch(java.io.IOException ex) { ex.printStackTrace(); } - } + } - synchronized(this) - { - _keepAlive = new SessionKeepAliveThread(_session, registry.getSessionTimeout() / 2); - _keepAlive.start(); - } + synchronized(this) + { + _keepAlive = new SessionKeepAliveThread(_session, registry.getSessionTimeout() / 2); + _keepAlive.start(); + } - try - { - HelloPrx hello = HelloPrxHelper.checkedCast( - _session.allocateObjectById(communicator().stringToIdentity("hello"))); + try + { + HelloPrx hello = HelloPrxHelper.checkedCast( + _session.allocateObjectById(communicator().stringToIdentity("hello"))); - menu(); - - String line = null; - do - { - try - { - System.out.print("==> "); - System.out.flush(); - line = in.readLine(); - if(line == null) - { - break; - } - if(line.equals("t")) - { - hello.sayHello(); - } - else if(line.equals("x")) - { - // Nothing to do - } - else if(line.equals("?")) - { - menu(); - } - else - { - System.out.println("unknown command `" + line + "'"); - menu(); - } - } - catch(java.io.IOException ex) - { - ex.printStackTrace(); - } - catch(Ice.LocalException ex) - { - ex.printStackTrace(); - } - } - while(!line.equals("x")); - } - catch(IceGrid.AllocationException ex) - { - System.err.println("could not allocate object: " + ex.reason); - status = 1; - } - catch(IceGrid.ObjectNotRegisteredException ex) - { - System.err.println("object not registered with registry"); - status = 1; - } - catch(Exception ex) - { - System.err.println("expected exception: " + ex); - status = 1; - } + menu(); + + String line = null; + do + { + try + { + System.out.print("==> "); + System.out.flush(); + line = in.readLine(); + if(line == null) + { + break; + } + if(line.equals("t")) + { + hello.sayHello(); + } + else if(line.equals("x")) + { + // Nothing to do + } + else if(line.equals("?")) + { + menu(); + } + else + { + System.out.println("unknown command `" + line + "'"); + menu(); + } + } + catch(java.io.IOException ex) + { + ex.printStackTrace(); + } + catch(Ice.LocalException ex) + { + ex.printStackTrace(); + } + } + while(!line.equals("x")); + } + catch(IceGrid.AllocationException ex) + { + System.err.println("could not allocate object: " + ex.reason); + status = 1; + } + catch(IceGrid.ObjectNotRegisteredException ex) + { + System.err.println("object not registered with registry"); + status = 1; + } + catch(Exception ex) + { + System.err.println("expected exception: " + ex); + status = 1; + } - cleanup(); + cleanup(); return status; } @@ -219,36 +219,36 @@ public class Client extends Ice.Application synchronized void cleanup() { - // - // Destroy the keepAlive thread and the sesion object otherwise - // the session will be kept allocated until the timeout occurs. - // Destroying the session will release all allocated objects. - // - if(_keepAlive != null) - { - _keepAlive.terminate(); - try - { - _keepAlive.join(); - } - catch(InterruptedException e) - { - } - _keepAlive = null; - } - if(_session != null) - { - _session.destroy(); - _session = null; - } + // + // Destroy the keepAlive thread and the sesion object otherwise + // the session will be kept allocated until the timeout occurs. + // Destroying the session will release all allocated objects. + // + if(_keepAlive != null) + { + _keepAlive.terminate(); + try + { + _keepAlive.join(); + } + catch(InterruptedException e) + { + } + _keepAlive = null; + } + if(_session != null) + { + _session.destroy(); + _session = null; + } } public static void main(String[] args) { - Client app = new Client(); - int status = app.main("Client", args, "config.client"); - System.exit(status); + Client app = new Client(); + int status = app.main("Client", args, "config.client"); + System.exit(status); } SessionKeepAliveThread _keepAlive; |