diff options
author | Matthew Newhook <matthew@zeroc.com> | 2015-03-18 12:58:16 -0230 |
---|---|---|
committer | Matthew Newhook <matthew@zeroc.com> | 2015-03-18 12:58:16 -0230 |
commit | 9b7668c7c92cf9cb311fe444cdddb489cd2a219d (patch) | |
tree | 5016567c58c81f5654e9d01935e199c6bf4761d2 /java/demo/Database/library/ReapTask.java | |
parent | VS add-in & build updates: (diff) | |
download | ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.tar.bz2 ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.tar.xz ice-9b7668c7c92cf9cb311fe444cdddb489cd2a219d.zip |
Removed demos.
Moved demoscript to distribution.
Diffstat (limited to 'java/demo/Database/library/ReapTask.java')
-rw-r--r-- | java/demo/Database/library/ReapTask.java | 109 |
1 files changed, 0 insertions, 109 deletions
diff --git a/java/demo/Database/library/ReapTask.java b/java/demo/Database/library/ReapTask.java deleted file mode 100644 index ed15614eb9d..00000000000 --- a/java/demo/Database/library/ReapTask.java +++ /dev/null @@ -1,109 +0,0 @@ -// ********************************************************************** -// -// Copyright (c) 2003-2015 ZeroC, Inc. All rights reserved. -// -// This copy of Ice is licensed to you under the terms described in the -// ICE_LICENSE file included in this distribution. -// -// ********************************************************************** - -import Demo.*; - -class ReapTask implements Runnable -{ - static class SessionProxyPair - { - SessionProxyPair(Demo.SessionPrx p, SessionI s) - { - glacier2proxy = null; - proxy = p; - session = s; - } - - SessionProxyPair(Glacier2.SessionPrx p, SessionI s) - { - glacier2proxy = p; - proxy = null; - session = s; - } - - Glacier2.SessionPrx glacier2proxy; - Demo.SessionPrx proxy; - SessionI session; - } - - ReapTask(Ice.Logger logger, long timeout) - { - _logger = logger; - _timeout = timeout; - } - - @Override - synchronized public void - run() - { - java.util.Iterator<SessionProxyPair> p = _sessions.iterator(); - while(p.hasNext()) - { - SessionProxyPair s = p.next(); - try - { - // - // Session destruction may take time in a - // real-world example. Therefore the current time - // is computed for each iteration. - // - if((System.currentTimeMillis() - s.session.timestamp()) > _timeout * 1000) - { - _logger.trace("ReapTask", "The session " + - s.proxy.ice_getCommunicator().identityToString(s.proxy.ice_getIdentity()) + - " has timed out."); - if(s.proxy != null) - { - s.proxy.destroy(); - } - else - { - s.glacier2proxy.destroy(); - } - p.remove(); - } - } - catch(Ice.ObjectNotExistException e) - { - p.remove(); - } - } - } - - synchronized public void - terminate() - { - // Destroy each of the sessions, releasing any resources they - // may hold. This calls directly on the session, not via the - // proxy since terminate() is called after the communicator is - // shutdown, which means calls on collocated objects are not - // permitted. - for(SessionProxyPair p : _sessions) - { - p.session.shutdown(); - } - _sessions.clear(); - } - - synchronized public void - add(SessionPrx proxy, SessionI session) - { - _sessions.add(new SessionProxyPair(proxy, session)); - } - - synchronized public void - add(Glacier2.SessionPrx proxy, SessionI session) - { - _sessions.add(new SessionProxyPair(proxy, session)); - } - - private final long _timeout; - private Ice.Logger _logger; - private java.util.List<SessionProxyPair> _sessions = new java.util.LinkedList<SessionProxyPair>(); -} |