X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=src%2Ffilter_frontend_net.cpp;h=c0f27ef942dadbd27ac22ab4f742cb13e4724fe8;hb=102cab997609bf96205b0831eb71fc6fe9bb732a;hp=c7450c1b1f358b802cf4caaa235373550877e2d5;hpb=3597c200e3876e2c7a44e6eca0d60fab397de900;p=metaproxy-moved-to-github.git

diff --git a/src/filter_frontend_net.cpp b/src/filter_frontend_net.cpp
index c7450c1..c0f27ef 100644
--- a/src/filter_frontend_net.cpp
+++ b/src/filter_frontend_net.cpp
@@ -126,7 +126,7 @@ namespace metaproxy_1 {
         
         void failNotify();
         void timeoutNotify();
-    void connectNotify();
+        void connectNotify();
     private:
         mp::ThreadPoolSocketObserver *m_thread_pool_observer;
         const mp::Package *m_package;
@@ -436,6 +436,8 @@ void mp::filter::FrontendNet::process(Package &package) const
     }
     while (m_p->mySocketManager.processEvent() > 0)
     {
+        if (m_p->mySocketManager.getNumberOfObservers() <= 1)
+            break;
 	if (tt && tt->timeout())
 	    break;
     }