HG_REPOSITORIES/LPP/INSTRUMENTATION/SocExplorerPlugins Files · spwplugin/SpwTcpPacketServer/spwtcppacketserver.cpp

Fix some remaining mistakes.

katra - - Load All Authors

File last commit:

r55:16536c43bd1c default


                r55:16536c43bd1c

default

Download file

             spwtcppacketserver.cpp
        
                    231 lines
            
             | 7.0 KiB
            
                | text/x-c
            
             |
                CppLexer
            
             / spwplugin / SpwTcpPacketServer / spwtcppacketserver.cpp
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        jeandet
    
Added stop function to dsu3plugin...

              r14
            
      /*------------------------------------------------------------------------------

      --  This file is a part of the SocExplorer Software

      --  Copyright (C) 2014, Plasma Physics Laboratory - CNRS

      --

      --  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., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

      -------------------------------------------------------------------------------*/

      /*--                  Author : Alexis Jeandet

      --                     Mail : alexis.jeandet@member.fsf.org

      ----------------------------------------------------------------------------*/

        Jeandet Alexis
    
STAR-Dundee USB Brick driver ready for testing.

              r12
            
      #include "spwtcppacketserver.h"

      #include "ui_spwtcppacketserver.h"

        Jeandet Alexis
    
Sync

              r20
            
      #include <QNetworkInterface>

      #include <QByteArray>

        Jeandet Alexis
    
STAR-Dundee USB Brick driver ready for testing.

              r12
            
      SpwTcpPacketServer::SpwTcpPacketServer(QWidget *parent) :

          QWidget(parent),

          ui(new Ui::SpwTcpPacketServer)

      {

          ui->setupUi(this);

        Jeandet Alexis
    
Sync

              r18
            
          this->p_bridge = NULL;

          this->p_server = new QTcpServer();

        jeandet
    
Updated plugin version management....

              r51
            
          this->incomingPacketParser = new IncomingPacketParser();

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
        Jeandet Alexis
    
Sync

              r18
            
          connect(this->ui->startServeQpb,SIGNAL(clicked(bool)),SLOT(toggleServer()));

        Jeandet Alexis
    
Sync

              r20
            
          updateHostIP();

          this->ui->PortLineEdit->setText("2200");

        jeandet
    
Sync

              r21
            
          connect(this->p_server,SIGNAL(newConnection()),this,SLOT(newConnection()));

        paul
    
Functions added to the Python API:...

              r35
            
          resetStatististics();

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
        jeandet
    
Updated plugin version management....

              r51
            
          connect( this->incomingPacketParser, SIGNAL(sendPacketUsingSpaceWire(QByteArray)),

        katra
    
Fix some remaining mistakes.

              r55
            
                   this, SLOT(sendSPWPacketUsingSpaceWire(QByteArray)));

        Jeandet Alexis
    
STAR-Dundee USB Brick driver ready for testing.

              r12
            
      }

      SpwTcpPacketServer::~SpwTcpPacketServer()

      {

          delete ui;

      }

        Jeandet Alexis
    
Sync

              r18
            
      void SpwTcpPacketServer::setBridge(abstractSpwBridge *bridge)

      {

          if(this->p_bridge!=NULL)

          {

              disconnect(this,SLOT(pushPacket(char*,int)));

          }

          this->p_bridge = bridge;

          connect(bridge,SIGNAL(pushPacketOverTCP(char*,int)),SLOT(pushPacket(char*,int)));

      }

      void SpwTcpPacketServer::pushPacket(char *packet, int size)

      {

        Jeandet Alexis
    
Sync

              r20
            
          QByteArray data;

          char sizech[3];

          data.append((char)0);

          sizech[0]=size & 0x0FF;

          sizech[1]=(size>>8) & 0x0FF;

          sizech[2]=(size>>16) & 0x0FF;

          data.append(sizech,3);

          data.append(packet,size);

          for(int i=0;i<connectedClients.count();i++)

          {

              QTcpSocket* soc=connectedClients.at(i);

              if(soc->state()!=QAbstractSocket::ConnectedState)

              {

                  connectedClients.removeAt(i);

                  delete soc;

              }

              else

              {

                  connectedClients.at(i)->write(data);

        paul
    
Functions added to the Python API:...

              r35
            
                  onePacketTransmitted();

        Jeandet Alexis
    
Sync

              r20
            
              }

          }

        Jeandet Alexis
    
Started GR-ESB driver.

              r22
            
          free(packet);

        Jeandet Alexis
    
Sync

              r18
            
      }

      void SpwTcpPacketServer::toggleServer()

      {

          if(this->p_server->isListening())

          {

        Jeandet Alexis
    
Sync

              r20
            
             disconnectServer();

        Jeandet Alexis
    
Sync

              r18
            
          }

          else

          {

        Jeandet Alexis
    
Sync

              r20
            
              connectServer();

        Jeandet Alexis
    
Sync

              r18
            
          }

      }

        Jeandet Alexis
    
