uLab
/
remotelaboratory
mirror of https://mirror.git.trinitydesktop.org/gitea/uLab/remotelaboratory
0
0
Fork 0
Code Issues Releases Wiki Activity

Add serial console client

Browse Source
master
Timothy Pearson 10 years ago
parent c912b0f1d3
commit 55f109d365
8 changed files with 423 additions and 5 deletions
Show Stats Download Patch File Download Diff File

2
clients/tde/src/part/Makefile.am
Unescape View File

@ -1 +1 @@
SUBDIRS = scope commanalyzer fpgaview fpgaprogram sensormonitor adminconsole adminusermgmt prototerminal
SUBDIRS = scope commanalyzer fpgaview fpgaprogram sensormonitor adminconsole adminusermgmt serialconsole prototerminal

2
clients/tde/src/part/prototerminal/part.cpp
Unescape View File

@ -1,4 +1,4 @@
//Author: Timothy Pearson <kb9vqf@pearsoncomputing.net>, (C) 2012
//Author: Timothy Pearson <kb9vqf@pearsoncomputing.net>, (C) 2014
//Copyright: See COPYING file that comes with this distribution
#include "define.h"

6
clients/tde/src/part/prototerminal/part.h
Unescape View File

@ -1,8 +1,8 @@
//Author: Timothy Pearson <kb9vqf@pearsoncomputing.net>, (C) 2012
//Author: Timothy Pearson <kb9vqf@pearsoncomputing.net>, (C) 2014
//Copyright: See COPYING file that comes with this distribution
#ifndef REMOTELAB_COMMANALYZERPART_H
#define REMOTELAB_COMMANALYZERPART_H
#ifndef REMOTELAB_PROTOTERMINALPART_H
#define REMOTELAB_PROTOTERMINALPART_H
#include <tdeparts/browserextension.h>
#include <tdeparts/statusbarextension.h>

12
clients/tde/src/part/serialconsole/Makefile.am
Unescape View File

@ -0,0 +1,12 @@
INCLUDES = $(all_includes) -I$(top_srcdir)/src -I$(top_srcdir)/src/widgets $(KDE_INCLUDES)/tde
KDE_CXXFLAGS = $(USE_EXCEPTIONS)
METASOURCES = AUTO
KDE_ICON = libremotelab_serialconsole
#Part
kde_module_LTLIBRARIES = libremotelab_serialconsole.la
libremotelab_serialconsole_la_LIBADD = $(LIB_KFILE) $(LIB_TDEPARTS) $(LIB_TDEUI) $(LIB_QT)
libremotelab_serialconsole_la_LDFLAGS = $(all_libraries) $(KDE_PLUGIN) -ltdecore -ltdeui -ltdeio -ltdefx -ltdekrbsocket -ltqtrla
libremotelab_serialconsole_la_SOURCES = \
part.cpp layout.ui

BIN
clients/tde/src/part/serialconsole/hi16-action-libremotelab_serialconsole.png
View File

Binary file not shown.
Side by Side

After

Width:  |  Height:  |  Size: 666 B

58
clients/tde/src/part/serialconsole/layout.ui
Unescape View File

@ -0,0 +1,58 @@
<!DOCTYPE UI><UI version="3.0" stdsetdef="1">
<class>SerialConsoleBase</class>
<widget class="TQWidget">
<property name="name">
<cstring>SerialConsoleBase</cstring>
</property>
<property name="geometry">
<rect>
<x>0</x>
<y>0</y>
<width>519</width>
<height>356</height>
</rect>
</property>
<grid>
<property name="name">
<cstring>unnamed</cstring>
</property>
<widget class="KTextEdit" row="0" column="0" colspan="3">
<property name="name">
<cstring>textOutput</cstring>
</property>
<property name="readOnly">
<bool>true</bool>
</property>
</widget>
<widget class="TQLabel" row="1" column="0" colspan="1">
<property name="name">
<cstring>unnamed</cstring>
</property>
<property name="text">
<string>Input:</string>
</property>
<property name="textFormat">
<enum>PlainText</enum>
</property>
</widget>
<widget class="KLineEdit" row="1" column="1" colspan="1">
<property name="name">
<cstring>textInput</cstring>
</property>
</widget>
<widget class="TQPushButton" row="1" column="2" colspan="1">
<property name="name">
<cstring>sendText</cstring>
</property>
<property name="text">
<cstring>Send</cstring>
</property>
</widget>
</grid>
</widget>
<includes>
<include location="local" impldecl="in implementation">SerialConsoleBase.ui.h</include>
</includes>
<layoutdefaults spacing="3" margin="6"/>
<layoutfunctions spacing="KDialog::spacingHint" margin="KDialog::marginHint"/>
</UI>

