Merge branch 'pierre-luc'

sflphone-common/libs/dbus-c++/include/dbus-c++/eventloop.h

@@ -30,6 +30,7 @@
 
 #include "api.h"
 #include "util.h"
+#include "error.h"
 
 namespace DBus {
 
@@ -149,6 +150,8 @@ public:
 
 	virtual void dispatch();
 
+    virtual void terminate();
+    
 private:
 
 	DefaultMutex _mutex_t;
@@ -157,6 +160,8 @@ private:
 	DefaultMutex _mutex_w;
 	DefaultWatches _watches;
 	
+	int _terminateFd[2];
+
 friend class DefaultTimeout;
 friend class DefaultWatch;
 };

sflphone-common/libs/dbus-c++/src/eventloop-integration.cpp

@@ -86,6 +86,7 @@ void BusDispatcher::enter()
 void BusDispatcher::leave()
 {
     _running = false;
+    terminate();
 }
 
 void BusDispatcher::do_iteration()

sflphone-common/libs/dbus-c++/src/eventloop.cpp

@@ -30,6 +30,8 @@
 
 #include <sys/poll.h>
 #include <sys/time.h>
+#include <unistd.h> 
+#include <cstdio>
 
 #include <dbus/dbus.h>
 
@@ -97,6 +99,9 @@ void DefaultMutex::unlock()
 
 DefaultMainLoop::DefaultMainLoop()
 {
+    if(pipe(_terminateFd) < 0) {
+        throw ErrorFailed ("unable to create unamed pipe");
+    }  
 }
 
 DefaultMainLoop::~DefaultMainLoop()
@@ -129,14 +134,22 @@ DefaultMainLoop::~DefaultMainLoop()
         ti = tmp;
     }
 
+    close(_terminateFd[0]);
+    close(_terminateFd[1]);
+    
     _mutex_t.unlock();
 }
 
+void DefaultMainLoop::terminate() 
+{
+    write(_terminateFd[1], " ", 1);
+}
+
 void DefaultMainLoop::dispatch()
 {    
     _mutex_w.lock();
 
-    int nfd = _watches.size();
+    int nfd = _watches.size() + 1;
     
     pollfd fds[nfd];
 
@@ -152,6 +165,10 @@ void DefaultMainLoop::dispatch()
         }
     }
 
+    fds[nfd].fd = _terminateFd[0];
+    fds[nfd].events = POLLIN;
+    fds[nfd].revents = 0;
+        
     _mutex_w.unlock();
 
     int wait_min = 10000;
@@ -167,7 +184,7 @@ void DefaultMainLoop::dispatch()
 
     _mutex_t.unlock();
 
-    poll (fds, nfd, wait_min);
+    poll (fds, nfd+1, wait_min);
 
     timeval now;
     gettimeofday (&now, NULL);