From 55527152af356fda6037f836c978c2b3a2e2f045 Mon Sep 17 00:00:00 2001 From: Mark Spruiell Date: Tue, 8 Dec 2009 14:10:38 -0800 Subject: - bug 3533: add async version of Connection/Communicator flushBatchRequests operation - Slice file cleanup in C# tests - Updating C++ dependencies --- cpp/src/Ice/ObjectAdapterI.cpp | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) (limited to 'cpp/src/Ice/ObjectAdapterI.cpp') 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 f; { IceUtil::Monitor::Lock sync(*this); f = _incomingConnectionFactories; } - for_each(f.begin(), f.end(), Ice::voidMemFun(&IncomingConnectionFactory::flushBatchRequests)); + + for(vector::const_iterator p = f.begin(); p != f.end(); ++p) + { + (*p)->flushAsyncBatchRequests(outAsync); + } } void -- cgit v1.2.3