Sync

              r20
            
      void SpwTcpPacketServer::connectServer()

      {

          this->p_server->listen(QHostAddress::Any,this->ui->PortLineEdit->text().toInt());

          this->ui->startServeQpb->setText("Stop Server");

        paul
    
Functions added to the Python API:...

              r35
            
          resetStatististics();

        Jeandet Alexis
    
Sync

              r20
            
      }

      void SpwTcpPacketServer::disconnectServer()

      {

          this->ui->startServeQpb->setText("Start Server");

          this->p_server->close();

      }

      void SpwTcpPacketServer::setServerPort(qint32 port)

      {

          this->ui->PortLineEdit->setText(QString("%1").arg(port));

      }

        jeandet
    
Sync

              r21
            
      void SpwTcpPacketServer::setServerSetIP(QString ip)

      {

          this->ui->IPLineEdit->setText(ip);

      }

        Jeandet Alexis
    
Sync

              r20
            
      void SpwTcpPacketServer::newConnection()

      {

        Jeandet Alexis
    
Started GR-ESB driver.

              r22
            
          QTcpSocket* soc=this->p_server->nextPendingConnection();

          this->connectedClients.append(soc);

        jeandet
    
Sync

              r21
            
          this->ui->listWidget->addItem(this->connectedClients.last()->peerAddress().toString());

        jeandet
    
Updated plugin version management....

              r51
            
          connect(soc,SIGNAL(readyRead()),this,SLOT(parseIncomingPacket()));

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
      }

        jeandet
    
Updated plugin version management....

              r51
            
      void SpwTcpPacketServer::parseIncomingPacket()

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
      {

          for(int i=0;i<connectedClients.count();i++)

          {

              QTcpSocket* soc=connectedClients.at(i);

              if(soc->state()!=QAbstractSocket::ConnectedState)

              {

                  connectedClients.removeAt(i);

                  delete soc;

              }

              else

              {

                  if(soc->bytesAvailable()!=0)

                  {

                      do

                      {

                          QByteArray data = soc->readAll();

        jeandet
    
Updated plugin version management....

              r51
            
                          incomingPacketParser->processIncomingQByteArray( data );

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
                      }while(soc->bytesAvailable()!=0);

                  }

              }

          }

      }

        jeandet
    
