diff options
Diffstat (limited to 'java')
| -rw-r--r-- | java/demo/Ice/session/Client.java | 21 | ||||
| -rw-r--r-- | java/demo/Ice/session/SessionFactoryI.java | 2 |
2 files changed, 10 insertions, 13 deletions
diff --git a/java/demo/Ice/session/Client.java b/java/demo/Ice/session/Client.java index c9bd29a7a36..2a062181811 100644 --- a/java/demo/Ice/session/Client.java +++ b/java/demo/Ice/session/Client.java @@ -32,18 +32,17 @@ public class Client catch(InterruptedException e) { } - if(_terminated) + if(!_terminated) { - break; - } - try - { - _session.refresh(); - } - catch(Ice.LocalException ex) - { - _logger.warning("SessionRefreshThread: " + ex); - break; + try + { + _session.refresh(); + } + catch(Ice.LocalException ex) + { + _logger.warning("SessionRefreshThread: " + ex); + _terminated = true; + } } } } diff --git a/java/demo/Ice/session/SessionFactoryI.java b/java/demo/Ice/session/SessionFactoryI.java index 5b0a76eb47c..c8b0bf12c69 100644 --- a/java/demo/Ice/session/SessionFactoryI.java +++ b/java/demo/Ice/session/SessionFactoryI.java @@ -33,7 +33,6 @@ class SessionFactoryI extends _SessionFactoryDisp } if(!_terminated) { - assert _factory != null; _factory.reap(); } } @@ -56,7 +55,6 @@ class SessionFactoryI extends _SessionFactoryDisp { _adapter = adapter; _reapThread = new ReapThread(this, _timeout); - _reapThread = new ReapThread(this, _timeout); _reapThread.start(); } |