diff options
| author | Matthew Newhook <matthew@zeroc.com> | 2008-08-26 15:32:33 -0230 |
|---|---|---|
| committer | Matthew Newhook <matthew@zeroc.com> | 2008-08-26 15:32:33 -0230 |
| commit | b4e1bc6a6b1f1ad360db6f61bc5f705e02ba8bd0 (patch) | |
| tree | 6a69a69087f25c16ac37d65aaab27f05841a02aa /java/demo/Database/library/RunParser.java | |
| parent | Merge branch 'R3_3_branch' (diff) | |
| parent | Minor cleanup, added session timeout. (diff) | |
| download | ice-b4e1bc6a6b1f1ad360db6f61bc5f705e02ba8bd0.tar.bz2 ice-b4e1bc6a6b1f1ad360db6f61bc5f705e02ba8bd0.tar.xz ice-b4e1bc6a6b1f1ad360db6f61bc5f705e02ba8bd0.zip | |
Merge branch 'jdbc'
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(); |