Updated plugin version management....

              r51
            
      void SpwTcpPacketServer::sendSPWPacketUsingSpaceWire(QByteArray data)

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
      {

          onePacketReceived();

        paul
    
A lot of cleaning,...

              r50
            
          if(data[0]==(char)0)  // Protocole = 0 => Host to SpaceWire packet transmission

        paul
    
Functions added to the plugin to get the number of CCSDS packets...

              r40
            
          {

              int size = (data[1]*256*256) + (data[2]*256) + data[3];

              char* SPWpacket = (char*)malloc(size);

              memcpy(SPWpacket,data.data()+4,size);   // 4 bytes will be added later to the packet

              emit sendSPWPacket(SPWpacket,size);

          }

        Jeandet Alexis
    
Started GR-ESB driver.

              r22
            
      }

      void SpwTcpPacketServer::readReady()

      {

          for(int i=0;i<connectedClients.count();i++)

          {

              QTcpSocket* soc=connectedClients.at(i);

              if(soc->state()!=QAbstractSocket::ConnectedState)

              {

                  connectedClients.removeAt(i);

                  delete soc;

              }

              else

              {

                  if(soc->bytesAvailable()!=0)

                  {

                      do

                      {

                          QByteArray data = soc->readAll();

        paul
    
Functions added to the Python API:...

              r35
            
                          onePacketReceived();

        paul
    
A lot of cleaning,...

              r50
            
                          if(data[0]==(char)0)  // Protocole = 0 => Host to SpaceWire packet transmission

        Jeandet Alexis
    
Started GR-ESB driver.

              r22
            
                          {

                              int size = (data[1]*256*256) + (data[2]*256) + data[3];

                              char* SPWpacket = (char*)malloc(size);

        paul
    
Functions added to the Python API:...

              r35
            
                              memcpy(SPWpacket,data.data()+4,size);   // 4 bytes will be added later to the packet

        Jeandet Alexis
    
Started GR-ESB driver.

              r22
            
                              emit sendSPWPacket(SPWpacket,size);

                          }

                      }while(soc->bytesAvailable()!=0);

                  }

              }

          }

        Jeandet Alexis
    
Sync

              r20
            
      }

        paul
    
Functions added to the Python API:...

              r35
            
      void SpwTcpPacketServer::resetStatististics()

      {

          receivedPackets = 0;

          transmittedPackets = 0;

          this->ui->receivedPacketsNumber->display( QString::number(receivedPackets) );

          this->ui->transmittedPacketsNumber->display( QString::number(transmittedPackets) );

      }

        Jeandet Alexis
    
Sync

              r20
            
      void SpwTcpPacketServer::updateHostIP()

      {

          QList<QHostAddress> list = QNetworkInterface::allAddresses();

          for(int nIter=0; nIter<list.count(); nIter++)

          {

              if(!list[nIter].isLoopback())

                  if (list[nIter].protocol() == QAbstractSocket::IPv4Protocol )

                      this->ui->IPLineEdit->setText(list[nIter].toString());

          }

      }

        paul
    
Functions added to the Python API:...

              r35
            
      void SpwTcpPacketServer::onePacketReceived()

      {

          receivedPackets = receivedPackets + 1;

          this->ui->receivedPacketsNumber->display( QString::number(receivedPackets) );

      }

      void SpwTcpPacketServer::onePacketTransmitted()

      {

          transmittedPackets = transmittedPackets + 1;

          this->ui->transmittedPacketsNumber->display( QString::number(transmittedPackets) );

      }

	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

jeandet Added stop function to dsu3plugin...	r14	/*------------------------------------------------------------------------------
		-- This file is a part of the SocExplorer Software
		-- Copyright (C) 2014, Plasma Physics Laboratory - CNRS
		--
		-- 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
		-------------------------------------------------------------------------------*/
		/*-- Author : Alexis Jeandet
		-- Mail : alexis.jeandet@member.fsf.org
		----------------------------------------------------------------------------*/
Jeandet Alexis STAR-Dundee USB Brick driver ready for testing.	r12	#include "spwtcppacketserver.h"
		#include "ui_spwtcppacketserver.h"
Jeandet Alexis Sync	r20	#include <QNetworkInterface>
		#include <QByteArray>
