[omapd] r171 committed - Add the managementserver.{h,cpp} files

[om...@googlecode.com]

Revision: 171
Author: sma...@gmail.com
Date: Thu Jan 3 16:45:23 2013
Log: Add the managementserver.{h,cpp} files
http://code.google.com/p/omapd/source/detail?r=171

Added:
/trunk/managementserver.cpp
/trunk/managementserver.h

=======================================
--- /dev/null
+++ /trunk/managementserver.cpp Thu Jan 3 16:45:23 2013
@@ -0,0 +1,94 @@
+/*
+managementserver.cpp: Implementation of ManagementServer class
+
+Copyright (C) 2013 Sarab D. Mattes <mat...@nixnux.org>
+
+This file is part of omapd.
+
+omapd is free software: you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+omapd is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with omapd. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#include <QTcpSocket>
+#include "managementserver.h"
+
+ManagementServer::ManagementServer(MapGraphInterface *mapGraph, QObject
*parent) :
+ QTcpServer(parent), _mapGraph(mapGraph)
+{
+ _omapdConfig = OmapdConfig::getInstance();
+}
+
+bool ManagementServer::startListening()
+{
+ bool rc = false;
+ QHostAddress listenOn;
+ if
(listenOn.setAddress(_omapdConfig->valueFor("mgmt_address").toString())) {
+ unsigned int port = _omapdConfig->valueFor("mgmt_port").toUInt();
+
+ if (listenOn != QHostAddress::LocalHost && listenOn !=
QHostAddress::LocalHostIPv6) {
+ qDebug() << __PRETTY_FUNCTION__ << ":"
+ << "WARNING: Management interface configured for
non-localhost interface:"
+ << listenOn.toString();
+ }
+
+ if (listen(listenOn, port)) {
+ rc = true;
+ this->setMaxPendingConnections(30); // 30 is QTcpServer default
+
+ connect(this, SIGNAL(newConnection()), this,
SLOT(handleMgmtConnection()));
+ } else {
+ qDebug() << __PRETTY_FUNCTION__ << ":" << "Error with listen
on:" << listenOn.toString()
+ << ":" << port;
+ }
+ } else {
+ qDebug() << __PRETTY_FUNCTION__ << ":" << "Error setting server
address";
+ }
+
+ return rc;
+}
+
+void ManagementServer::handleMgmtConnection()
+{
+ QTcpSocket *clientConnection = this->nextPendingConnection();
+
+ if
(_omapdConfig->valueFor("debug_level").value<OmapdConfig::IfmapDebugOptions>().testFlag(OmapdConfig::ShowManagementRequests))
{
+ qDebug() << __PRETTY_FUNCTION__ << ":" << "Received management
request from:"
+ << clientConnection->peerAddress().toString();
+ }
+
+ connect(clientConnection, SIGNAL(disconnected()),
+ clientConnection, SLOT(deleteLater()));
+
+ connect(clientConnection, SIGNAL(readyRead()),
+ this, SLOT(readMgmtRequest()));
+}
+
+void ManagementServer::readMgmtRequest()
+{
+ QTcpSocket *clientConnection = (QTcpSocket *)sender();
+
+ QByteArray requestData = clientConnection->readLine(128).trimmed();
+ if
(_omapdConfig->valueFor("debug_level").value<OmapdConfig::IfmapDebugOptions>().testFlag(OmapdConfig::ShowManagementRequests))
{
+ qDebug() << __PRETTY_FUNCTION__ << ":" << "Received management
request:"
+ << requestData;
+ }
+
+ if (requestData == "mapdump") {
+ _mapGraph->dumpMap();
+ } else {
+ if
(_omapdConfig->valueFor("debug_level").value<OmapdConfig::IfmapDebugOptions>().testFlag(OmapdConfig::ShowManagementRequests))
{
+ qDebug() << __PRETTY_FUNCTION__ << ":" << "Received
unrecognized management request:"
+ << requestData;
+ }
+ }
+}
=======================================
--- /dev/null
+++ /trunk/managementserver.h Thu Jan 3 16:45:23 2013
@@ -0,0 +1,47 @@
+/*
+managementserver.h: Declaration of ManagementServer class
+
+Copyright (C) 2013 Sarab D. Mattes <mat...@nixnux.org>
+
+This file is part of omapd.
+
+omapd is free software: you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation, either version 3 of the License, or
+(at your option) any later version.
+
+omapd is distributed in the hope that it will be useful,
+but WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+GNU General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with omapd. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+#ifndef MANAGEMENTSERVER_H
+#define MANAGEMENTSERVER_H
+
+#include <QtCore>
+#include <QTcpServer>
+#include "mapgraphinterface.h"
+
+class ManagementServer : public QTcpServer
+{
+ Q_OBJECT
+public:
+ explicit ManagementServer(MapGraphInterface *mapGraph, QObject *parent
= 0);
+ bool startListening();
+
+signals:
+
+private slots:
+ void handleMgmtConnection();
+ void readMgmtRequest();
+
+private:
+ OmapdConfig* _omapdConfig;
+ MapGraphInterface* _mapGraph;
+};
+
+#endif // MANAGEMENTSERVER_H