summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ObjectAdapterFactory.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/ObjectAdapterFactory.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/ObjectAdapterFactory.cpp')
-rw-r--r--cpp/src/Ice/ObjectAdapterFactory.cpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/cpp/src/Ice/ObjectAdapterFactory.cpp b/cpp/src/Ice/ObjectAdapterFactory.cpp
index a8345745fee..83161252ab5 100644
--- a/cpp/src/Ice/ObjectAdapterFactory.cpp
+++ b/cpp/src/Ice/ObjectAdapterFactory.cpp
@@ -197,7 +197,7 @@ IceInternal::ObjectAdapterFactory::removeObjectAdapter(const ObjectAdapterPtr& a
}
void
-IceInternal::ObjectAdapterFactory::flushBatchRequests() const
+IceInternal::ObjectAdapterFactory::flushAsyncBatchRequests(const CommunicatorBatchOutgoingAsyncPtr& outAsync) const
{
list<ObjectAdapterIPtr> adapters;
{
@@ -205,7 +205,11 @@ IceInternal::ObjectAdapterFactory::flushBatchRequests() const
adapters = _adapters;
}
- for_each(adapters.begin(), adapters.end(), IceUtil::voidMemFun(&ObjectAdapterI::flushBatchRequests));
+
+ for(list<ObjectAdapterIPtr>::const_iterator p = adapters.begin(); p != adapters.end(); ++p)
+ {
+ (*p)->flushAsyncBatchRequests(outAsync);
+ }
}
IceInternal::ObjectAdapterFactory::ObjectAdapterFactory(const InstancePtr& instance,