Jeandet Alexis STAR-Dundee USB Brick driver ready for testing.	r12
		SpwTcpPacketServer::SpwTcpPacketServer(QWidget *parent) :
		QWidget(parent),
		ui(new Ui::SpwTcpPacketServer)
		{
		ui->setupUi(this);
Jeandet Alexis Sync	r18	this->p_bridge = NULL;
		this->p_server = new QTcpServer();
jeandet Updated plugin version management....	r51	this->incomingPacketParser = new IncomingPacketParser();
paul Functions added to the plugin to get the number of CCSDS packets...	r40
Jeandet Alexis Sync	r18	connect(this->ui->startServeQpb,SIGNAL(clicked(bool)),SLOT(toggleServer()));
Jeandet Alexis Sync	r20	updateHostIP();
		this->ui->PortLineEdit->setText("2200");
jeandet Sync	r21	connect(this->p_server,SIGNAL(newConnection()),this,SLOT(newConnection()));
paul Functions added to the Python API:...	r35	resetStatististics();
paul Functions added to the plugin to get the number of CCSDS packets...	r40
jeandet Updated plugin version management....	r51	connect( this->incomingPacketParser, SIGNAL(sendPacketUsingSpaceWire(QByteArray)),
katra Fix some remaining mistakes.	r55	this, SLOT(sendSPWPacketUsingSpaceWire(QByteArray)));
Jeandet Alexis STAR-Dundee USB Brick driver ready for testing.	r12	}

		SpwTcpPacketServer::~SpwTcpPacketServer()
		{
		delete ui;
		}
Jeandet Alexis Sync	r18
		void SpwTcpPacketServer::setBridge(abstractSpwBridge *bridge)
		{
		if(this->p_bridge!=NULL)
		{
		disconnect(this,SLOT(pushPacket(char*,int)));
		}
		this->p_bridge = bridge;
		connect(bridge,SIGNAL(pushPacketOverTCP(char,int)),SLOT(pushPacket(char,int)));
		}

		void SpwTcpPacketServer::pushPacket(char *packet, int size)
		{
Jeandet Alexis Sync	r20	QByteArray data;
		char sizech[3];
		data.append((char)0);
		sizech[0]=size & 0x0FF;
		sizech[1]=(size>>8) & 0x0FF;
		sizech[2]=(size>>16) & 0x0FF;
		data.append(sizech,3);
		data.append(packet,size);
		for(int i=0;i<connectedClients.count();i++)
		{
		QTcpSocket* soc=connectedClients.at(i);
		if(soc->state()!=QAbstractSocket::ConnectedState)
		{
		connectedClients.removeAt(i);
		delete soc;
		}
		else
		{
		connectedClients.at(i)->write(data);
paul Functions added to the Python API:...	r35	onePacketTransmitted();
Jeandet Alexis Sync	r20	}
		}
Jeandet Alexis Started GR-ESB driver.	r22	free(packet);
Jeandet Alexis Sync	r18	}

		void SpwTcpPacketServer::toggleServer()
		{
		if(this->p_server->isListening())
		{
Jeandet Alexis Sync	r20	disconnectServer();
Jeandet Alexis Sync	r18	}
		else
		{
Jeandet Alexis Sync	r20	connectServer();
Jeandet Alexis Sync	r18	}
		}
Jeandet Alexis Sync	r20
		void SpwTcpPacketServer::connectServer()
		{
		this->p_server->listen(QHostAddress::Any,this->ui->PortLineEdit->text().toInt());
		this->ui->startServeQpb->setText("Stop Server");
paul Functions added to the Python API:...	r35	resetStatististics();
Jeandet Alexis Sync	r20	}

		void SpwTcpPacketServer::disconnectServer()
		{
		this->ui->startServeQpb->setText("Start Server");
		this->p_server->close();
		}

		void SpwTcpPacketServer::setServerPort(qint32 port)
		{
		this->ui->PortLineEdit->setText(QString("%1").arg(port));
		}

jeandet Sync	r21	void SpwTcpPacketServer::setServerSetIP(QString ip)
		{
		this->ui->IPLineEdit->setText(ip);
		}

Jeandet Alexis Sync	r20	void SpwTcpPacketServer::newConnection()
		{
Jeandet Alexis Started GR-ESB driver.	r22	QTcpSocket* soc=this->p_server->nextPendingConnection();
		this->connectedClients.append(soc);
jeandet Sync	r21	this->ui->listWidget->addItem(this->connectedClients.last()->peerAddress().toString());
jeandet Updated plugin version management....	r51	connect(soc,SIGNAL(readyRead()),this,SLOT(parseIncomingPacket()));
paul Functions added to the plugin to get the number of CCSDS packets...	r40	}

