1 files changed, 5 insertions, 12 deletions
diff --git a/src/mad.cpp b/src/mad.cpp
index d6e0ae3..6ca18ae 100644
--- a/src/mad.cpp
+++ b/src/mad.cpp
@@ -18,6 +18,7 @@
  */
 
 #include "Net/ClientConnection.h"
+#include "Net/FdManager.h"
 #include "Net/IPAddress.h"
 #include "Common/Backends/SystemBackendPosix.h"
 #include "Common/Backends/SystemBackendProc.h"
@@ -60,12 +61,8 @@ int main() {
   try {
     connection->connect(Net::IPAddress("127.0.0.1"), true);
 
-    while(connection->isConnecting()) {
-      struct pollfd fd = connection->getPollfd();
-
-      if(poll(&fd, 1, 10000) > 0)
-        connection->sendReceive(fd.revents);
-    }
+    while(connection->isConnecting())
+      Net::FdManager::getFdManager()->run();
 
     Common::RequestManager::getRequestManager()->registerConnection(connection);
 
@@ -78,12 +75,8 @@ int main() {
     //Common::RequestManager::getRequestManager()->sendRequest(connection, std::auto_ptr<Common::RequestBase>(new Daemon::Requests::IdentifyRequest(hostname, sigc::ptr_fun(requestFinished))));
     Common::RequestManager::getRequestManager()->sendRequest(connection, std::auto_ptr<Common::RequestBase>(new Daemon::Requests::IdentifyRequest("test", sigc::ptr_fun(requestFinished))));
 
-    while(connection->isConnected()) {
-      struct pollfd fd = connection->getPollfd();
-
-      if(poll(&fd, 1, 10000) > 0)
-        connection->sendReceive(fd.revents);
-    }
+    while(connection->isConnected())
+      Net::FdManager::getFdManager()->run();
 
     Common::Logger::unregisterLogger(&networkLogger);