284
clients/tde/src/part/serialconsole/part.cpp
Unescape View File

@ -0,0 +1,284 @@
//Author: Timothy Pearson <kb9vqf@pearsoncomputing.net>, (C) 2014
//Copyright: See COPYING file that comes with this distribution
#include "define.h"
#include "part.h"
#include <tdeaboutdata.h> //::createAboutData()
#include <tdeaction.h>
#include <tdelocale.h>
#include <tdemessagebox.h> //::start()
#include <tdeparts/genericfactory.h>
#include <kstatusbar.h>
#include <kstdaction.h>
#include <tqfile.h> //encodeName()
#include <tqtimer.h>
#include <tqvbox.h>
#include <tqsocket.h>
#include <tqmutex.h>
#include <tqeventloop.h>
#include <tqapplication.h>
#include <tqpushbutton.h>
#include <klineedit.h>
#include <ktextedit.h>
#include <unistd.h> //access()
#include <stdint.h>
#include <cmath>
#include "layout.h"
#define NETWORK_COMM_TIMEOUT_MS 15000
/* exception handling */
struct exit_exception {
int c;
exit_exception(int c):c(c) { }
};
namespace RemoteLab {
typedef KParts::GenericFactory<RemoteLab::SerialConsolePart> Factory;
#define CLIENT_LIBRARY "libremotelab_serialconsole"
K_EXPORT_COMPONENT_FACTORY( libremotelab_serialconsole, RemoteLab::Factory )
SerialConsolePart::SerialConsolePart( TQWidget *parentWidget, const char *widgetName, TQObject *parent, const char *name, const TQStringList& )
: RemoteInstrumentPart( parent, name ), m_commHandlerState(-1), m_commHandlerMode(0), m_commHandlerCommandState(0), m_connectionActiveAndValid(false), m_base(0)
{
// Initialize important base class variables
m_clientLibraryName = CLIENT_LIBRARY;
// Initialize mutex
m_instrumentMutex = 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()));
// Create widgets
m_base = new SerialConsoleBase(widget());
connect(m_base->sendText, SIGNAL(clicked()), this, SLOT(sendTextClicked()));
connect(m_base->textInput, SIGNAL(returnPressed()), m_base->sendText, SIGNAL(clicked()));
TQTimer::singleShot(0, this, TQT_SLOT(postInit()));
}
SerialConsolePart::~SerialConsolePart() {
if (m_instrumentMutex->locked()) {
printf("[WARNING] Exiting when data transfer still in progress!\n\r"); fflush(stdout);
}
disconnectFromServer();
delete m_instrumentMutex;
}
void SerialConsolePart::postInit() {
setUsingFixedSize(false);
}
bool SerialConsolePart::openURL(const KURL &url) {
int ret;
m_connectionActiveAndValid = false;
ret = connectToServer(url.url());
processLockouts();
return (ret != 0);
}
bool SerialConsolePart::closeURL() {
disconnectFromServer();
m_url = KURL();
return true;
}
void SerialConsolePart::processLockouts() {
if (m_connectionActiveAndValid) {
m_base->setEnabled(true);
}
else {
m_base->setEnabled(false);
}
}
void SerialConsolePart::disconnectFromServerCallback() {
m_forcedUpdateTimer->stop();
m_updateTimeoutTimer->stop();
m_connectionActiveAndValid = false;
}
void SerialConsolePart::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 = 0;
m_commHandlerMode = 0;
m_socket->setDataTimeout(NETWORK_COMM_TIMEOUT_MS);
m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE);
processLockouts();
mainEventLoop();
return;
}
void SerialConsolePart::connectionStatusChangedCallback() {
processLockouts();
}
void SerialConsolePart::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;
}
}
#define UPDATEDISPLAY_TIMEOUT m_connectionActiveAndValid = false; \
m_tickerState = 0; \
m_commHandlerState = 2; \
m_commHandlerMode = 0; \
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_instrumentMutex->unlock(); \
return;
#define COMMUNICATIONS_FAILED m_connectionActiveAndValid = false; \
m_tickerState = 0; \
m_commHandlerState = 2; \
m_commHandlerMode = 0; \
m_socket->clearIncomingData(); \
setStatusMessage(i18n("Instrument communication failure. Please verify the status of your network connection.")); \
m_updateTimeoutTimer->start(NETWORK_COMM_TIMEOUT_MS, TRUE); \
m_instrumentMutex->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); \
setTickerMessage(i18n("Connected"));
#define SET_NEXT_STATE(x) if (m_commHandlerMode == 0) { \
m_commHandlerState = x; \
} \
else { \
m_commHandlerState = 255; \
}
#define EXEC_NEXT_STATE_IMMEDIATELY m_forcedUpdateTimer->start(0, TRUE);
void SerialConsolePart::mainEventLoop() {
TQDataStream ds(m_socket);
ds.setPrintableData(true);
if (!m_instrumentMutex->tryLock()) {
EXEC_NEXT_STATE_IMMEDIATELY
return;
}
if (m_socket) {
if ((m_commHandlerMode == 0) || (m_commHandlerMode == 1)) {
if (m_commHandlerState == 0) {
ds << TQString("PING");
m_socket->writeEndOfFrame();
m_commHandlerState = 1;
EXEC_NEXT_STATE_IMMEDIATELY
}
else if (m_commHandlerState == 1) {
// Receive data
if (m_socket->canReadFrame()) {
PAT_WATCHDOG_TIMER
// Get command status
TQString input;
while (!ds.atEnd()) {
ds >> input;
if (input == "DATA") {
TQByteArray data;
ds >> data;
TQString textData(data);
textData.replace("\r", "\n>>>");
m_base->textOutput->append(">>>" + textData);
}
}
m_socket->clearFrameTail();
EXEC_NEXT_STATE_IMMEDIATELY
}
else {
if (!m_updateTimeoutTimer->isActive()) {
UPDATEDISPLAY_TIMEOUT
}
}
// Send data
if (m_TextToSend != "") {
TQByteArray data;
data.duplicate(m_TextToSend.ascii(), strlen(m_TextToSend.ascii()));
ds << TQString("SEND");
ds << data;
m_socket->writeEndOfFrame();
m_base->textOutput->append("<<<" + m_TextToSend);
m_TextToSend = "";
EXEC_NEXT_STATE_IMMEDIATELY
}
else {
ds << TQString("PING");
m_socket->writeEndOfFrame();
}
}
else if (m_commHandlerState == 2) {
// Ignore timeouts
m_commHandlerState = 1;
EXEC_NEXT_STATE_IMMEDIATELY
}
SET_WATCHDOG_TIMER
}
}
else {
m_commHandlerState = 0;
m_commHandlerCommandState = 0;
}
processLockouts();
m_instrumentMutex->unlock();
}
void SerialConsolePart::sendTextClicked() {
m_TextToSend = m_TextToSend + m_base->textInput->text();
m_base->textInput->setText("");
// Transmit!
EXEC_NEXT_STATE_IMMEDIATELY
}
TDEAboutData* SerialConsolePart::createAboutData() {
return new TDEAboutData( APP_NAME, I18N_NOOP( APP_PRETTYNAME ), APP_VERSION );
}
} //namespace RemoteLab
#include "part.moc"

