From 454cfccd51e2b9ad453fe79df04360fcd6eeb742 Mon Sep 17 00:00:00 2001
From: Matthias Schiffer <matthias@gamezock.de>
Date: Sat, 6 Jun 2009 15:01:07 +0200
Subject: User-RequestHandler zur UserRequestHandlerGroup zusammengefasst

---
 src/Common/RequestManager.cpp | 25 ++++++++++++++-----------
 1 file changed, 14 insertions(+), 11 deletions(-)

(limited to 'src/Common/RequestManager.cpp')

diff --git a/src/Common/RequestManager.cpp b/src/Common/RequestManager.cpp
index 3785b3f..b443292 100644
--- a/src/Common/RequestManager.cpp
+++ b/src/Common/RequestManager.cpp
@@ -108,21 +108,24 @@ void RequestManager::receiveHandler(Connection *connection, boost::shared_ptr<co
     return;
   }
 
-  std::map<std::string, boost::shared_ptr<RequestHandlerFactory> >::iterator factoryIt = requestHandlerFactories.find(packet->getType());
-  if(factoryIt != requestHandlerFactories.end()) {
-    {
-      boost::upgrade_to_unique_lock<boost::shared_mutex> upgradeLock(lock);
+  std::map<std::string, boost::shared_ptr<RequestHandlerGroup> >::iterator rgh = requestHandlerGroups.find(packet->getType());
+  if(rgh != requestHandlerGroups.end()) {
+    request = rgh->second->createRequestHandler(packet->getType());
 
-      request = factoryIt->second->createRequestHandler();
-      requestMap.addRequest(connection, requestId, request);
-      request->connectSignalFinished(boost::bind(&RequestManager::handleRequestFinished, this, connection, requestId));
+    if(request) {
+      {
+        boost::upgrade_to_unique_lock<boost::shared_mutex> upgradeLock(lock);
 
-    }
+        requestMap.addRequest(connection, requestId, request);
+        request->connectSignalFinished(boost::bind(&RequestManager::handleRequestFinished, this, connection, requestId));
 
-    lock.unlock();
-    Net::ThreadManager::get()->pushWork(boost::bind(&RequestHandler::handlePacket, request, packet));
+      }
 
-    return;
+      lock.unlock();
+      Net::ThreadManager::get()->pushWork(boost::bind(&RequestHandler::handlePacket, request, packet));
+
+      return;
+    }
   }
 
   lock.unlock();
-- 
cgit v1.2.3