summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorMatthias Schiffer <matthias@gamezock.de>2008-07-08 22:31:29 +0200
committerMatthias Schiffer <matthias@gamezock.de>2008-07-08 22:31:29 +0200
commit1508969d508e41de824d1d1227be708136760cfa (patch)
tree8950d27e708ac8f0451f14c94c8cf76b0ce15877 /src
parent4cd88a87e66dbbb9be4137de04ad79c97ac5bf2c (diff)
downloadmad-1508969d508e41de824d1d1227be708136760cfa.tar
mad-1508969d508e41de824d1d1227be708136760cfa.zip
Request-Verarbeitung ?berarbeitet
Diffstat (limited to 'src')
-rw-r--r--src/Common/Makefile.am2
-rw-r--r--src/Common/Makefile.in2
-rw-r--r--src/Common/Request/DisconnectRequest.h44
-rw-r--r--src/Common/Request/Makefile.am2
-rw-r--r--src/Common/Request/Makefile.in2
-rw-r--r--src/Common/Request/PingRequest.h47
-rw-r--r--src/Common/Request/Request.h (renamed from src/Common/RequestInfo.h)38
-rw-r--r--src/Common/RequestManager.cpp62
-rw-r--r--src/Common/RequestManager.h28
-rw-r--r--src/Core/ConfigManager.cpp2
-rw-r--r--src/madc.cpp4
11 files changed, 160 insertions, 73 deletions
diff --git a/src/Common/Makefile.am b/src/Common/Makefile.am
index 1e8a524..1958a1c 100644
--- a/src/Common/Makefile.am
+++ b/src/Common/Makefile.am
@@ -3,4 +3,4 @@ SUBDIRS = Request
noinst_LTLIBRARIES = libcommon.la
libcommon_la_SOURCES = ConfigManager.cpp RequestManager.cpp
-noinst_HEADERS = ConfigManager.h RequestInfo.h RequestManager.h Util.h
+noinst_HEADERS = ConfigManager.h RequestManager.h Util.h
diff --git a/src/Common/Makefile.in b/src/Common/Makefile.in
index f47fa8d..da63be0 100644
--- a/src/Common/Makefile.in
+++ b/src/Common/Makefile.in
@@ -192,7 +192,7 @@ top_srcdir = @top_srcdir@
SUBDIRS = Request
noinst_LTLIBRARIES = libcommon.la
libcommon_la_SOURCES = ConfigManager.cpp RequestManager.cpp
-noinst_HEADERS = ConfigManager.h RequestInfo.h RequestManager.h Util.h
+noinst_HEADERS = ConfigManager.h RequestManager.h Util.h
all: all-recursive
.SUFFIXES:
diff --git a/src/Common/Request/DisconnectRequest.h b/src/Common/Request/DisconnectRequest.h
index 309504d..9023c13 100644
--- a/src/Common/Request/DisconnectRequest.h
+++ b/src/Common/Request/DisconnectRequest.h
@@ -20,15 +20,53 @@
#ifndef DISCONNECTREQUEST_H_
#define DISCONNECTREQUEST_H_
-#include "../RequestInfo.h"
+#include "Request.h"
+#include "../RequestManager.h"
+#include <Net/Connection.h>
+#include <Net/Packet.h>
namespace Mad {
namespace Common {
namespace Request {
-class DisconnectRequest: public RequestInfo {
+class DisconnectRequest: public Request {
+ private:
+ DisconnectRequest() {}
+
public:
- DisconnectRequest() : RequestInfo(TYPE_DISCONNECT) {}
+ static bool send(Net::Connection *connection, RequestManager &requestManager) {
+ Request *request = new DisconnectRequest();
+
+ if(requestManager.sendRequest(connection, request))
+ return true;
+
+ delete request;
+ return false;
+ }
+
+ virtual bool sendRequest(Net::Connection *connection, unsigned short requestId) {
+ if(isSent())
+ return false;
+
+ if(!connection->send(Net::Packet(Net::Packet::TYPE_DISCONNECT_REQ, requestId)))
+ return false;
+
+ setSent();
+ return true;
+ }
+
+ virtual bool handlePacket(Net::Connection *connection, const Net::Packet &packet) {
+ if(isFinished())
+ return false;
+
+ if(packet.getType() != Net::Packet::TYPE_DISCONNECT_REP)
+ return false; // TODO Logging
+
+ connection->disconnect();
+
+ setFinished();
+ return true;
+ }
};
}
diff --git a/src/Common/Request/Makefile.am b/src/Common/Request/Makefile.am
index 35e432b..17e47fe 100644
--- a/src/Common/Request/Makefile.am
+++ b/src/Common/Request/Makefile.am
@@ -1 +1 @@
-noinst_HEADERS = DisconnectRequest.h PingRequest.h
+noinst_HEADERS = DisconnectRequest.h PingRequest.h Request.h
diff --git a/src/Common/Request/Makefile.in b/src/Common/Request/Makefile.in
index 7d68911..d96c0a7 100644
--- a/src/Common/Request/Makefile.in
+++ b/src/Common/Request/Makefile.in
@@ -162,7 +162,7 @@ sysconfdir = @sysconfdir@
target_alias = @target_alias@
top_builddir = @top_builddir@
top_srcdir = @top_srcdir@
-noinst_HEADERS = DisconnectRequest.h PingRequest.h
+noinst_HEADERS = DisconnectRequest.h PingRequest.h Request.h
all: all-am
.SUFFIXES:
diff --git a/src/Common/Request/PingRequest.h b/src/Common/Request/PingRequest.h
index 35a0171..92e3c1a 100644
--- a/src/Common/Request/PingRequest.h
+++ b/src/Common/Request/PingRequest.h
@@ -20,15 +20,56 @@
#ifndef MAD_COMMON_REQUEST_PINGREQUEST_H_
#define MAD_COMMON_REQUEST_PINGREQUEST_H_
-#include "../RequestInfo.h"
+#include "Request.h"
+#include "../RequestManager.h"
+#include <Net/Connection.h>
+#include <Net/Packet.h>
+
+#include <iostream>
namespace Mad {
namespace Common {
namespace Request {
-class PingRequest : public RequestInfo {
+class PingRequest : public Request {
+ private:
+ PingRequest() {}
+
public:
- PingRequest() : RequestInfo(TYPE_PING) {}
+ static bool send(Net::Connection *connection, RequestManager &requestManager) {
+ Request *request = new PingRequest();
+
+ if(requestManager.sendRequest(connection, request))
+ return true;
+
+ delete request;
+ return false;
+ }
+
+ virtual bool sendRequest(Net::Connection *connection, unsigned short requestId) {
+ if(isSent())
+ return false;
+
+ if(!connection->send(Net::Packet(Net::Packet::TYPE_PING, requestId)))
+ return false;
+
+ setSent();
+ return true;
+ }
+
+ virtual bool handlePacket(Net::Connection*, const Net::Packet &packet) {
+ if(isFinished())
+ return false;
+
+ if(packet.getType() != Net::Packet::TYPE_PONG)
+ return false; // TODO Logging
+
+ std::cout << "Received ping reply." << std::endl;
+ std::cout << " Request ID: " << packet.getRequestId() << std::endl;
+
+ setFinished();
+ return true;
+ }
};
}
diff --git a/src/Common/RequestInfo.h b/src/Common/Request/Request.h
index 943cf31..211b2cd 100644
--- a/src/Common/RequestInfo.h
+++ b/src/Common/Request/Request.h
@@ -1,5 +1,5 @@
/*
- * RequestInfo.h
+ * Request.h
*
* Copyright (C) 2008 Matthias Schiffer <matthias@gamezock.de>
*
@@ -17,29 +17,41 @@
* with this program. If not, see <http://www.gnu.org/licenses/>.
*/
-#ifndef MAD_COMMON_REQUESTINFO_H_
-#define MAD_COMMON_REQUESTINFO_H_
+#ifndef MAD_COMMON_REQUEST_REQUEST_H_
+#define MAD_COMMON_REQUEST_REQUEST_H_
namespace Mad {
-namespace Common {
-class RequestInfo {
- public:
- enum Type {
- TYPE_PING, TYPE_DISCONNECT
- };
+namespace Net {
+class Connection;
+class Packet;
+}
+
+namespace Common {
+namespace Request {
+class Request {
private:
- Type type;
+ bool sent, finished;
protected:
- RequestInfo(Type type0) : type(type0) {}
+ Request() : sent(false), finished(false) {}
+
+ void setSent() {sent = true;}
+ void setFinished() {finished = true;}
public:
- Type getType() const {return type;}
+ virtual ~Request() {}
+
+ bool isSent() const {return sent;}
+ bool isFinished() const {return finished;}
+
+ virtual bool sendRequest(Net::Connection *connection, unsigned short requestId) = 0;
+ virtual bool handlePacket(Net::Connection *connection, const Net::Packet &packet) = 0;
};
}
}
+}
-#endif /* MAD_COMMON_REQUESTINFO_H_ */
+#endif /* MAD_COMMON_REQUEST_REQUEST_H_ */
diff --git a/src/Common/RequestManager.cpp b/src/Common/RequestManager.cpp
index 34a9141..2d79b25 100644
--- a/src/Common/RequestManager.cpp
+++ b/src/Common/RequestManager.cpp
@@ -35,7 +35,16 @@ void RequestManager::receiveHandler(Net::Connection *connection, const Net::Pack
}
RequestMap &requestInfo = it->second;
- RequestMap::iterator it2;
+ Request::Request *request = requestInfo.findRequest(packet.getRequestId());
+
+ if(request) {
+ request->handlePacket(connection, packet);
+
+ if(request->isFinished())
+ requestInfo.deleteRequest(packet.getRequestId());
+
+ return;
+ }
switch(packet.getType()) {
case Net::Packet::TYPE_PING:
@@ -44,40 +53,16 @@ void RequestManager::receiveHandler(Net::Connection *connection, const Net::Pack
connection->send(Net::Packet(Net::Packet::TYPE_PONG, packet.getRequestId(), packet.getData(), packet.getLength()));
break;
- case Net::Packet::TYPE_PONG:
- it2 = requestInfo.find(packet.getRequestId());
- if(it2 == requestInfo.end() || it2->second.getType() != RequestInfo::TYPE_PING) {
- // TODO: Error
- std::cerr << "Received an unexpected ping reply." << std::endl;
-
- return;
- }
-
- requestInfo.erase(it2);
-
- std::cout << "Received ping reply." << std::endl;
- std::cout << " Request ID: " << packet.getRequestId() << std::endl;
- break;
case Net::Packet::TYPE_DISCONNECT_REQ:
connection->send(Net::Packet(Net::Packet::TYPE_DISCONNECT_REP, packet.getRequestId()));
connection->disconnect();
break;
- case Net::Packet::TYPE_DISCONNECT_REP:
- it2 = requestInfo.find(packet.getRequestId());
- if(it2 == requestInfo.end() || it2->second.getType() != RequestInfo::TYPE_DISCONNECT) {
- // TODO: Error
- std::cerr << "Received an unexpected disconnect reply." << std::endl;
-
- return;
- }
-
- requestInfo.erase(it2);
-
- connection->disconnect();
+ default:
+ std::cerr << "Received an unexpected packet." << std::endl;
}
}
-bool RequestManager::sendRequest(Net::Connection *connection, RequestInfo requestData) {
+bool RequestManager::sendRequest(Net::Connection *connection, Request::Request *request) {
std::map<Net::Connection*,RequestMap>::iterator it = requestMap.find(connection);
if(it == requestMap.end())
@@ -85,24 +70,15 @@ bool RequestManager::sendRequest(Net::Connection *connection, RequestInfo reques
RequestMap &requestInfo = it->second;
- unsigned short request;
+ unsigned short id;
do {
- request = getRequestId();
- } while(requestInfo.find(request) != requestInfo.end());
+ id = getRequestId();
+ } while(requestInfo.findRequest(id));
- switch(requestData.getType()) {
- case RequestInfo::TYPE_PING:
- if(!connection->send(Net::Packet(Net::Packet::TYPE_PING, request)))
- return false;
-
- requestInfo.insert(std::make_pair(request, requestData));
- break;
- case RequestInfo::TYPE_DISCONNECT:
- if(!connection->send(Net::Packet(Net::Packet::TYPE_DISCONNECT_REQ, request)))
- return false;
+ if(!request->sendRequest(connection, id))
+ return false;
- requestInfo.insert(std::make_pair(request, requestData));
- }
+ requestInfo.addRequest(id, request);
return true;
}
diff --git a/src/Common/RequestManager.h b/src/Common/RequestManager.h
index a5861dd..fde8f3e 100644
--- a/src/Common/RequestManager.h
+++ b/src/Common/RequestManager.h
@@ -20,7 +20,7 @@
#ifndef MAD_COMMON_REQUESTMANAGER_H_
#define MAD_COMMON_REQUESTMANAGER_H_
-#include "RequestInfo.h"
+#include "Request/Request.h"
#include <Net/Connection.h>
#include <map>
@@ -29,7 +29,29 @@ namespace Common {
class RequestManager {
private:
- typedef std::map<unsigned short,RequestInfo> RequestMap;
+ class RequestMap : private std::map<unsigned short,Request::Request*> {
+ public:
+ ~RequestMap() {
+ for(iterator it = begin(); it != end(); ++it)
+ delete it->second;
+ }
+
+ bool addRequest(unsigned short id, Request::Request *info) {
+ return insert(std::make_pair(id, info)).second;
+ }
+
+ Request::Request* findRequest(unsigned short id) {
+ iterator it = find(id);
+ if(it == end())
+ return 0;
+
+ return it->second;
+ }
+
+ bool deleteRequest(unsigned short id) {
+ return erase(id);
+ }
+ };
std::map<Net::Connection*,RequestMap> requestMap;
unsigned short requestId;
@@ -51,7 +73,7 @@ class RequestManager {
requestMap.erase(connection);
}
- bool sendRequest(Net::Connection *connection, RequestInfo requestData);
+ bool sendRequest(Net::Connection *connection, Request::Request *request);
RequestManager() : requestId(0) {}
diff --git a/src/Core/ConfigManager.cpp b/src/Core/ConfigManager.cpp
index e1e5021..b4c81bc 100644
--- a/src/Core/ConfigManager.cpp
+++ b/src/Core/ConfigManager.cpp
@@ -20,8 +20,6 @@
#include "ConfigManager.h"
#include <Common/Util.h>
-#include <iostream>
-
namespace Mad {
namespace Core {
diff --git a/src/madc.cpp b/src/madc.cpp
index 3f5d5bc..d6a06e3 100644
--- a/src/madc.cpp
+++ b/src/madc.cpp
@@ -43,8 +43,8 @@ int main() {
requestManager.registerConnection(connection);
- requestManager.sendRequest(connection, Mad::Common::Request::PingRequest());
- requestManager.sendRequest(connection, Mad::Common::Request::DisconnectRequest());
+ Mad::Common::Request::PingRequest::send(connection, requestManager);
+ Mad::Common::Request::DisconnectRequest::send(connection, requestManager);
while(connection->isConnected()) {
struct pollfd fd = connection->getPollfd();