jeandet Updated plugin version management....	r51	void SpwTcpPacketServer::parseIncomingPacket()
paul Functions added to the plugin to get the number of CCSDS packets...	r40	{
		for(int i=0;i<connectedClients.count();i++)
		{
		QTcpSocket* soc=connectedClients.at(i);
		if(soc->state()!=QAbstractSocket::ConnectedState)
		{
		connectedClients.removeAt(i);
		delete soc;
		}
		else
		{
		if(soc->bytesAvailable()!=0)
		{
		do
		{
		QByteArray data = soc->readAll();
jeandet Updated plugin version management....	r51	incomingPacketParser->processIncomingQByteArray( data );
paul Functions added to the plugin to get the number of CCSDS packets...	r40	}while(soc->bytesAvailable()!=0);
		}
		}
		}
		}

jeandet Updated plugin version management....	r51	void SpwTcpPacketServer::sendSPWPacketUsingSpaceWire(QByteArray data)
paul Functions added to the plugin to get the number of CCSDS packets...	r40	{
		onePacketReceived();
paul A lot of cleaning,...	r50	if(data[0]==(char)0) // Protocole = 0 => Host to SpaceWire packet transmission
paul Functions added to the plugin to get the number of CCSDS packets...	r40	{
		int size = (data[1]256256) + (data[2]*256) + data[3];
		char* SPWpacket = (char*)malloc(size);
		memcpy(SPWpacket,data.data()+4,size); // 4 bytes will be added later to the packet
		emit sendSPWPacket(SPWpacket,size);
		}
Jeandet Alexis Started GR-ESB driver.	r22	}

		void SpwTcpPacketServer::readReady()
		{
		for(int i=0;i<connectedClients.count();i++)
		{
		QTcpSocket* soc=connectedClients.at(i);
		if(soc->state()!=QAbstractSocket::ConnectedState)
		{
		connectedClients.removeAt(i);
		delete soc;
		}
		else
		{
		if(soc->bytesAvailable()!=0)
		{
		do
		{
		QByteArray data = soc->readAll();
paul Functions added to the Python API:...	r35	onePacketReceived();
paul A lot of cleaning,...	r50	if(data[0]==(char)0) // Protocole = 0 => Host to SpaceWire packet transmission
Jeandet Alexis Started GR-ESB driver.	r22	{
		int size = (data[1]256256) + (data[2]*256) + data[3];
		char* SPWpacket = (char*)malloc(size);
paul Functions added to the Python API:...	r35	memcpy(SPWpacket,data.data()+4,size); // 4 bytes will be added later to the packet
Jeandet Alexis Started GR-ESB driver.	r22	emit sendSPWPacket(SPWpacket,size);
		}
		}while(soc->bytesAvailable()!=0);
		}
		}
		}
Jeandet Alexis Sync	r20	}

paul Functions added to the Python API:...	r35	void SpwTcpPacketServer::resetStatististics()
		{
		receivedPackets = 0;
		transmittedPackets = 0;

		this->ui->receivedPacketsNumber->display( QString::number(receivedPackets) );
		this->ui->transmittedPacketsNumber->display( QString::number(transmittedPackets) );
		}

Jeandet Alexis Sync	r20	void SpwTcpPacketServer::updateHostIP()
		{
		QList<QHostAddress> list = QNetworkInterface::allAddresses();

		for(int nIter=0; nIter<list.count(); nIter++)
		{
		if(!list[nIter].isLoopback())
		if (list[nIter].protocol() == QAbstractSocket::IPv4Protocol )
		this->ui->IPLineEdit->setText(list[nIter].toString());
		}
		}
paul Functions added to the Python API:...	r35
		void SpwTcpPacketServer::onePacketReceived()
		{
		receivedPackets = receivedPackets + 1;

		this->ui->receivedPacketsNumber->display( QString::number(receivedPackets) );
		}

		void SpwTcpPacketServer::onePacketTransmitted()
		{
		transmittedPackets = transmittedPackets + 1;

		this->ui->transmittedPacketsNumber->display( QString::number(transmittedPackets) );
		}