diff options
Diffstat (limited to 'java/src/IceGridGUI/Coordinator.java')
-rw-r--r-- | java/src/IceGridGUI/Coordinator.java | 52 |
1 files changed, 29 insertions, 23 deletions
diff --git a/java/src/IceGridGUI/Coordinator.java b/java/src/IceGridGUI/Coordinator.java index 208b193b1a2..911b05a388d 100644 --- a/java/src/IceGridGUI/Coordinator.java +++ b/java/src/IceGridGUI/Coordinator.java @@ -1268,8 +1268,7 @@ public class Coordinator login(final SessionKeeper sessionKeeper, final SessionKeeper.ConnectionInfo info, final JDialog parent, - final Cursor oldCursor, - Ice.LongHolder keepAlivePeriodHolder) + final Cursor oldCursor) { // @@ -1709,14 +1708,14 @@ public class Coordinator return _session; } - synchronized public void setKeepAlivePeriod(long keepAlivePeriod) + synchronized public void setSessionTimeout(long sessionTimeout) { - _keepAlivePeriod = keepAlivePeriod; + _sessionTimeout = sessionTimeout; } - synchronized public long getKeepAlivePeriod() + synchronized public void setACMTimeout(int acmTimeout) { - return _keepAlivePeriod; + _acmTimeout = acmTimeout; } synchronized public void loginSuccess() @@ -1731,7 +1730,7 @@ public class Coordinator _newApplicationWithDefaultTemplates.setEnabled(true); _acquireExclusiveWriteAccess.setEnabled(true); _mainPane.setSelectedComponent(_liveDeploymentPane); - _sessionKeeper.loginSuccess(parent, oldCursor, _keepAlivePeriod, _session, info); + _sessionKeeper.loginSuccess(parent, oldCursor, _sessionTimeout, _acmTimeout, _session, info); } synchronized public void loginFailed() @@ -1753,7 +1752,8 @@ public class Coordinator } private AdminSessionPrx _session; - private long _keepAlivePeriod; + private long _sessionTimeout = 0; + private int _acmTimeout = 0; private boolean _failed = false; } @@ -1859,7 +1859,14 @@ public class Coordinator } } cb.setSession(AdminSessionPrxHelper.uncheckedCast(s)); - cb.setKeepAlivePeriod(router.getSessionTimeout() * 1000 / 2); + cb.setSessionTimeout(router.getSessionTimeout()); + try + { + cb.setACMTimeout(router.getACMTimeout()); + } + catch(Ice.OperationNotExistException ex) + { + } SwingUtilities.invokeLater(new Runnable() { public void run() @@ -2113,7 +2120,14 @@ public class Coordinator info.getPassword() != null ? new String(info.getPassword()) : "")); assert cb.getSession() != null; } - cb.setKeepAlivePeriod(cb.getRegistry().getSessionTimeout() * 1000 / 2); + cb.setSessionTimeout(cb.getRegistry().getSessionTimeout()); + try + { + cb.setACMTimeout(cb.getRegistry().getACMTimeout()); + } + catch(Ice.OperationNotExistException ex) + { + } } catch(final IceGrid.PermissionDeniedException e) { @@ -2191,7 +2205,7 @@ public class Coordinator } } } - }while(cb.getSession() == null); + } while(cb.getSession() == null); SwingUtilities.invokeLater(new Runnable() { @@ -2206,20 +2220,19 @@ public class Coordinator } } - void destroySession(AdminSessionPrx session) + void destroySession(AdminSessionPrx session, boolean routed) { _liveDeploymentRoot.closeAllShowLogDialogs(); - Ice.RouterPrx router = _communicator.getDefaultRouter(); - try { - if(router == null) + if(!routed) { session.destroy(); } else { + Ice.RouterPrx router = _communicator.getDefaultRouter(); Glacier2.RouterPrx gr = Glacier2.RouterPrxHelper.uncheckedCast(router); Glacier2.Callback_Router_destroySession cb = new Glacier2.Callback_Router_destroySession() @@ -2242,7 +2255,6 @@ public class Coordinator } catch(Ice.LocalException e) { - // Ignored } } @@ -2519,11 +2531,6 @@ public class Coordinator properties.setProperty("Ice.Override.ConnectTimeout", "5000"); // - // For Glacier - // - properties.setProperty("Ice.ACM.Client", "0"); - - // // Disable retries // properties.setProperty("Ice.RetryIntervals", "-1"); @@ -3360,8 +3367,7 @@ public class Coordinator } catch(Ice.LocalException e) { - System.err.println("_communicator.destroy() raised " - + e.toString()); + System.err.println("_communicator.destroy() raised " + e.toString()); e.printStackTrace(); } _communicator = null; |