Add sensor monitor server and client skeletons

1 files changed, 297 insertions, 0 deletions

diff --git a/clients/tde/src/part/sensormonitor/part.cpp b/clients/tde/src/part/sensormonitor/part.cpp
new file mode 100644
index 0000000..469f24d
--- /dev/null
+++ b/clients/tde/src/part/sensormonitor/part.cpp
@@ -0,0 +1,297 @@
+/*
+ * Remote Laboratory FPGA Programming Part
+ *
+ * This program 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.
+ *
+ * This program 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 this program; if not, write to the Free Software Foundation, Inc.,
+ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
+ *
+ * (c) 2012 Timothy Pearson
+ * Raptor Engineering
+ * http://www.raptorengineeringinc.com
+ */
+
+#include "define.h"
+#include "part.h"
+
+#include <kaboutdata.h>   //::createAboutData()
+#include <kaction.h>
+#include <klocale.h>
+#include <ktextedit.h>
+#include <kfiledialog.h>
+#include <kmessagebox.h>  //::start()
+#include <kparts/genericfactory.h>
+#include <kstatusbar.h>
+#include <kstdaction.h>
+#include <knuminput.h>
+#include <kmdcodec.h>
+#include <kurlrequester.h>
+#include <tqfile.h>        //encodeName()
+#include <tqtimer.h>       //postInit() hack
+#include <tqvbox.h>
+#include <tqsocket.h>
+#include <tqmutex.h>
+#include <tqeventloop.h>
+#include <tqapplication.h>
+#include <tqgroupbox.h>
+#include <tqcheckbox.h>
+#include <tqpushbutton.h>
+#include <tqprogressbar.h>
+#include <unistd.h>       //access()
+#include <stdint.h>
+
+#include <tqpainter.h>
+
+#include "tracewidget.h"
+#include "floatspinbox.h"
+#include "layout.h"
+
+#define NETWORK_COMM_TIMEOUT_MS 2500
+
+enum connectionModes {
+	ModeIdle					= 0
+};
+
+enum connectionStates {
+	ModeIdle_StateStatusRequest			= 0,
+	ModeIdle_StateProcessStatus			= 1,
+	ModeIdle_StateDelay				= 2
+};
+
+namespace RemoteLab {
+
+typedef KParts::GenericFactory<RemoteLab::SensorMonitorPart> Factory;
+#define CLIENT_LIBRARY "libremotelab_sensormonitor"
+K_EXPORT_COMPONENT_FACTORY(libremotelab_sensormonitor, RemoteLab::Factory)
+
+SensorMonitorPart::SensorMonitorPart(TQWidget *parentWidget, const char *widgetName, TQObject *parent, const char *name, const TQStringList&)
+	: RemoteInstrumentPart( parent, name ), m_base(NULL), m_commHandlerState(0), m_connectionActiveAndValid(false), m_tickerState(0)
+{
+	// Initialize important base class variables
+	m_clientLibraryName = CLIENT_LIBRARY;
+
+	// Initialize mutex
+	m_connectionMutex = new TQMutex(false);
+
+	// Initialize kpart
+	setInstance(Factory::instance());
+	setWidget(new TQVBox(parentWidget, widgetName));
+
+	// Create timers
+	m_forcedUpdateTimer = new TQTimer(this);
+	connect(m_forcedUpdateTimer, SIGNAL(timeout()), this, SLOT(mainEventLoop()));
+	m_updateTimeoutTimer = new TQTimer(this);
+	connect(m_updateTimeoutTimer, SIGNAL(timeout()), this, SLOT(mainEventLoop()));
+	m_pingDelayTimer = new TQTimer(this);
+	connect(m_pingDelayTimer, SIGNAL(timeout()), this, SLOT(mainEventLoop()));
+
+	// Create widgets
+	m_base = new SensorMonitorBase(widget());
+
+	// Initialize widgets
+	connect(m_base->runControlStartButton, SIGNAL(clicked()), this, SLOT(programStartButtonClicked()));
+	connect(m_base->runControlStopButton, SIGNAL(clicked()), this, SLOT(programStopButtonClicked()));
+
+	TQTimer::singleShot(0, this, TQT_SLOT(postInit()));
+}
+
+SensorMonitorPart::~SensorMonitorPart() {
+	if (m_connectionMutex->locked()) {
+		printf("[WARNING] Exiting when data transfer still in progress!\n\r"); fflush(stdout);
+	}
+
+	disconnectFromServer();
+	delete m_connectionMutex;
+}
+
+void SensorMonitorPart::processLockouts() {
+	TQWidget* mainWidget = widget();
+	if (mainWidget) {
+		if ((m_socket) && (m_socket->state() == TQSocket::Connected) && (connToServerState > 0) && (connToServerConnecting == false)) {
+			mainWidget->setEnabled(true);
+		}
+		else {
+			mainWidget->setEnabled(false);
+		}
+	}
+}
+
+void SensorMonitorPart::resizeToHint() {
+	resize(widget()->sizeHint());
+}
+
+void SensorMonitorPart::connectionClosed() {
+	closeURL();
+}
+
+void SensorMonitorPart::postInit() {
+	setUsingFixedSize(false);
+}
+
+bool SensorMonitorPart::openURL(const KURL &url) {
+	int ret;
+	ret = connectToServer(url.url());
+	processLockouts();
+	return (ret != 0);
+}
+
+bool SensorMonitorPart::closeURL() {
+	disconnectFromServer();
+	m_url = KURL();
+	return true;
+}
+
+void SensorMonitorPart::disconnectFromServerCallback() {
+	m_forcedUpdateTimer->stop();
+	m_updateTimeoutTimer->stop();
+}
+
+void SensorMonitorPart::connectionFinishedCallback() {
+	connect(m_socket, SIGNAL(readyRead()), m_socket, SLOT(processPendingData()));
+	m_socket->processPendingData();
+	connect(m_socket, SIGNAL(newDataReceived()), this, SLOT(mainEventLoop()));
+	m_tickerState = 0;
+	m_commHandlerState = ModeIdle_StateStatusRequest;
+	m_commHandlerMode = ModeIdle;
+	m_socket->setDataTimeout(NETWORK_COMM_TIMEOUT_MS);
+	m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE);
+	processLockouts();
+	mainEventLoop();
+	return;
+}
+
+void SensorMonitorPart::connectionStatusChangedCallback() {
+	processLockouts();
+}
+
+#define UPDATEDISPLAY_TIMEOUT		m_connectionActiveAndValid = false;														\
+					m_tickerState = 0;																\
+					m_commHandlerState = ModeIdle_StateStatusRequest;												\
+					m_commHandlerMode = ModeIdle;															\
+					m_socket->clearIncomingData();															\
+					setStatusMessage(i18n("Server ping timeout.  Please verify the status of your network connection."));						\
+					m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE);											\
+					m_connectionMutex->unlock();															\
+					return;
+
+#define SET_WATCHDOG_TIMER		if (!m_updateTimeoutTimer->isActive()) m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE);
+#define PAT_WATCHDOG_TIMER		m_updateTimeoutTimer->stop(); m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE);
+
+#define SET_NEXT_STATE(x)		m_commHandlerState = x;	
+
+#define EXEC_NEXT_STATE_IMMEDIATELY	m_forcedUpdateTimer->start(0, TRUE);
+
+void SensorMonitorPart::setTickerMessage(TQString message) {
+	m_connectionActiveAndValid = true;
+	TQString tickerChar;
+	switch (m_tickerState) {
+		case 0:
+			tickerChar = "-";
+			break;
+		case 1:
+			tickerChar = "\\";
+			break;
+		case 2:
+			tickerChar = "|";
+			break;
+		case 3:
+			tickerChar = "/";
+			break;
+	}
+	setStatusMessage(message + TQString("... %1").arg(tickerChar));
+	m_tickerState++;
+	if (m_tickerState > 3) {
+		m_tickerState = 0;
+	}
+}
+
+void SensorMonitorPart::mainEventLoop() {
+	TQDataStream ds(m_socket);
+	ds.setPrintableData(true);
+
+	if (!m_connectionMutex->tryLock()) {
+		EXEC_NEXT_STATE_IMMEDIATELY
+		return;
+	}
+
+	if (m_socket) {
+		if (m_commHandlerMode == ModeIdle) {
+			// Normal operation
+			switch (m_commHandlerState) {
+				case ModeIdle_StateStatusRequest:
+					// Get status of remote system
+					// Clear buffers to synchronize frames in case of data corruption
+					m_socket->clearIncomingData();
+					ds << TQString("STATUS");
+					m_socket->writeEndOfFrame();
+
+					SET_NEXT_STATE(ModeIdle_StateProcessStatus)
+					break;
+				case ModeIdle_StateProcessStatus:
+					// Get all data
+					if (m_socket->canReadFrame()) {
+						PAT_WATCHDOG_TIMER
+
+						TQString status;
+						ds >> status;
+						m_socket->clearFrameTail();
+
+						if (status == "") {
+							// Transfer probably failed
+							UPDATEDISPLAY_TIMEOUT
+						}
+						else if (status == "IDLE") {
+							// Do nothing
+						}
+
+						setTickerMessage(i18n("Connected"));
+
+						if (m_commHandlerState == ModeIdle_StateProcessStatus) {
+							m_pingDelayTimer->start(250, TRUE);
+							SET_NEXT_STATE(ModeIdle_StateDelay);
+						}
+					}
+					else {
+						if (!m_updateTimeoutTimer->isActive()) {
+							UPDATEDISPLAY_TIMEOUT
+						}
+					}
+					break;
+				case ModeIdle_StateDelay:
+					// Let the client and server rest for a bit to lower CPU/network overhead
+					if (!m_pingDelayTimer->isActive()) {
+						EXEC_NEXT_STATE_IMMEDIATELY
+						// Execute query on next event loop
+						SET_NEXT_STATE(ModeIdle_StateStatusRequest);
+					}
+					PAT_WATCHDOG_TIMER
+					break;
+			}
+		}
+
+		SET_WATCHDOG_TIMER
+	}
+	else {
+		SET_NEXT_STATE(ModeIdle_StateStatusRequest);
+		m_commHandlerMode = ModeIdle;
+	}
+
+	m_connectionMutex->unlock();
+}
+
+KAboutData* SensorMonitorPart::createAboutData() {
+	return new KAboutData( APP_NAME, I18N_NOOP( APP_PRETTYNAME ), APP_VERSION );
+}
+
+} //namespace RemoteLab
+
+#include "part.moc"