summaryrefslogtreecommitdiff
path: root/cpp/src/IceGrid/ReapThread.cpp
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2006-04-19 15:46:52 +0000
committerBenoit Foucher <benoit@zeroc.com>2006-04-19 15:46:52 +0000
commit86996779eead5db4d8ee3c0aea681344e4367a24 (patch)
tree05d010c0a6ff43254778dba3768d90b3fe3343ec /cpp/src/IceGrid/ReapThread.cpp
parentWindows fixes (diff)
downloadice-86996779eead5db4d8ee3c0aea681344e4367a24.tar.bz2
ice-86996779eead5db4d8ee3c0aea681344e4367a24.tar.xz
ice-86996779eead5db4d8ee3c0aea681344e4367a24.zip
- Removed support for named property sets in templates.
- Added first (and incomplete) cut of client and admin session interfaces.
Diffstat (limited to 'cpp/src/IceGrid/ReapThread.cpp')
-rw-r--r--cpp/src/IceGrid/ReapThread.cpp17
1 files changed, 8 insertions, 9 deletions
diff --git a/cpp/src/IceGrid/ReapThread.cpp b/cpp/src/IceGrid/ReapThread.cpp
index d3991103b37..1a41eba89c4 100644
--- a/cpp/src/IceGrid/ReapThread.cpp
+++ b/cpp/src/IceGrid/ReapThread.cpp
@@ -8,7 +8,6 @@
// **********************************************************************
#include <Ice/Ice.h>
-#include <Glacier2/Session.h>
#include <IceGrid/ReapThread.h>
using namespace std;
@@ -27,16 +26,16 @@ ReapThread::run()
while(!_terminated)
{
- list<pair<SessionIPtr, Glacier2::SessionPrx> >::iterator p = _sessions.begin();
+ list<ReapablePtr>::iterator p = _sessions.begin();
while(p != _sessions.end())
{
try
{
- if((IceUtil::Time::now() - p->first->timestamp()) > _timeout)
+ if((IceUtil::Time::now() - (*p)->timestamp()) > _timeout)
{
try
{
- p->second->destroy();
+ (*p)->destroy();
}
catch(const Ice::LocalException&)
{
@@ -66,13 +65,13 @@ ReapThread::terminate()
_terminated = true;
notify();
- for(list<pair<SessionIPtr, Glacier2::SessionPrx> >::const_iterator p = _sessions.begin(); p != _sessions.end(); ++p)
+ for(list<ReapablePtr>::const_iterator p = _sessions.begin(); p != _sessions.end(); ++p)
{
try
{
- p->second->destroy();
+ (*p)->destroy();
}
- catch(const Ice::Exception&)
+ catch(const Ice::LocalException&)
{
// Ignore.
}
@@ -82,9 +81,9 @@ ReapThread::terminate()
}
void
-ReapThread::add(const Glacier2::SessionPrx& proxy, const SessionIPtr& session)
+ReapThread::add(const ReapablePtr& reapable)
{
Lock sync(*this);
- _sessions.push_back(make_pair(session, proxy));
+ _sessions.push_back(reapable);
}