HG_REPOSITORIES/LPP/INSTRUMENTATION/SOLO_LFR/LPPMON_PLUGINS_PAUL Files · rmapplugin/rmappluginpythonwrapper.cpp

Function added to the plugin to store packets in CSV format.

leroy - - Load All Authors

File last commit:

r19:7f565009af54 default


                r55:4ea52012da18

default

Download file

             rmappluginpythonwrapper.cpp
        
                    146 lines
            
             | 4.0 KiB
            
                | text/x-c
            
             |
                CppLexer
            
             / rmapplugin / rmappluginpythonwrapper.cpp
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        leroy
    
Initial commit: rmapplugin fully operational with the GRESB Ethernet/SpaceWire bridge.

              r0
            
      #include "rmappluginpythonwrapper.h"

      #include <math.h>

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
      #include <QApplication>

        leroy
    
Initial commit: rmapplugin fully operational with the GRESB Ethernet/SpaceWire bridge.

              r0
            
      rmappluginPythonWrapper::rmappluginPythonWrapper(QObject *parent) :

          genericPySysdriver(parent)

      {

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
          timer = new QTimer;

          timer->setSingleShot(true);

          connect(timer, SIGNAL(timeout()), this, SLOT(sendTC()));

          connect(this, SIGNAL(activateTCLoopSig()), this, SLOT(sendTCLoop()));

        leroy
    
Initial commit: rmapplugin fully operational with the GRESB Ethernet/SpaceWire bridge.

              r0
            
      }

        leroy
    
Last commit before installation on pc-alison

              r12
            
      QList<QVariant> rmappluginPythonWrapper::ReadSPW(unsigned int size) // size is not used

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
      {

          QList<QVariant> result;

        leroy
    
plugin updated, TM packet store reworked to store any TM continuously...

              r13
            
          TMPacketToRead *ccsdsPacket;

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
          if (!ccsdsPacketStore->isEmpty())

          {

              ccsdsPacket = ccsdsPacketStore->takeFirst();

        leroy
    
plugin updated, TM packet store reworked to store any TM continuously...

              r13
            
              for(unsigned int i = 0;i<ccsdsPacket->size;i++)

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
              {

        leroy
    
plugin updated, TM packet store reworked to store any TM continuously...

              r13
            
                  result.append((QVariant)ccsdsPacket->Value[i]);

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
              }

        leroy
    
plugin updated, TM packet store reworked to store any TM continuously...

              r13
            
              delete(ccsdsPacket);

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
          }

        leroy
    
waveform display added for the normal mode...

              r19
            
          emit nbPacketHasChanged(ccsdsPacketStore->size());

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
          return result;

      }

      void rmappluginPythonWrapper::WriteSPW(QList<int> dataList)

      {

          char targetLogicalAddress;

          char userApplication;

          unsigned int count;

          char *Value;

          unsigned char data[dataList.count()];

          for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char

          {

              data[i] = (unsigned char)dataList.at(i);

          }

          // read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters

          targetLogicalAddress = data[0];

          userApplication = data[3];

          count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON

          Value = (char*) &data[4];

          emit WriteSPWSig(Value, count, targetLogicalAddress, userApplication);

      }

      void rmappluginPythonWrapper::WriteSPWDelay(QList<int> dataList, unsigned int delay)

      {

          char targetLogicalAddress;

          char userApplication;

          unsigned int count;

          char *Value;

          TCPacketToSend *packet;

          unsigned char data[dataList.count()];

          for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char

          {

              data[i] = (unsigned char)dataList.at(i);

          }

          // read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters

          targetLogicalAddress = data[0];

          userApplication = data[3];

          count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON

          Value = (char*) &data[4];

          packet = new TCPacketToSend(Value, count, targetLogicalAddress, userApplication, delay);

          TCPacketStore.append(packet);

          emit(activateTCLoopSig());

      }

      void rmappluginPythonWrapper::processPacketStoreLater(unsigned int delay)

      {

          emit sendMessage(

                      "*** process packet store in " + QString::number(delay) + " ms"

                      );

          QTimer::singleShot(delay, this, SLOT(sendProcessPacketStoreNowSig()));

      }

      void rmappluginPythonWrapper::sendTCLoop()

      {

          unsigned int delay;

          if (!timer->isActive())

          {

              if (!TCPacketStore.isEmpty())

              {

                  delay = TCPacketStore.at(0)->delay;

                  timer->setInterval(delay);

                  timer->start();

              }

          }

      }

      void rmappluginPythonWrapper::sendTC()

      {

          TCPacketToSend *packet;

          unsigned int delay;

          packet = TCPacketStore.takeFirst();

          // the signal is connected with the option Qt::DirectConnection, thus it is processed immediately

          emit(WriteSPWSig(packet->Value, packet->count,packet->targetLogicalAddress, packet->userApplication));

          delete(packet);

          if (!TCPacketStore.isEmpty())

          {

              delay = TCPacketStore.at(0)->delay;

              timer->setInterval(delay);

              timer->start();

          }

      }

      void rmappluginPythonWrapper::processPacketStore()

      {

        leroy
    
infinite loop suppressed...

              r18
            
          emit ccsdsPacketIsAvailable(ccsdsPacketStore->at(0)->size);

        leroy
    
Plugin modified to allow the launch of interactiv tests from the python interpreter...

              r11
            
      }

      void rmappluginPythonWrapper::setTargetAddressValue(unsigned int address)

      {

          unsigned char newAddress;

          newAddress = (unsigned char) address;

          emit updateTargetAddress(newAddress);

      }

      void rmappluginPythonWrapper::setSourceAddressValue(unsigned int address)

      {

          unsigned char newAddress;

          newAddress = (unsigned char) address;

          emit updateSourceAddress(newAddress);

      }

      void rmappluginPythonWrapper::ProcessPendingEvents()

      {

          QCoreApplication::processEvents();

      }

        leroy
    
