##// END OF EJS Templates
Changes to lfrsge...
Changes to lfrsge Minor changes to the rmap plugin

File last commit:

r45:bff3fdf42776 default
r58:6bfd3f59df14 default
Show More
tmechobridge.cpp
241 lines | 8.1 KiB | text/x-c | CppLexer
#include "tmechobridge.h"
TMEchoBridge::TMEchoBridge(QWidget *parent) :
QWidget(parent)
{
totalOfBytes = 0;
totalOfPackets = 0;
totalOfPacketsDropped = 0;
tmEchoBridgeServer = new QTcpServer();
tmEchoBridgeSocket = new QTcpSocket();
xmlWriter = new QXmlStreamWriter();
console = new QTextEdit();
label_TMServerPort = new QLabel(tr("TM Server Port:"));
label_totalOfBytes = new QLabel(tr("Number of TM bytes sent: -"));
label_totalOfPackets = new QLabel(tr("Number of TM packets sent: -"));
label_totalOfPacketsDropped = new QLabel(tr("Number of TM packets dropped: -"));
spinbox_TMServerPort = new QSpinBox();
spinbox_TMServerPort->setRange(59002, 65535);
button_openServerTCTM = new QPushButton(tr("Open Port"));
button_testServerTCTM = new QPushButton(tr("Test Port"));
button_sendTestPacket = new QPushButton(tr("Send a test packet"));
button_clearConsole = new QPushButton(tr("Clear console"));
button_resetTMStatistics = new QPushButton(tr("Reset TM Statistics"));
groupbox_ports = new QGroupBox(tr("Port of the TM Echo Bridge"));
layout_ports = new QGridLayout();
mainLayout = new QGridLayout();
initSocketStatesList();
layout_ports->addWidget(label_TMServerPort, 0, 0, 1, 1);
layout_ports->addWidget(spinbox_TMServerPort, 0, 1, 1, 1);
layout_ports->addWidget(button_openServerTCTM, 2, 0, 1, 2);
layout_ports->addWidget(button_testServerTCTM, 3, 0, 1, 2);
layout_ports->addWidget(button_sendTestPacket, 4, 0, 1, 2);
layout_ports->addWidget(label_totalOfPackets, 5, 0, 1, 2);
layout_ports->addWidget(label_totalOfBytes, 6, 0, 1, 2);
layout_ports->addWidget(label_totalOfPacketsDropped, 7, 0, 1, 2);
layout_ports->addWidget(button_resetTMStatistics, 8, 0, 1, 2);
layout_ports->setRowStretch(9, 1);
layout_ports->setColumnStretch(2, 1);
groupbox_ports->setLayout(layout_ports);
mainLayout->addWidget(groupbox_ports, 0, 0, 1, 1);
mainLayout->addWidget(console, 0, 1, 1, 1);
mainLayout->addWidget(button_clearConsole, 1, 1, 1, 1);
this->setLayout(mainLayout);
connect(this->tmEchoBridgeServer, SIGNAL(newConnection()), this, SLOT(newConnectionOnTMEchoBridgeServer()));
connect(this->button_openServerTCTM, SIGNAL(clicked()), this, SLOT(listenOnTMEchoBridgePort()));
connect(this->button_testServerTCTM, SIGNAL(clicked()), this, SLOT(testTMEchoBridgePort()));
connect(this->button_sendTestPacket, SIGNAL(clicked()), this, SLOT(sendXML_GSE_HK()));
connect(this->button_clearConsole, SIGNAL(clicked()), this, SLOT(clearConsole()));
connect(this->button_resetTMStatistics, SIGNAL(clicked()), this, SLOT(resetTMStatistics()));
}
void TMEchoBridge::listenOnTMEchoBridgePort()
{
QString str;
tmEchoBridgeServer->listen(QHostAddress::Any, this->getTMPort());
str = tmEchoBridgeServer->errorString();
if (!str.isEmpty())
{
this->displayOnConsole(str);
}
this->displayOnConsole("Listening TM on port "
+ QString::number(this->getTMPort())
);
}
void TMEchoBridge::testTMEchoBridgePort()
{
if (tmEchoBridgeSocket != NULL)
{
this->displayOnConsole("TM socket *** " + socketStates.at(tmEchoBridgeSocket->state()) );
}
else
{
this->displayOnConsole("TC socket *** not tested, (socketTC) is NULL" );
}
}
void TMEchoBridge::newConnectionOnTMEchoBridgeServer()
{
this->displayOnConsole("got new connection on TM port");
tmEchoBridgeSocket = tmEchoBridgeServer->nextPendingConnection();
this->displayOnConsole("TM socket *** " + socketStates.at(tmEchoBridgeSocket->state()) );
xmlWriter->setDevice(this->tmEchoBridgeSocket);
}
int TMEchoBridge::getTMPort()
{
return spinbox_TMServerPort->value();
}
void TMEchoBridge::displayOnConsole(QString message)
{
console->append(message);
}
void TMEchoBridge::initSocketStatesList()
{
socketStates.append("The socket is not connected");
socketStates.append("The socket is performing a host name lookup");
socketStates.append("The socket has started establishing a connection");
socketStates.append("A connection is established");
socketStates.append("The socket is bound to an address and port (for servers)");
socketStates.append("The socket is about to close (data may still be waiting to be written)");
socketStates.append("For internal use only");
}
void TMEchoBridge::sendXML_GSE_HK()
{
char data[10];
for (int i = 0; i <10; i++)
{
data[i] = i;
}
if (tmEchoBridgeSocket->state() == QAbstractSocket::ConnectedState)
{
xmlWriter->writeStartDocument();
xmlWriter->writeStartElement("Event");
// EventDate
xmlWriter->writeStartElement("EventDate");
xmlWriter->writeEndElement();
// Event Time
xmlWriter->writeStartElement("EventTime");
xmlWriter->writeEndElement();
// EventBinary
xmlWriter->writeStartElement("EventBinary");
xmlWriter->writeCharacters("FFFFCC0099");
xmlWriter->writeCharacters(QString::fromLocal8Bit(data, 10));
xmlWriter->writeEndElement();
xmlWriter->writeEndElement();
xmlWriter->writeEndDocument();
}
else
{
this->displayOnConsole("TM socket *** " + socketStates.at(tmEchoBridgeSocket->state()) );
}
}
void TMEchoBridge::sendTMPacket(TMPacketToRead *tmPacketToRead)
{
QByteArray ccsdsArray;
if (tmEchoBridgeSocket->state() == QAbstractSocket::ConnectedState)
{
ccsdsArray.append("<Event>");
ccsdsArray.append("<EventDate>");
ccsdsArray.append("</EventDate>");
ccsdsArray.append("<EventTime>");
ccsdsArray.append("</EventTime>");
ccsdsArray.append("<EventBinary>");
ccsdsArray.append(QByteArray::fromRawData( (char*) tmPacketToRead->Value, tmPacketToRead->size).toHex());
ccsdsArray.append("</EventBinary>");
ccsdsArray.append("</Event>");
tmEchoBridgeSocket->write(ccsdsArray);
tmEchoBridgeSocket->flush();
totalOfBytes = totalOfBytes + tmPacketToRead->size;
totalOfPackets = totalOfPackets + 1;
label_totalOfBytes->setText("Number of TM bytes sent: " + QString::number(totalOfBytes));
label_totalOfPackets->setText("Number of TM packets sent: " + QString::number(totalOfPackets));
}
else
{
totalOfPacketsDropped = totalOfPacketsDropped + 1;
label_totalOfPacketsDropped->setText("Number of TM packets dropped: " + QString::number(totalOfPacketsDropped));
}
}
void TMEchoBridge::sendTMPacketLESIA(TMPacketToRead *tmPacketToRead)
{
QByteArray ccsdsArray;
if (tmEchoBridgeSocket->state() == QAbstractSocket::ConnectedState)
{
ccsdsArray.append("<Event>");
ccsdsArray.append("<EventDate>");
ccsdsArray.append("</EventDate>");
ccsdsArray.append("<EventTime>");
ccsdsArray.append("</EventTime>");
ccsdsArray.append("<EventBinary>");
ccsdsArray.append(QByteArray::fromRawData( (char*) &tmPacketToRead->Value[4], tmPacketToRead->size-4).toHex());
ccsdsArray.append("</EventBinary>");
ccsdsArray.append("</Event>");
tmEchoBridgeSocket->write(ccsdsArray);
tmEchoBridgeSocket->flush();
totalOfBytes = totalOfBytes + tmPacketToRead->size;
totalOfPackets = totalOfPackets + 1;
label_totalOfBytes->setText("Number of TM bytes sent: " + QString::number(totalOfBytes));
label_totalOfPackets->setText("Number of TM packets sent: " + QString::number(totalOfPackets));
}
else
{
totalOfPacketsDropped = totalOfPacketsDropped + 1;
label_totalOfPacketsDropped->setText("Number of TM packets dropped: " + QString::number(totalOfPacketsDropped));
}
}
void TMEchoBridge::clearConsole()
{
this->console->clear();
}
void TMEchoBridge::resetTMStatistics()
{
label_totalOfBytes->setText("Number of TM bytes sent: -");
label_totalOfPackets->setText("Number of TM packets sent: -");
label_totalOfPacketsDropped->setText("Number of TM packets dropped: -");
totalOfBytes = 0;
totalOfPackets = 0;
totalOfPacketsDropped = 0;
}