64
clients/tde/src/part/serialconsole/part.h
Unescape View File

@ -0,0 +1,64 @@
//Author: Timothy Pearson <kb9vqf@pearsoncomputing.net>, (C) 2014
//Copyright: See COPYING file that comes with this distribution
#ifndef REMOTELAB_SERIALCONSOLEPART_H
#define REMOTELAB_SERIALCONSOLEPART_H
#include <tdeparts/browserextension.h>
#include <tdeparts/statusbarextension.h>
#include <tdeparts/part.h>
#include <kurl.h>
#include <tqtrla.h>
class TDEAboutData;
using KParts::StatusBarExtension;
class TraceWidget;
class TQSocket;
class TQTimer;
class TQMutex;
class TQRectF;
class SerialConsoleBase;
namespace RemoteLab
{
class SerialConsolePart : public KParts::RemoteInstrumentPart
{
Q_OBJECT
public:
SerialConsolePart( QWidget *, const char *, TQObject *, const char *, const TQStringList&);
~SerialConsolePart();
virtual bool openFile() { return false; } // pure virtual in the base class
virtual bool closeURL();
static TDEAboutData *createAboutData();
public slots:
virtual bool openURL(const KURL &url);
private slots:
void postInit();
void processLockouts();
void connectionFinishedCallback();
void disconnectFromServerCallback();
void connectionStatusChangedCallback();
void setTickerMessage(TQString message);
void mainEventLoop();
void sendTextClicked();
private:
int m_commHandlerState;
int m_commHandlerMode;
int m_commHandlerCommandState;
TQTimer* m_forcedUpdateTimer;
TQTimer* m_updateTimeoutTimer;
bool m_connectionActiveAndValid;
unsigned char m_tickerState;
SerialConsoleBase* m_base;
TQMutex* m_instrumentMutex;
TQString m_TextToSend;
};
}
#endif
Write Preview
Loading…
Cancel
Save