Last commit before installation on pc-alison

              r12

	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

leroy Initial commit: rmapplugin fully operational with the GRESB Ethernet/SpaceWire bridge.	r0	#include "rmappluginpythonwrapper.h"
		#include <math.h>
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	#include <QApplication>
leroy Initial commit: rmapplugin fully operational with the GRESB Ethernet/SpaceWire bridge.	r0
		rmappluginPythonWrapper::rmappluginPythonWrapper(QObject *parent) :
		genericPySysdriver(parent)
		{
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	timer = new QTimer;
		timer->setSingleShot(true);
		connect(timer, SIGNAL(timeout()), this, SLOT(sendTC()));
		connect(this, SIGNAL(activateTCLoopSig()), this, SLOT(sendTCLoop()));
leroy Initial commit: rmapplugin fully operational with the GRESB Ethernet/SpaceWire bridge.	r0	}

leroy Last commit before installation on pc-alison	r12	QList<QVariant> rmappluginPythonWrapper::ReadSPW(unsigned int size) // size is not used
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	{
		QList<QVariant> result;
leroy plugin updated, TM packet store reworked to store any TM continuously...	r13	TMPacketToRead *ccsdsPacket;
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11
		if (!ccsdsPacketStore->isEmpty())
		{
		ccsdsPacket = ccsdsPacketStore->takeFirst();
leroy plugin updated, TM packet store reworked to store any TM continuously...	r13	for(unsigned int i = 0;i<ccsdsPacket->size;i++)
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	{
leroy plugin updated, TM packet store reworked to store any TM continuously...	r13	result.append((QVariant)ccsdsPacket->Value[i]);
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	}
leroy plugin updated, TM packet store reworked to store any TM continuously...	r13	delete(ccsdsPacket);
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	}
leroy waveform display added for the normal mode...	r19	emit nbPacketHasChanged(ccsdsPacketStore->size());
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	return result;
		}

		void rmappluginPythonWrapper::WriteSPW(QList<int> dataList)
		{
		char targetLogicalAddress;
		char userApplication;
		unsigned int count;
		char *Value;

		unsigned char data[dataList.count()];

		for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char
		{
		data[i] = (unsigned char)dataList.at(i);
		}
		// read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters
		targetLogicalAddress = data[0];
		userApplication = data[3];

		count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON
		Value = (char*) &data[4];

		emit WriteSPWSig(Value, count, targetLogicalAddress, userApplication);
		}

		void rmappluginPythonWrapper::WriteSPWDelay(QList<int> dataList, unsigned int delay)
		{
		char targetLogicalAddress;
		char userApplication;
		unsigned int count;
		char *Value;
		TCPacketToSend *packet;

		unsigned char data[dataList.count()];

		for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char
		{
		data[i] = (unsigned char)dataList.at(i);
		}
		// read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters
		targetLogicalAddress = data[0];
		userApplication = data[3];

		count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON
		Value = (char*) &data[4];

		packet = new TCPacketToSend(Value, count, targetLogicalAddress, userApplication, delay);
		TCPacketStore.append(packet);

		emit(activateTCLoopSig());

		}

		void rmappluginPythonWrapper::processPacketStoreLater(unsigned int delay)
		{
		emit sendMessage(
		"*** process packet store in " + QString::number(delay) + " ms"
		);
		QTimer::singleShot(delay, this, SLOT(sendProcessPacketStoreNowSig()));
		}

		void rmappluginPythonWrapper::sendTCLoop()
		{
		unsigned int delay;

		if (!timer->isActive())
		{
		if (!TCPacketStore.isEmpty())
		{
		delay = TCPacketStore.at(0)->delay;
		timer->setInterval(delay);
		timer->start();
		}
		}
		}

		void rmappluginPythonWrapper::sendTC()
		{
		TCPacketToSend *packet;
		unsigned int delay;

		packet = TCPacketStore.takeFirst();
		// the signal is connected with the option Qt::DirectConnection, thus it is processed immediately
		emit(WriteSPWSig(packet->Value, packet->count,packet->targetLogicalAddress, packet->userApplication));
		delete(packet);
		if (!TCPacketStore.isEmpty())
		{
		delay = TCPacketStore.at(0)->delay;
		timer->setInterval(delay);
		timer->start();
		}
		}

		void rmappluginPythonWrapper::processPacketStore()
		{
leroy infinite loop suppressed...	r18	emit ccsdsPacketIsAvailable(ccsdsPacketStore->at(0)->size);
leroy Plugin modified to allow the launch of interactiv tests from the python interpreter...	r11	}

		void rmappluginPythonWrapper::setTargetAddressValue(unsigned int address)
		{
		unsigned char newAddress;
		newAddress = (unsigned char) address;
		emit updateTargetAddress(newAddress);
		}

		void rmappluginPythonWrapper::setSourceAddressValue(unsigned int address)
		{
		unsigned char newAddress;
		newAddress = (unsigned char) address;
		emit updateSourceAddress(newAddress);
		}

		void rmappluginPythonWrapper::ProcessPendingEvents()
		{
		QCoreApplication::processEvents();
		}
leroy Last commit before installation on pc-alison	r12