summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ObjectAdapterI.cpp
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2009-12-08 14:10:38 -0800
committerMark Spruiell <mes@zeroc.com>2009-12-08 14:10:38 -0800
commit55527152af356fda6037f836c978c2b3a2e2f045 (patch)
treed1872fe6e2d01fa15455a462df090ef94799cb5b /cpp/src/Ice/ObjectAdapterI.cpp
parentvsplugin fxcop issues (diff)
downloadice-55527152af356fda6037f836c978c2b3a2e2f045.tar.bz2
ice-55527152af356fda6037f836c978c2b3a2e2f045.tar.xz
ice-55527152af356fda6037f836c978c2b3a2e2f045.zip
- bug 3533: add async version of Connection/Communicator
flushBatchRequests operation - Slice file cleanup in C# tests - Updating C++ dependencies
Diffstat (limited to 'cpp/src/Ice/ObjectAdapterI.cpp')
-rw-r--r--cpp/src/Ice/ObjectAdapterI.cpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/cpp/src/Ice/ObjectAdapterI.cpp b/cpp/src/Ice/ObjectAdapterI.cpp
index 4c3a0f5335e..69363ee91db 100644
--- a/cpp/src/Ice/ObjectAdapterI.cpp
+++ b/cpp/src/Ice/ObjectAdapterI.cpp
@@ -764,14 +764,18 @@ Ice::ObjectAdapterI::isLocal(const ObjectPrx& proxy) const
}
void
-Ice::ObjectAdapterI::flushBatchRequests()
+Ice::ObjectAdapterI::flushAsyncBatchRequests(const CommunicatorBatchOutgoingAsyncPtr& outAsync)
{
vector<IncomingConnectionFactoryPtr> f;
{
IceUtil::Monitor<IceUtil::RecMutex>::Lock sync(*this);
f = _incomingConnectionFactories;
}
- for_each(f.begin(), f.end(), Ice::voidMemFun(&IncomingConnectionFactory::flushBatchRequests));
+
+ for(vector<IncomingConnectionFactoryPtr>::const_iterator p = f.begin(); p != f.end(); ++p)
+ {
+ (*p)->flushAsyncBatchRequests(outAsync);
+ }
}
void