HG_REPOSITORIES/LPP/INSTRUMENTATION/SocExplorerPlugins Commit - r20:d09469239955

Sync

Jeandet Alexis -

r20:d09469239955 default

parent child

Context file:

r20:d09469239955

Collapse all files

spwplugin/SpwTcpPacketServer/spwtcppacketserver.cpp +60 -4

@@ -21,6 +21,8
21	----------------------------------------------------------------------------*/	21	----------------------------------------------------------------------------*/
22	#include "spwtcppacketserver.h"	22	#include "spwtcppacketserver.h"
23	#include "ui_spwtcppacketserver.h"	23	#include "ui_spwtcppacketserver.h"
		24	#include <QNetworkInterface>
		25	#include <QByteArray>
24		26
25	SpwTcpPacketServer::SpwTcpPacketServer(QWidget *parent) :	27	SpwTcpPacketServer::SpwTcpPacketServer(QWidget *parent) :
26	QWidget(parent),	28	QWidget(parent),
@@ -30,6 +32,8 SpwTcpPacketServer::SpwTcpPacketServer(Q
30	this->p_bridge = NULL;	32	this->p_bridge = NULL;
31	this->p_server = new QTcpServer();	33	this->p_server = new QTcpServer();
32	connect(this->ui->startServeQpb,SIGNAL(clicked(bool)),SLOT(toggleServer()));	34	connect(this->ui->startServeQpb,SIGNAL(clicked(bool)),SLOT(toggleServer()));
		35	updateHostIP();
		36	this->ui->PortLineEdit->setText("2200");
33	}	37	}
34		38
35	SpwTcpPacketServer::~SpwTcpPacketServer()	39	SpwTcpPacketServer::~SpwTcpPacketServer()
@@ -49,20 +53,72 void SpwTcpPacketServer::setBridge(abstr
49		53
50	void SpwTcpPacketServer::pushPacket(char *packet, int size)	54	void SpwTcpPacketServer::pushPacket(char *packet, int size)
51	{	55	{
52		56	QByteArray data;
		57	char sizech[3];
		58	data.append((char)0);
		59	sizech[0]=size & 0x0FF;
		60	sizech[1]=(size>>8) & 0x0FF;
		61	sizech[2]=(size>>16) & 0x0FF;
		62	data.append(sizech,3);
		63	data.append(packet,size);
		64	for(int i=0;i<connectedClients.count();i++)
		65	{
		66	QTcpSocket* soc=connectedClients.at(i);
		67	if(soc->state()!=QAbstractSocket::ConnectedState)
		68	{
		69	connectedClients.removeAt(i);
		70	delete soc;
		71	}
		72	else
		73	{
		74	connectedClients.at(i)->write(data);
		75	}
		76	}
53	}	77	}
54		78
55	void SpwTcpPacketServer::toggleServer()	79	void SpwTcpPacketServer::toggleServer()
56	{	80	{
57	if(this->p_server->isListening())	81	if(this->p_server->isListening())
58	{	82	{
59	this->ui->startServeQpb->setText("Start Server");	83	disconnectServer();
60	this->p_server->close();
61	}	84	}
62	else	85	else
63	{	86	{
		87	connectServer();
		88	}
		89	}
		90
		91	void SpwTcpPacketServer::connectServer()
		92	{
64	this->p_server->listen(QHostAddress::Any,this->ui->PortLineEdit->text().toInt());	93	this->p_server->listen(QHostAddress::Any,this->ui->PortLineEdit->text().toInt());
65
66	this->ui->startServeQpb->setText("Stop Server");	94	this->ui->startServeQpb->setText("Stop Server");
67	}	95	}
		96
		97	void SpwTcpPacketServer::disconnectServer()
		98	{
		99	this->ui->startServeQpb->setText("Start Server");
		100	this->p_server->close();
68	}	101	}
		102
		103	void SpwTcpPacketServer::setServerPort(qint32 port)
		104	{
		105	this->ui->PortLineEdit->setText(QString("%1").arg(port));
		106	}
		107
		108	void SpwTcpPacketServer::newConnection()
		109	{
		110	this->connectedClients.append(this->p_server->nextPendingConnection());
		111	}
		112
		113	void SpwTcpPacketServer::updateHostIP()
		114	{
		115	QList<QHostAddress> list = QNetworkInterface::allAddresses();
		116
		117	for(int nIter=0; nIter<list.count(); nIter++)
		118
		119	{
		120	if(!list[nIter].isLoopback())
		121	if (list[nIter].protocol() == QAbstractSocket::IPv4Protocol )
		122	this->ui->IPLineEdit->setText(list[nIter].toString());
		123	}
		124	}

spwplugin/SpwTcpPacketServer/spwtcppacketserver.h +8 0

             #include <QWidget>
             #include <abstractspwbridge.h>
             #include <QTcpServer>
+            #include <QList>
+            #include <QTcpSocket>
             namespace Ui {
             class SpwTcpPacketServer;
             public slots:
                 void pushPacket(char* packet,int size);
                 void toggleServer();
+                void connectServer();
+                void disconnectServer();
+                void setServerPort(qint32 port);
+                void newConnection();
             private:
+                void updateHostIP();
                 Ui::SpwTcpPacketServer *ui;
                 abstractSpwBridge* p_bridge;
                 QTcpServer* p_server;
+                QList<QTcpSocket*> connectedClients;
             };
             #endif // SPWTCPPACKETSERVER_H

spwplugin/spwplugin.cpp +4 -1

                 this->bridgeSelector->addItem("STAR-Dundee Spw USB Brick");
                 connect(this->bridgeSelector,SIGNAL(currentIndexChanged(QString)),this,SLOT(bridgeSelectionChanged(QString)));
                 connect(((spwPyWrapper*)this->pyObject),SIGNAL(selectBridge(QString)),this,SLOT(selectBridge(QString)));
+                connect(((spwPyWrapper*)this->pyObject),SIGNAL(TCPServerConnect()),this->tcpServer,SLOT(connectServer()));
+                connect(((spwPyWrapper*)this->pyObject),SIGNAL(TCPServerDisconnect()),this->tcpServer,SLOT(disconnectServer()));
+                connect(((spwPyWrapper*)this->pyObject),SIGNAL(TCPServerSetPort(qint32)),this->tcpServer,SLOT(setServerPort(qint32)));
             }
                     connect(((spwPyWrapper*)this->pyObject),SIGNAL(connectBridge()),((stardundeeSPW_USB*)bridge),SLOT(connectBridge()));
                     connect(((spwPyWrapper*)this->pyObject),SIGNAL(disconnectBridge()),((stardundeeSPW_USB*)bridge),SLOT(disconnectBridge()));
                 }
+            }
             void spwplugin::selectBridge(const QString &text)
             {

spwplugin/spwplugin.h +1 -1

             signals:
             private:
+                SpwTcpPacketServer* tcpServer;
                 abstractSpwBridge* bridge;
-                SpwTcpPacketServer* tcpServer;
                 bool scanDone;
                 QTabWidget* mainTabWidgt;
                 QGroupBox* mainGroupBox;

spwplugin/spwpywrapper.h +4 -1

                 Q_OBJECT
             public:
                 explicit spwPyWrapper(socexplorerplugin *parent = 0);
             signals:
                 void selectBridge(const QString &bridgeName);
                 bool connectBridge();
                 void StarDundeeSetRmapAddress(const QString & address);
                 void StarDundeeSetRmapKey(const QString & key);
                 void StarDundeeSetRmapTimeout(const QString & timeout);
+                void TCPServerConnect();
+                void TCPServerDisconnect();
+                void TCPServerSetPort(qint32 port);
             public slots:
             };

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages