summaryrefslogtreecommitdiff
path: root/cpp/src/Glacier2/RequestQueue.cpp
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2004-09-13 18:19:41 +0000
committerMarc Laukien <marc@zeroc.com>2004-09-13 18:19:41 +0000
commite012bfcd0c32c6fd185890aedb5f17e69da8870e (patch)
tree28dd15cd1a91ee0a244078487ed0d7b799364504 /cpp/src/Glacier2/RequestQueue.cpp
parentadding AMI tests (diff)
downloadice-e012bfcd0c32c6fd185890aedb5f17e69da8870e.tar.bz2
ice-e012bfcd0c32c6fd185890aedb5f17e69da8870e.tar.xz
ice-e012bfcd0c32c6fd185890aedb5f17e69da8870e.zip
Connection.ice
Diffstat (limited to 'cpp/src/Glacier2/RequestQueue.cpp')
-rw-r--r--cpp/src/Glacier2/RequestQueue.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/Glacier2/RequestQueue.cpp b/cpp/src/Glacier2/RequestQueue.cpp
index 18e72840029..50d7402c83a 100644
--- a/cpp/src/Glacier2/RequestQueue.cpp
+++ b/cpp/src/Glacier2/RequestQueue.cpp
@@ -15,7 +15,7 @@ using namespace Ice;
using namespace Glacier2;
Glacier2::Request::Request(const ObjectPrx& proxy, const vector<Byte>& inParams, const Current& current,
- const AMI_Object_ice_invokePtr& amiCB) :
+ const AMI_Object_ice_invokePtr& amiCB) :
_proxy(proxy),
_inParams(inParams),
_current(current),
@@ -187,7 +187,7 @@ Glacier2::RequestQueue::run()
while(true)
{
vector<RequestPtr> requests;
- set<TransportInfoPtr> flushSet;
+ set<ConnectionPtr> flushSet;
{
IceUtil::Monitor<IceUtil::Mutex>::Lock lock(*this);
@@ -222,7 +222,7 @@ Glacier2::RequestQueue::run()
if(proxy->ice_batchOneway() || proxy->ice_batchDatagram())
{
- flushSet.insert(proxy->ice_getTransportInfo());
+ flushSet.insert(proxy->ice_getConnection());
}
if(_traceLevelRequest >= 1)
@@ -233,7 +233,7 @@ Glacier2::RequestQueue::run()
(*p)->invoke(_forwardContext);
}
- for_each(flushSet.begin(), flushSet.end(), Ice::voidMemFun(&TransportInfo::flushBatchRequests));
+ for_each(flushSet.begin(), flushSet.end(), Ice::voidMemFun(&Connection::flushBatchRequests));
}
catch(const Ice::Exception& ex)
{