From 776377bb21ee1cfe0bcdbc000f7c6fa0be227226 Mon Sep 17 00:00:00 2001
From: Matthias Schiffer <matthias@gamezock.de>
Date: Wed, 20 May 2009 01:08:16 +0200
Subject: Netzwerk-Code auf boost::asio umgestellt

---
 src/Net/ThreadManager.cpp | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

(limited to 'src/Net/ThreadManager.cpp')

diff --git a/src/Net/ThreadManager.cpp b/src/Net/ThreadManager.cpp
index 71a754e..0fb0716 100644
--- a/src/Net/ThreadManager.cpp
+++ b/src/Net/ThreadManager.cpp
@@ -18,11 +18,13 @@
  */
 
 #include "ThreadManager.h"
-#include "FdManager.h"
+#include "Connection.h"
 
 #include <Common/Logger.h>
 #include <Common/LogManager.h>
 
+#include <boost/bind.hpp>
+
 #include <fcntl.h>
 
 namespace Mad {
@@ -97,10 +99,12 @@ void ThreadManager::doInit() {
 
   threadLock.lock();
 
+  ioWorker.reset(new boost::asio::io_service::work(Connection::ioService));
+
   mainThreadId = boost::this_thread::get_id();
-  workerThread = new boost::thread(std::mem_fun(&ThreadManager::workerFunc), this);
-  loggerThread = new boost::thread(std::mem_fun(&Common::LogManager::loggerThread), Common::LogManager::get());
-  ioThread = new boost::thread(std::mem_fun(&FdManager::ioThread), FdManager::get());
+  workerThread = new boost::thread(&ThreadManager::workerFunc, this);
+  loggerThread = new boost::thread(&Common::LogManager::loggerThread, Common::LogManager::get());
+  ioThread = new boost::thread((std::size_t(boost::asio::io_service::*)())&boost::asio::io_service::run, &Connection::ioService);
 
   threadLock.unlock();
 }
@@ -128,7 +132,7 @@ void ThreadManager::doDeinit() {
   threads.join_all();
 
   // IO thread is next
-  FdManager::get()->stopIOThread();
+  ioWorker.reset();
   ioThread->join();
   delete ioThread;
 
-- 
cgit v1.2.3