1 files changed, 18 insertions, 0 deletions
diff --git a/cpp/src/Ice/Instance.cpp b/cpp/src/Ice/Instance.cpp
index e2ad598d146..52ba8ea430d 100644
--- a/cpp/src/Ice/Instance.cpp
+++ b/cpp/src/Ice/Instance.cpp
@@ -360,6 +360,24 @@ IceInternal::Instance::messageSizeMax() const
     return _messageSizeMax;
 }
 
+void
+IceInternal::Instance::flushBatchRequests()
+{
+    OutgoingConnectionFactoryPtr factory;
+    std::map<std::string, ::Ice::ObjectAdapterIPtr> adapters;
+    {
+	IceUtil::RecMutex::Lock sync(*this);
+
+	factory = _outgoingConnectionFactory;
+	adapters = _objectAdapterFactory->_adapters;
+    }
+    factory->flushBatchRequests();
+    for(std::map<std::string, ::Ice::ObjectAdapterIPtr>::const_iterator p = adapters.begin(); p != adapters.end(); ++p)
+    {
+	p->second->flushBatchRequests();
+    }
+}
+
 IceInternal::Instance::Instance(const CommunicatorPtr& communicator, int& argc, char* argv[],
                                 const PropertiesPtr& properties) :
     _destroyed(false),