diff options
| author | Matthew Newhook <matthew@zeroc.com> | 2008-08-26 15:32:09 -0230 |
|---|---|---|
| committer | Matthew Newhook <matthew@zeroc.com> | 2008-08-26 15:32:09 -0230 |
| commit | d2d1ae0ca7d03f0b67f5c2086bff18f78331682d (patch) | |
| tree | 966bdc697be9249585c02dd9dbbb27bfc1695c6b /java/demo/Database/library/RunParser.java | |
| parent | move the query objects to the library. (diff) | |
| download | ice-d2d1ae0ca7d03f0b67f5c2086bff18f78331682d.tar.bz2 ice-d2d1ae0ca7d03f0b67f5c2086bff18f78331682d.tar.xz ice-d2d1ae0ca7d03f0b67f5c2086bff18f78331682d.zip | |
Minor cleanup, added session timeout.
Diffstat (limited to 'java/demo/Database/library/RunParser.java')
| -rw-r--r-- | java/demo/Database/library/RunParser.java | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/java/demo/Database/library/RunParser.java b/java/demo/Database/library/RunParser.java index a963dfff194..778c34063ba 100644 --- a/java/demo/Database/library/RunParser.java +++ b/java/demo/Database/library/RunParser.java @@ -77,7 +77,7 @@ class RunParser { _logger = logger; _session = session; - _timeout = timeout; + _timeout = timeout; // seconds. } synchronized public void @@ -87,7 +87,7 @@ class RunParser { try { - wait(_timeout); + wait(_timeout * 1000); } catch(InterruptedException e) { @@ -125,6 +125,7 @@ class RunParser { SessionAdapter session; Glacier2.RouterPrx router = Glacier2.RouterPrxHelper.uncheckedCast(communicator.getDefaultRouter()); + long timeout; if(router != null) { Glacier2.SessionPrx glacier2session = null; @@ -148,6 +149,7 @@ class RunParser try { glacier2session = router.createSession(id, pw); + timeout = router.getSessionTimeout() / 2; break; } catch(Glacier2.PermissionDeniedException ex) @@ -177,8 +179,9 @@ class RunParser } session = new DemoSessionAdapter(factory.create()); + timeout = factory.getSessionTimeout(); } - SessionRefreshThread refresh = new SessionRefreshThread(communicator.getLogger(), 5000, session); + SessionRefreshThread refresh = new SessionRefreshThread(communicator.getLogger(), timeout, session); refresh.start(); LibraryPrx library = session.getLibrary(); |