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

SpwPlugin:...

SpwPlugin: Another try to fix thread terminaison.

jeandet - - Load All Authors

File last commit:

r51:87980339c225 default


                r91:857534592b43

default

Download file

             incomingpacketparser.cpp
        
                    43 lines
            
             | 1.2 KiB
            
                | text/x-c
            
             |
                CppLexer
            
             / spwplugin / SpwTcpPacketServer / incomingpacketparser.cpp
          
                    History
                
                 |
                  Source
                 | Raw
                 |Copy content
                 |Copy permalink

        jeandet
    
Updated plugin version management....

              r51
            
      #include "incomingpacketparser.h"

      IncomingPacketParser::IncomingPacketParser(QObject *parent) :

          QObject(parent)

      {

          incompleteData = false;

          localDataArray.clear();

      }

      void IncomingPacketParser::processIncomingQByteArray(QByteArray incomingQByteArray)

      {

          int ccsdsSize;

          bool keepParsing;

          QByteArray tcPacket;

          keepParsing = true;

          localDataArray.append( incomingQByteArray );

          if (localDataArray.size() >= 4 )

          {

              while(keepParsing == true)

              {

                  ccsdsSize = ( (unsigned char) localDataArray[1] ) * 256 * 256

                          + ( (unsigned char) localDataArray[2] ) * 256

                          + ( (unsigned char) localDataArray[3] );

                  if (localDataArray.size() < (ccsdsSize+4) ) keepParsing = false;

                  else

                  {

                      tcPacket = QByteArray( localDataArray );

                      tcPacket.resize( ccsdsSize + 4 );

                      emit sendPacketUsingSpaceWire( tcPacket );

                      localDataArray.remove(0, ccsdsSize + 4);

                  }

                  if (localDataArray.size() >= 4 )    keepParsing = true;

                  else                                keepParsing = false;

              }

          }

      }

	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 Updated plugin version management....	r51	#include "incomingpacketparser.h"

		IncomingPacketParser::IncomingPacketParser(QObject *parent) :
		QObject(parent)
		{
		incompleteData = false;
		localDataArray.clear();
		}

		void IncomingPacketParser::processIncomingQByteArray(QByteArray incomingQByteArray)
		{
		int ccsdsSize;
		bool keepParsing;
		QByteArray tcPacket;

		keepParsing = true;

		localDataArray.append( incomingQByteArray );

		if (localDataArray.size() >= 4 )
		{
		while(keepParsing == true)
		{
		ccsdsSize = ( (unsigned char) localDataArray[1] ) * 256 * 256
		+ ( (unsigned char) localDataArray[2] ) * 256
		+ ( (unsigned char) localDataArray[3] );

		if (localDataArray.size() < (ccsdsSize+4) ) keepParsing = false;
		else
		{
		tcPacket = QByteArray( localDataArray );
		tcPacket.resize( ccsdsSize + 4 );

		emit sendPacketUsingSpaceWire( tcPacket );

		localDataArray.remove(0, ccsdsSize + 4);
		}

		if (localDataArray.size() >= 4 ) keepParsing = true;
		else keepParsing = false;
		}
		}
		}