summaryrefslogtreecommitdiff
path: root/java/demo
diff options
context:
space:
mode:
authorMatthew Newhook <matthew@zeroc.com>2005-04-18 08:05:14 +0000
committerMatthew Newhook <matthew@zeroc.com>2005-04-18 08:05:14 +0000
commita74ededfac14f35a852bda1776e2833d142bcea7 (patch)
tree94410515765510a600ce9a29b42687ca7bf546d7 /java/demo
parentFixed a typo. (diff)
downloadice-a74ededfac14f35a852bda1776e2833d142bcea7.tar.bz2
ice-a74ededfac14f35a852bda1776e2833d142bcea7.tar.xz
ice-a74ededfac14f35a852bda1776e2833d142bcea7.zip
fix
Diffstat (limited to 'java/demo')
-rw-r--r--java/demo/Ice/session/Client.java21
-rw-r--r--java/demo/Ice/session/SessionFactoryI.java2
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();
}