HG_REPOSITORIES/LPP/INSTRUMENTATION/SOLO_LFR/LPPMON_PLUGINS_PAUL Commit - r9:bf36b48e03cd

class gresb fully functional, writeSPW function not tested yet

leroy -

r9:bf36b48e03cd default

parent child

Context file:

r9:bf36b48e03cd

PAULs_LPPMON_PLUGINS.pro.user +1 -1

             <?xml version="1.0" encoding="UTF-8"?>
             <!DOCTYPE QtCreatorProject>
-            <!-- Written by Qt Creator 2.4.1, 2012-12-10T13:26:06. -->
+            <!-- Written by Qt Creator 2.4.1, 2012-12-10T15:32:54. -->
             <qtcreator>
              <data>
               <variable>ProjectExplorer.Project.ActiveTarget</variable>
               <value type="int">0</value>
              </data>
              <data>
               <variable>ProjectExplorer.Project.EditorSettings</variable>
               <valuemap type="QVariantMap">
                <value type="bool" key="EditorConfiguration.AutoIndent">true</value>
                <value type="bool" key="EditorConfiguration.AutoSpacesForTabs">false</value>
                <valuemap type="QVariantMap" key="EditorConfiguration.CodeStyle.0">
                 <value type="QString" key="language">Cpp</value>
                 <valuemap type="QVariantMap" key="value">
                  <value type="QString" key="CurrentPreferences">CppGlobal</value>
                 </valuemap>
                </valuemap>
                <valuemap type="QVariantMap" key="EditorConfiguration.CodeStyle.1">
                 <value type="QString" key="language">QmlJS</value>
                 <valuemap type="QVariantMap" key="value">
                  <value type="QString" key="CurrentPreferences">QmlJSGlobal</value>
                 </valuemap>
                </valuemap>
                <value type="int" key="EditorConfiguration.CodeStyle.Count">2</value>
                <value type="QByteArray" key="EditorConfiguration.Codec">System</value>
                <value type="bool" key="EditorConfiguration.ConstrainTooltips">false</value>
                <value type="int" key="EditorConfiguration.IndentSize">4</value>
                <value type="bool" key="EditorConfiguration.MouseNavigation">true</value>
                <value type="int" key="EditorConfiguration.PaddingMode">1</value>
                <value type="bool" key="EditorConfiguration.ScrollWheelZooming">true</value>
                <value type="int" key="EditorConfiguration.SmartBackspaceBehavior">0</value>
                <value type="bool" key="EditorConfiguration.SpacesForTabs">true</value>
                <value type="int" key="EditorConfiguration.TabKeyBehavior">0</value>
                <value type="int" key="EditorConfiguration.TabSize">8</value>
                <value type="bool" key="EditorConfiguration.UseGlobal">true</value>
                <value type="int" key="EditorConfiguration.Utf8BomBehavior">1</value>
                <value type="bool" key="EditorConfiguration.addFinalNewLine">true</value>
                <value type="bool" key="EditorConfiguration.cleanIndentation">true</value>
                <value type="bool" key="EditorConfiguration.cleanWhitespace">true</value>
                <value type="bool" key="EditorConfiguration.inEntireDocument">false</value>
               </valuemap>
              </data>
              <data>
               <variable>ProjectExplorer.Project.PluginSettings</variable>
               <valuemap type="QVariantMap"/>
              </data>
              <data>
               <variable>ProjectExplorer.Project.Target.0</variable>
               <valuemap type="QVariantMap">
                <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Desktop</value>
                <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName">Desktop</value>
                <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.Target.DesktopTarget</value>
                <value type="int" key="ProjectExplorer.Target.ActiveBuildConfiguration">0</value>
                <value type="int" key="ProjectExplorer.Target.ActiveDeployConfiguration">0</value>
                <value type="int" key="ProjectExplorer.Target.ActiveRunConfiguration">0</value>
                <valuemap type="QVariantMap" key="ProjectExplorer.Target.BuildConfiguration.0">
                 <value type="QString" key="ProjectExplorer.BuildCOnfiguration.ToolChain">ProjectExplorer.ToolChain.Gcc:/usr/bin/g++.x86-linux-generic-elf-64bit./usr/bin/gdb</value>
                 <valuemap type="QVariantMap" key="ProjectExplorer.BuildConfiguration.BuildStepList.0">
                  <valuemap type="QVariantMap" key="ProjectExplorer.BuildStepList.Step.0">
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">qmake</value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">QtProjectManager.QMakeBuildStep</value>
                   <value type="bool" key="QtProjectManager.QMakeBuildStep.LinkQmlDebuggingLibrary">false</value>
                   <value type="bool" key="QtProjectManager.QMakeBuildStep.LinkQmlDebuggingLibraryAuto">true</value>
                   <value type="QString" key="QtProjectManager.QMakeBuildStep.QMakeArguments"></value>
                   <value type="bool" key="QtProjectManager.QMakeBuildStep.QMakeForced">false</value>
                  </valuemap>
                  <valuemap type="QVariantMap" key="ProjectExplorer.BuildStepList.Step.1">
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Make</value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.MakeStep</value>
                   <value type="bool" key="Qt4ProjectManager.MakeStep.Clean">false</value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeArguments"></value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeCommand"></value>
                  </valuemap>
                  <value type="int" key="ProjectExplorer.BuildStepList.StepsCount">2</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Build</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.BuildSteps.Build</value>
                 </valuemap>
                 <valuemap type="QVariantMap" key="ProjectExplorer.BuildConfiguration.BuildStepList.1">
                  <valuemap type="QVariantMap" key="ProjectExplorer.BuildStepList.Step.0">
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Make</value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.MakeStep</value>
                   <value type="bool" key="Qt4ProjectManager.MakeStep.Clean">true</value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeArguments">clean</value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeCommand"></value>
                  </valuemap>
                  <value type="int" key="ProjectExplorer.BuildStepList.StepsCount">1</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Clean</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.BuildSteps.Clean</value>
                 </valuemap>
                 <value type="int" key="ProjectExplorer.BuildConfiguration.BuildStepListCount">2</value>
                 <value type="bool" key="ProjectExplorer.BuildConfiguration.ClearSystemEnvironment">false</value>
                 <valuelist type="QVariantList" key="ProjectExplorer.BuildConfiguration.UserEnvironmentChanges"/>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Qt 4.8.2 in PATH (System) Release</value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.Qt4BuildConfiguration</value>
                 <value type="int" key="Qt4ProjectManager.Qt4BuildConfiguration.BuildConfiguration">0</value>
                 <value type="QString" key="Qt4ProjectManager.Qt4BuildConfiguration.BuildDirectory">/opt/LPPMON_PLUGINS_PAUL</value>
                 <value type="int" key="Qt4ProjectManager.Qt4BuildConfiguration.QtVersionId">1</value>
                 <value type="bool" key="Qt4ProjectManager.Qt4BuildConfiguration.UseShadowBuild">false</value>
                </valuemap>
                <valuemap type="QVariantMap" key="ProjectExplorer.Target.BuildConfiguration.1">
                 <value type="QString" key="ProjectExplorer.BuildCOnfiguration.ToolChain">ProjectExplorer.ToolChain.Gcc:/usr/bin/g++.x86-linux-generic-elf-64bit./usr/bin/gdb</value>
                 <valuemap type="QVariantMap" key="ProjectExplorer.BuildConfiguration.BuildStepList.0">
                  <valuemap type="QVariantMap" key="ProjectExplorer.BuildStepList.Step.0">
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">qmake</value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">QtProjectManager.QMakeBuildStep</value>
                   <value type="bool" key="QtProjectManager.QMakeBuildStep.LinkQmlDebuggingLibrary">false</value>
                   <value type="bool" key="QtProjectManager.QMakeBuildStep.LinkQmlDebuggingLibraryAuto">true</value>
                   <value type="QString" key="QtProjectManager.QMakeBuildStep.QMakeArguments"></value>
                   <value type="bool" key="QtProjectManager.QMakeBuildStep.QMakeForced">false</value>
                  </valuemap>
                  <valuemap type="QVariantMap" key="ProjectExplorer.BuildStepList.Step.1">
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Make</value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.MakeStep</value>
                   <value type="bool" key="Qt4ProjectManager.MakeStep.Clean">false</value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeArguments"></value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeCommand"></value>
                  </valuemap>
                  <value type="int" key="ProjectExplorer.BuildStepList.StepsCount">2</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Build</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.BuildSteps.Build</value>
                 </valuemap>
                 <valuemap type="QVariantMap" key="ProjectExplorer.BuildConfiguration.BuildStepList.1">
                  <valuemap type="QVariantMap" key="ProjectExplorer.BuildStepList.Step.0">
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Make</value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                   <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.MakeStep</value>
                   <value type="bool" key="Qt4ProjectManager.MakeStep.Clean">true</value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeArguments">clean</value>
                   <value type="QString" key="Qt4ProjectManager.MakeStep.MakeCommand"></value>
                  </valuemap>
                  <value type="int" key="ProjectExplorer.BuildStepList.StepsCount">1</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Clean</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.BuildSteps.Clean</value>
                 </valuemap>
                 <value type="int" key="ProjectExplorer.BuildConfiguration.BuildStepListCount">2</value>
                 <value type="bool" key="ProjectExplorer.BuildConfiguration.ClearSystemEnvironment">false</value>
                 <valuelist type="QVariantList" key="ProjectExplorer.BuildConfiguration.UserEnvironmentChanges"/>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Qt 4.8.2 in PATH (System) Debug</value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">Qt4ProjectManager.Qt4BuildConfiguration</value>
                 <value type="int" key="Qt4ProjectManager.Qt4BuildConfiguration.BuildConfiguration">2</value>
                 <value type="QString" key="Qt4ProjectManager.Qt4BuildConfiguration.BuildDirectory">/opt/LPPMON_PLUGINS_PAUL</value>
                 <value type="int" key="Qt4ProjectManager.Qt4BuildConfiguration.QtVersionId">1</value>
                 <value type="bool" key="Qt4ProjectManager.Qt4BuildConfiguration.UseShadowBuild">false</value>
                </valuemap>
                <value type="int" key="ProjectExplorer.Target.BuildConfigurationCount">2</value>
                <valuemap type="QVariantMap" key="ProjectExplorer.Target.DeployConfiguration.0">
                 <valuemap type="QVariantMap" key="ProjectExplorer.BuildConfiguration.BuildStepList.0">
                  <value type="int" key="ProjectExplorer.BuildStepList.StepsCount">0</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Deploy</value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                  <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.BuildSteps.Deploy</value>
                 </valuemap>
                 <value type="int" key="ProjectExplorer.BuildConfiguration.BuildStepListCount">1</value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">No deployment</value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.DefaultDeployConfiguration</value>
                </valuemap>
                <value type="int" key="ProjectExplorer.Target.DeployConfigurationCount">1</value>
                <valuemap type="QVariantMap" key="ProjectExplorer.Target.RunConfiguration.0">
                 <value type="bool" key="Analyzer.Project.UseGlobal">true</value>
                 <value type="bool" key="Analyzer.Project.UseGlobal">true</value>
                 <valuelist type="QVariantList" key="Analyzer.Valgrind.AddedSuppressionFiles"/>
                 <valuelist type="QVariantList" key="Analyzer.Valgrind.AddedSuppressionFiles"/>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.CollectBusEvents">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.CollectBusEvents">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.CollectSystime">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.CollectSystime">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.EnableBranchSim">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.EnableBranchSim">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.EnableCacheSim">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.EnableCacheSim">false</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.EnableEventToolTips">true</value>
                 <value type="bool" key="Analyzer.Valgrind.Callgrind.EnableEventToolTips">true</value>
                 <value type="double" key="Analyzer.Valgrind.Callgrind.MinimumCostRatio">0.01</value>
                 <value type="double" key="Analyzer.Valgrind.Callgrind.MinimumCostRatio">0.01</value>
                 <value type="double" key="Analyzer.Valgrind.Callgrind.VisualisationMinimumCostRatio">10</value>
                 <value type="double" key="Analyzer.Valgrind.Callgrind.VisualisationMinimumCostRatio">10</value>
                 <value type="bool" key="Analyzer.Valgrind.FilterExternalIssues">true</value>
                 <value type="bool" key="Analyzer.Valgrind.FilterExternalIssues">true</value>
                 <value type="int" key="Analyzer.Valgrind.NumCallers">25</value>
                 <value type="int" key="Analyzer.Valgrind.NumCallers">25</value>
                 <valuelist type="QVariantList" key="Analyzer.Valgrind.RemovedSuppressionFiles"/>
                 <valuelist type="QVariantList" key="Analyzer.Valgrind.RemovedSuppressionFiles"/>
                 <value type="bool" key="Analyzer.Valgrind.TrackOrigins">true</value>
                 <value type="bool" key="Analyzer.Valgrind.TrackOrigins">true</value>
                 <value type="QString" key="Analyzer.Valgrind.ValgrindExecutable">valgrind</value>
                 <value type="QString" key="Analyzer.Valgrind.ValgrindExecutable">valgrind</value>
                 <valuelist type="QVariantList" key="Analyzer.Valgrind.VisibleErrorKinds">
                  <value type="int">0</value>
                  <value type="int">1</value>
                  <value type="int">2</value>
                  <value type="int">3</value>
                  <value type="int">4</value>
                  <value type="int">5</value>
                  <value type="int">6</value>
                  <value type="int">7</value>
                  <value type="int">8</value>
                  <value type="int">9</value>
                  <value type="int">10</value>
                  <value type="int">11</value>
                  <value type="int">12</value>
                  <value type="int">13</value>
                  <value type="int">14</value>
                 </valuelist>
                 <valuelist type="QVariantList" key="Analyzer.Valgrind.VisibleErrorKinds">
                  <value type="int">0</value>
                  <value type="int">1</value>
                  <value type="int">2</value>
                  <value type="int">3</value>
                  <value type="int">4</value>
                  <value type="int">5</value>
                  <value type="int">6</value>
                  <value type="int">7</value>
                  <value type="int">8</value>
                  <value type="int">9</value>
                  <value type="int">10</value>
                  <value type="int">11</value>
                  <value type="int">12</value>
                  <value type="int">13</value>
                  <value type="int">14</value>
                 </valuelist>
                 <value type="QString" key="ProjectExplorer.CustomExecutableRunConfiguration.Arguments"></value>
                 <value type="int" key="ProjectExplorer.CustomExecutableRunConfiguration.BaseEnvironmentBase">2</value>
                 <value type="QString" key="ProjectExplorer.CustomExecutableRunConfiguration.Executable">lppmon</value>
                 <value type="bool" key="ProjectExplorer.CustomExecutableRunConfiguration.UseTerminal">false</value>
                 <valuelist type="QVariantList" key="ProjectExplorer.CustomExecutableRunConfiguration.UserEnvironmentChanges"/>
                 <value type="QString" key="ProjectExplorer.CustomExecutableRunConfiguration.WorkingDirectory">%{buildDir}</value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DefaultDisplayName">Run lppmon</value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.DisplayName"></value>
                 <value type="QString" key="ProjectExplorer.ProjectConfiguration.Id">ProjectExplorer.CustomExecutableRunConfiguration</value>
                 <value type="uint" key="RunConfiguration.QmlDebugServerPort">3768</value>
                 <value type="bool" key="RunConfiguration.UseCppDebugger">true</value>
                 <value type="bool" key="RunConfiguration.UseQmlDebugger">false</value>
                 <value type="bool" key="RunConfiguration.UseQmlDebuggerAuto">false</value>
                </valuemap>
                <value type="int" key="ProjectExplorer.Target.RunConfigurationCount">1</value>
               </valuemap>
              </data>
              <data>
               <variable>ProjectExplorer.Project.TargetCount</variable>
               <value type="int">1</value>
              </data>
              <data>
               <variable>ProjectExplorer.Project.Updater.EnvironmentId</variable>
               <value type="QString">{2e58a81f-9962-4bba-ae6b-760177f0656c}</value>
              </data>
              <data>
               <variable>ProjectExplorer.Project.Updater.FileVersion</variable>
               <value type="int">10</value>
              </data>
             </qtcreator>

rmapplugin/bridge.cpp 0 -1

             #include "bridge.h"
             bridge::bridge(QWidget *parent) :
                 QWidget(parent)
             {
                 // Packet receiver
                 rmapPacketSEMAPHORE = new QSemaphore;
                 ccsdsPacketSEMAPHORE = new QSemaphore;
                 rmapPacket = (char*) malloc(RMAP_MAX_PACKET_LENGTH);
                 ccsdsPacket = (unsigned char*) malloc(CCSDS_MAX_PACKET_LENGTH);
                 spwPacket = (char*) malloc( qMax(RMAP_MAX_PACKET_LENGTH, CCSDS_MAX_PACKET_LENGTH) );
                 bridge_LAYOUT = new QGridLayout;
             }
             bridge::~bridge()
             {
                 free(rmapPacket);
                 free(ccsdsPacket);
                 free(spwPacket);
             }
             unsigned int bridge::Write(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int remainingCount = count;
                 unsigned int iOffset = 0;
                 QString console_message;
                 char* data;
                 if(rmapPacketSEMAPHORE->available()!=0)
                 {
                     emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP request already running, WRITE access stopped");
                     return 1;
                 }
                 emit this->RMAP_write_reply_setText("reply to the write command required\nlast reply status: unavailable");
                 data = (char*) malloc(READ_WRITE_MAX_COUNTS*4);
                 emit appendToLog(QString("*** START *** WRITE ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
                 while (remainingCount > READ_WRITE_MAX_COUNTS)
                 {
                     for (int i = 0; i<READ_WRITE_MAX_COUNTS; i++)
                     {
                         data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
                         data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
                         data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
                         data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
                     }
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Write ")+ QString::number(READ_WRITE_MAX_COUNTS*4) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if(WriteBLOCK(data, READ_WRITE_MAX_COUNTS*4, address)==0)
                     {
                         emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
                         return 1;
                     }
                     remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
                     address = address + READ_WRITE_MAX_COUNTS * 4;
                     iOffset = iOffset + READ_WRITE_MAX_COUNTS;
                 }
                 if (remainingCount > 0)
                 {
                     for (unsigned int i = 0; i<remainingCount; i++)
                     {
                         data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
                         data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
                         data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
                         data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
                     }
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Write ")+ QString::number(remainingCount*4) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (WriteBLOCK(data, remainingCount*4, address)==0)
                     {
                         emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
                         return 1;
                     }
                 }
                 emit appendToLog(QString("*** STOP *** WRITE"));
                 free(data);
                 return count;
             }
             unsigned int bridge::Read(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int remainingCount = count;
                 unsigned int iOffset = 0;
                 QString console_message;
                 if(rmapPacketSEMAPHORE->available()!=0)
                 {
                     emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP request already running, READ access stopped");
                     return 1;
                 }
                 emit appendToLog(QString("*** START *** READ ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
                 while (remainingCount > READ_WRITE_MAX_COUNTS)
                 {
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Read ")+ QString::number(4*READ_WRITE_MAX_COUNTS) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (this->ReadBLOCK(READ_WRITE_MAX_COUNTS*4, address)==0)
                     {
                         emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP packet not received");
                         return 1;
                     }
                     for(int i=0;i<READ_WRITE_MAX_COUNTS;i++)
                     {
                         Value[i+iOffset] = (unsigned char) rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
                         for(int j=1;j<4;j++)
                         {
                             Value[i+iOffset]= ((unsigned char) (rmapPacket[i*4+j+RMAP_READ_REPLY_HEADER_LENGTH]))
                                     + Value[i+iOffset]*256;
                         }
                     }
                     remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
                     address = address + READ_WRITE_MAX_COUNTS * 4;
                     iOffset = iOffset + READ_WRITE_MAX_COUNTS;
                     rmapPacketSEMAPHORE->acquire();
                 }
                 if (remainingCount > 0)
                 {
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Read ")+ QString::number(4*remainingCount) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (this->ReadBLOCK(4*remainingCount, address)==0)
                     {
                         emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP packet not received");
                         return 1;
                     }
                     for(unsigned int i=0;i<remainingCount;i++)
                     {
                         Value[i+iOffset] = (unsigned char) rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
                         for(int j=1;j<4;j++)
                         {
                             Value[i+iOffset]= ((unsigned char)(rmapPacket[i*4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]*256;
                         }
                     }
                     rmapPacketSEMAPHORE->acquire();
                 }
                 emit appendToLog(QString("*** STOP *** READ "));
                 return count;
             }

rmapplugin/bridge.h +5 -5

             #ifndef BRIDGE_H
             #define BRIDGE_H
             #include <QWidget>
             #include <QSemaphore>
             #include <QGridLayout>
             #include "rmapoperations.h"
             class bridge : public QWidget
             {
                 Q_OBJECT
             public:
                 explicit bridge(QWidget *parent = 0);
                 ~bridge();
                 unsigned int Write(unsigned int *Value,unsigned int count,unsigned int address=0);
                 unsigned int Read(unsigned int *Value,unsigned int count,unsigned int address=0);
-                virtual unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
+                //virtual unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
                 virtual unsigned int WriteBLOCK(char *data,unsigned int nbBytes,unsigned int address=0) = 0;
                 virtual unsigned int ReadBLOCK(unsigned int nbBytes,unsigned int address=0) = 0;
-                virtual unsigned int getLinkStatus(unsigned char link) = 0;
+                //virtual unsigned int getLinkStatus(unsigned char link) = 0;
                 unsigned char rmapTargetLogicalAddress ;
                 unsigned char rmapSourceLogicalAddress ;
                 RMAP_command_codes commandCode;
                 QGridLayout *bridge_LAYOUT;
                 QSemaphore *rmapPacketSEMAPHORE;
                 QSemaphore *ccsdsPacketSEMAPHORE;
                 char *spwPacket;
                 char* rmapPacket;
                 unsigned char *ccsdsPacket;
             signals:
                 void sendMessage(QString message);
                 void isOpen(bool);
                 void RMAP_write_reply_setText(QString);
                 void appendToLog(QString);
                 void ccsdsPacketAvailable(unsigned char*, unsigned int);
             public slots:
-                unsigned int Open();
+                //unsigned int Open();
-                unsigned int Close();
+                //unsigned int Close();
-                virtual int receiveSPWPacket(unsigned char requestID) = 0;
+                //virtual int receiveSPWPacket(unsigned char requestID) = 0;
                 void commandCodeHasChanged(RMAP_command_codes code) {this->commandCode = code;}
                 void targetHasChanged(int target) {rmapTargetLogicalAddress = (unsigned char) target;}
                 void sourceHasChanged(int target) {rmapSourceLogicalAddress = (unsigned char) target;}
             private:
             };
             #endif // BRIDGE_H

rmapplugin/gresb.cpp +115 -3

             #include "gresb.h"
             #include <QTime>
             #include <QHostAddress>
             gresb::gresb(QWidget *parent) :
                 QWidget(parent)
             {
                 RMAPSend_SOCKET = new QTcpSocket;
                 RMAPReceive_SOCKET = new QTcpSocket;
                 GRESBStatusQuery_SOCKET = new QTcpSocket;
+                rmapPacketSEMAPHORE = new QSemaphore;
+                ccsdsPacketSEMAPHORE = new QSemaphore;
                 rmapPacket = (char*) malloc(RMAP_MAX_PACKET_LENGTH);
                 ccsdsPacket = (unsigned char*) malloc(CCSDS_MAX_PACKET_LENGTH);
                 spwPacket = (char*) malloc( qMax(RMAP_MAX_PACKET_LENGTH, CCSDS_MAX_PACKET_LENGTH) );
                 commandCode = invalid0; // initialization of the command code for the RMAP transfers
                 //*** QLABEL ***//
                 gresbBridgeIPLabel = new QLabel(tr("GRESB Bridge IP: "));
                 gresbVirtualLinkLabel = new QLabel(tr("GRESB Virtual Link: "));
                 spwLinkLabel = new QLabel(tr("GRESB SPW Link: "));
                 rmapSourceLogicalAddressLabel = new QLabel(tr("RMAP Source Logical Address: "));
                 rmapSendStateLabel = new QLabel(tr("RMAP Send Socket State: waiting for connection"));
                 rmapReceiveStateLabel = new QLabel(tr("RMAP Receive Socket State: waiting for connection"));
                 gresbStatusQueryLabel = new QLabel(tr("GRESB status query socket (port 3010): waiting for connection"));
                 gresbStatusQueryDialogLabel = new QLabel(tr("sockets opened but SpaceWire link not running"));
                 //*** SPINBOX ***//
                 gresbVirtualLinkSpinBox = new QSpinBox;
                 rmapSourceLogicalAddressSpinBox = new QSpinBox;
                 spwLinkSpinBox = new QSpinBox;;
                 gresbVirtualLinkSpinBox->setRange(0, 4);
                 gresbVirtualLinkSpinBox->setValue(1);
                 rmapSourceLogicalAddressSpinBox->setRange(0, 255);
                 rmapSourceLogicalAddressSpinBox->setValue(33);
                 spwLinkSpinBox->setRange(0, 2);
                 spwLinkSpinBox->setValue(0);
                 //*** QPUSHBUTTON ***//
                 gresbStatusQueryRetryButton = new QPushButton(tr("Retry"));
                 gresbStatusQueryAbortButton = new QPushButton(tr("Abort"));
                 //*** LAYOUT ***//
                 connectionLayout = new QGridLayout;
                 //*** MISC ***//
                 gresbStatusQueryDialog = new QDialog;
                 gresbBridgeIPDialogBox = new QIPDialogBox;
                 spwLinkStatusEnquiry = new gresbStatusEnquiry;
                 connectionLayout->addWidget(gresbBridgeIPLabel, 0, 0, 0);
                 connectionLayout->addWidget(gresbBridgeIPDialogBox, 0, 1, 0);
                 connectionLayout->addWidget(gresbVirtualLinkLabel, 1, 0, 0);
                 connectionLayout->addWidget(gresbVirtualLinkSpinBox, 1, 1, 0);
                 connectionLayout->addWidget(spwLinkLabel, 2, 0, 0);
                 connectionLayout->addWidget(spwLinkSpinBox, 2, 1, 0);
                 connectionLayout->addWidget(rmapSourceLogicalAddressLabel, 3, 0, 0);
                 connectionLayout->addWidget(rmapSourceLogicalAddressSpinBox, 3, 1, 0);
                 connectionLayout->addWidget(rmapSendStateLabel, 4, 0, 1, 2);
                 connectionLayout->addWidget(rmapReceiveStateLabel, 5, 0, 1, 2);
                 connectionLayout->addWidget(gresbStatusQueryLabel, 6, 0, 1, 2);
                 connectionLayout->setRowStretch(7, 1);
                 connectionLayout->setColumnStretch(2, 1);
                 // GRESB STATUS QUERY DIALOG
                 gresbStatusQueryDialogLayout = new QGridLayout;
                 gresbStatusQueryDialogLayout->addWidget(gresbStatusQueryDialogLabel, 0, 0, 1, 2);
                 gresbStatusQueryDialogLayout->addWidget(gresbStatusQueryRetryButton, 1, 0, 0);
                 gresbStatusQueryDialogLayout->addWidget(gresbStatusQueryAbortButton, 1, 1, 0);
                 gresbStatusQueryDialog->setLayout(gresbStatusQueryDialogLayout);
                 this->setLayout(connectionLayout);
+                connect(RMAPSend_SOCKET, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(RMAPSendConnectionState(QAbstractSocket::SocketState)));
+                connect(RMAPReceive_SOCKET, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(RMAPReceiveConnectionState(QAbstractSocket::SocketState)));
+                connect(GRESBStatusQuery_SOCKET, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(GRESBConnectionState(QAbstractSocket::SocketState)));
+                connect(gresbStatusQueryRetryButton, SIGNAL(clicked()), this, SLOT(reTestSPWLink()));
+                connect(spwLinkStatusEnquiry->readSPWStatusButton, SIGNAL(clicked()), this, SLOT(GRESBStatusQuery()));
+                connect(this->RMAPReceive_SOCKET, SIGNAL(readyRead()), this, SLOT(receiveSPWPacket()));
                 connect(gresbStatusQueryAbortButton, SIGNAL(clicked()), gresbStatusQueryDialog, SLOT(reject()));
                 connect(this->RMAPReceive_SOCKET, SIGNAL(readyRead()), this, SLOT(receiveSPWPacket()));
             }
             gresb::~gresb()
             {
                 free(rmapPacket);
                 free(ccsdsPacket);
                 free(spwPacket);
             }
             unsigned int gresb::Write(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int remainingCount = count;
                 unsigned int iOffset = 0;
                 QString console_message;
                 char* data;
                 if(rmapPacketSEMAPHORE->available()!=0)
                 {
                     emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP request already running, WRITE access stopped");
                     return 1;
                 }
                 RMAP_write_reply_setText("reply to the write command required\nlast reply status: unavailable");
                 data = (char*) malloc(READ_WRITE_MAX_COUNTS*4);
                 emit appendToLog(QString("*** START *** WRITE ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
                 while (remainingCount > READ_WRITE_MAX_COUNTS)
                 {
                     for (int i = 0; i<READ_WRITE_MAX_COUNTS; i++)
                     {
                         data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
                         data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
                         data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
                         data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
                     }
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Write ")+ QString::number(READ_WRITE_MAX_COUNTS*4) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if(WriteBLOCK(data, READ_WRITE_MAX_COUNTS*4, address)==0)
                     {
                         emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
                         return 1;
                     }
                     remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
                     address = address + READ_WRITE_MAX_COUNTS * 4;
                     iOffset = iOffset + READ_WRITE_MAX_COUNTS;
                 }
                 if (remainingCount > 0)
                 {
                     for (unsigned int i = 0; i<remainingCount; i++)
                     {
                         data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
                         data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
                         data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
                         data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
                     }
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Write ")+ QString::number(remainingCount*4) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (WriteBLOCK(data, remainingCount*4, address)==0)
                     {
                         emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
                         return 1;
                     }
                 }
                 emit appendToLog(QString("*** STOP *** WRITE"));
                 free(data);
                 return count;
             }
             unsigned int gresb::Read(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int remainingCount = count;
                 unsigned int iOffset = 0;
                 QString console_message;
                 if(rmapPacketSEMAPHORE->available()!=0)
                 {
                     emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP request already running, READ access stopped");
                     return 1;
                 }
                 emit appendToLog(QString("*** START *** READ ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
                 while (remainingCount > READ_WRITE_MAX_COUNTS)
                 {
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Read ")+ QString::number(4*READ_WRITE_MAX_COUNTS) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (ReadBLOCK(READ_WRITE_MAX_COUNTS*4, address)==0)
                     {
                         emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP packet not received");
                         return 1;
                     }
                     for(int i=0;i<READ_WRITE_MAX_COUNTS;i++)
                     {
                         Value[i+iOffset] = (unsigned char) rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
                         for(int j=1;j<4;j++)
                         {
                             Value[i+iOffset]= ((unsigned char)(rmapPacket[i*4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]*256;
                         }
                     }
                     remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
                     address = address + READ_WRITE_MAX_COUNTS * 4;
                     iOffset = iOffset + READ_WRITE_MAX_COUNTS;
                     acquireRMAPSemaphore();
                 }
                 if (remainingCount > 0)
                 {
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     emit appendToLog(console_message + QString("Read ")+ QString::number(4*remainingCount) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (ReadBLOCK(4*remainingCount, address)==0)
                     {
                         emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP packet not received");
                         return 1;
                     }
                     for(unsigned int i=0;i<remainingCount;i++)
                     {
                         Value[i+iOffset] = (unsigned char) rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
                         for(int j=1;j<4;j++)
                         {
                             Value[i+iOffset]= ((unsigned char)(rmapPacket[i*4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]*256;
                         }
                     }
                     acquireRMAPSemaphore();
                 }
                 emit appendToLog(QString("*** STOP *** READ "));
                 return count;
             }
             unsigned int gresb::WriteBLOCK(char *data, unsigned int nbBytes, unsigned int address)
             {
                 QTime RMAPTimeout;
                 RMAP *RMAPCommand;
                 int errorCode;
                 QString console_message;
                 if (GRESBStatusQueryRequest(LinkStatus, spwLinkSpinBox->value()) == 1)
                 {
                     this->Close();
                     return 1;
                 }
                 RMAPCommand = new RMAP(commandCode,
                                        rmapTargetLogicalAddress,
-                                       rmapSourceLogicalAddress,
+                                       rmapSourceLogicalAddressSpinBox->value(),
                                        address,
                                        nbBytes,
                                        data);
                 // SEND GRESB HEADER
                 RMAPSend_SOCKET->write((char*) ((void*) &RMAPCommand->GRESBHeader), 4);
                 // SEND SPACEWIRE PACKET HEADER
                 RMAPSend_SOCKET->write((char*) ((void*) &RMAPCommand->RMAPHeader), sizeof(RMAPCommand->RMAPHeader));
                 // SEND DATA
                 RMAPSend_SOCKET->write( data, nbBytes);
                 // SEND DATA CRC
                 RMAPSend_SOCKET->write((char*) ((void*) &RMAPCommand->dataCRC), 1);
                 RMAPTimeout.start();
                 while(RMAPSend_SOCKET->bytesToWrite() > 0)
                 {
                     RMAPSend_SOCKET->waitForBytesWritten(100);
                     if(RMAPTimeout.elapsed()>1000)
                     {
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** sending Write RMAP Command timeout");
                         return 0;
                     }
                 }
                 if ( (commandCode == writeSingle_noVer_Rep) | (commandCode == writeInc_noVer_Rep) |
                      (commandCode == writeSingle_ver_rep) | (commandCode == writeInc_ver_rep) )
                 {
                     // WAIT FOR THE RMAP REPLY PACKET
                     errorCode = receiveSPWPacket(1);
                     if (errorCode<=0)
                     {
                         emit appendToLog("WARNING === in function WriteBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
                         return 0;
                     }
                     if(rmapPacketSize != 8)
                      {
                         console_message.sprintf("WARNING === in function WRITE (with reply) of rmapplugin *** write reply format not compliant\n");
                         emit appendToLog(console_message);
                         return 0;
                      }
                     switch (rmapPacket[3]) // byte 4 is the status byte in the reply
                     {
                     case 0:
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 0 Successfull");
                         break;
                     case 1:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** General error code");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 1 General error code");
                         break;
                     case 2:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Unused RMAP packet type or command code");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 2 Unused RMAP packet type or command code");
                         break;
                     case 3:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid key");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 3 Invalid key");
                         break;
                     case 4:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid data CRC");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 4 Invalid data CRC");
                         break;
                     case 5:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Early EOP");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 5 Early EOP");
                         break;
                     case 6:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Too much data");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 6 Too much data");
                         break;
                     case 7:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** EEP");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 7 EEP");
                         break;
                     case 8:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Reserved");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 8 Reserved");
                         break;
                     case 9:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Verify buffer overrun");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 9 Verify buffer overrun");
                         break;
                     case 10:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** RMAP command not implemented or not authorised");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 10 RMAP command not implemented or not authorised");
                         break;
                     case 11:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** RMW data length error");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 11 RMAP RMW data length error");
                         break;
                     case 12:
                         emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid target logical address");
                         RMAP_write_reply_setText("reply to the write command required\nlast reply status: 12 Invalid target logical address");
                         break;
                     }
                     acquireRMAPSemaphore();
                 }
                 return nbBytes;
             }
             unsigned int gresb::ReadBLOCK(unsigned int nbBytes, unsigned int address)
             {
                 int errorCode;
                 RMAP *RMAPCommand;
                 QTime RMAPTimeout;
                 unsigned int dataLength;
                 if (GRESBStatusQueryRequest(LinkStatus, spwLinkSpinBox->value()) == 1)
                 {
                     this->Close();
                     return 1;
                 }
                 if (nbBytes > 4)
                 {
                     RMAPCommand = new RMAP(read_Inc,
                                            rmapTargetLogicalAddress,
-                                           rmapSourceLogicalAddress,
+                                           rmapSourceLogicalAddressSpinBox->value(),
                                            address,
                                            nbBytes,
                                            NULL);
                 }
                 else
                 {
                     RMAPCommand = new RMAP(read_Single,
                                            rmapTargetLogicalAddress,
-                                           rmapSourceLogicalAddress,
+                                           rmapSourceLogicalAddressSpinBox->value(),
                                            address,
                                            nbBytes,
                                            NULL);
                 }
                 // SEND THE GRESB HEADER FOR THE RMAP READ COMMAND
                 RMAPSend_SOCKET->write((char*) ((void*) &RMAPCommand->GRESBHeader), 4);
                 // SEND THE SPACEWIRE PACKET FOR THE RMAP READ COMMAND
                 RMAPSend_SOCKET->write((char*) ((void*) &RMAPCommand->RMAPHeader), sizeof(RMAPCommand->RMAPHeader));
                 RMAPSend_SOCKET->waitForBytesWritten(100);
                 RMAPTimeout.start();
                 // write timeout
                 while(RMAPSend_SOCKET->bytesToWrite() > 0)
                 {
                     RMAPSend_SOCKET->waitForBytesWritten(100);
                     if(RMAPTimeout.elapsed()>1000)
                     {
                         emit appendToLog("WARNING === in function READ of rmapplugin *** sending Read RMAP Command timeout\n");
                         return 0;
                     }
                 }
                 // RECEIVE THE INCOMING RMAP PACKET
                 errorCode = receiveSPWPacket(1); // request ID 1 is for RMAP packet
                 if (errorCode<=0)
                 {
                     emit appendToLog("WARNING === in function ReadBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
                     return 0;
                 }
                 dataLength = rmapPacketSize - RMAP_READ_REPLY_HEADER_LENGTH - RMAP_DATA_CRC_LENGTH;
                 if(dataLength != nbBytes)
                  {
                     emit appendToLog("WARNING === in function READ of rmapplugin *** number of data received ("
                                 +QString::number(dataLength)
                                 +") not equal to number of data requested ("
                                 +QString::number(READ_WRITE_MAX_COUNTS*4)
                                 +")");
                     return 0;
                  }
                 return dataLength;
             }
             unsigned int gresb::WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication)
             {
                 char protocoleIdentifier = 0x02;
                 char reserved = 0x00;
                 char gresbProtocole = 0x00;
                 unsigned char size[3];
                 unsigned int spwPacketSize = count + 4;
                 QTime SPWTimeout;
                 if (count>248)
                 {
                     appendToLog("WARNING === in function WRITE of rmapplugin *** CCSDS packet size > 248 bytes\n");
                     return 1;
                 }
                 appendToLog(QString("*** START *** Send CCSDS packet of ")+ QString::number(count) + QString(" byte(s)"));
                 if (GRESBStatusQueryRequest(LinkStatus, spwLinkSpinBox->value()) == 1)
                 {
                     this->Close();
                     appendToLog("WARNING === in function WRITE of rmapplugin *** SPW link not running\n");
                     return 1;
                 }
                 // SEND GRESB HEADER
                 size[0] = (unsigned char) ((unsigned int) spwPacketSize>>16);
                 size[1] = (unsigned char) ((unsigned int) spwPacketSize>>8);
                 size[2] = (unsigned char) ((unsigned int) spwPacketSize);
                 RMAPSend_SOCKET->write(&gresbProtocole, 1);
                 RMAPSend_SOCKET->write((char*) size, 3);
                 // SEND SPW HEADER
                 RMAPSend_SOCKET->write(&targetLogicalAddress, 1);
                 RMAPSend_SOCKET->write(&protocoleIdentifier, 1);
                 RMAPSend_SOCKET->write(&reserved, 1);
                 RMAPSend_SOCKET->write(&userApplication, 1);
                 // SEND CCSDS PACKET
                 RMAPSend_SOCKET->write(Value, count);
                 SPWTimeout.start();
                 while(RMAPSend_SOCKET->bytesToWrite() > 0)
                 {
                     RMAPSend_SOCKET->waitForBytesWritten(100);
                     if(SPWTimeout.elapsed()>1000)
                     {
                         appendToLog("WARNING === in function WRITE of rmapplugin *** sending CCSDS packet timeout\n");
                         return 1;
                     }
                 }
                 appendToLog(QString("*** CCSDS packet sent"));
                 return count;
             }
             int gresb::receiveSPWPacket(unsigned char requestID) // SLOT
             {
                 QTime spwPacketReceiverTimeout;
                 // GRESB HEADER
                 char RES_TR_EP; // 6 bits REserved + 1 bit TRuncated + 1 bit EP error end of packet
                 unsigned char packetLength2;
                 unsigned char packetLength1;
                 unsigned char packetLength0;
                 unsigned int packetLength;
                 if (requestID==1)
                 {
                     if (rmapPacketSEMAPHORE->available()) return rmapPacketSize;
                 }
                 RMAPReceive_SOCKET->blockSignals(1); // block the signals of the socket during packet reception
                 // READ THE GRESB HEADER OF THE INCOMING PACKET
                 spwPacketReceiverTimeout.start();
                 while(RMAPReceive_SOCKET->bytesAvailable() < 4)
                 {
                     RMAPReceive_SOCKET->waitForReadyRead(100);
                     if(spwPacketReceiverTimeout.elapsed()>1000) return -1; // ERROR === read GRSEB header TIMEOUT
                 }
                 RMAPReceive_SOCKET->read(&RES_TR_EP, 1);
                 RMAPReceive_SOCKET->read( (char*) &packetLength2, 1);
                 RMAPReceive_SOCKET->read( (char*) &packetLength1, 1);
                 RMAPReceive_SOCKET->read( (char*) &packetLength0, 1);
                 packetLength = (packetLength2<<16) + (packetLength1<<8) + (packetLength0);
                 spwPacket = (char*) malloc(packetLength);
                 // READ THE SPW PACKET
                 while(RMAPReceive_SOCKET->bytesAvailable() < packetLength)
                 {
                     RMAPReceive_SOCKET->waitForReadyRead(100);
                     if(spwPacketReceiverTimeout.elapsed()>1000) return -2; // ERROR === read SPW packet TIMEOUT
                 }
                 RMAPReceive_SOCKET->read( spwPacket, packetLength );
                 RMAPReceive_SOCKET->blockSignals(0);
                 switch(spwPacket[1]) // byte 1 is the protocole identifier in the SPW packet
                 {
                 case 1: // 0x01 is the protocole identifier for RMAP packets
                     if (rmapPacketSEMAPHORE->available()!=0) return -3; // ERROR === previous RMAP packet not processed yet
                     for(unsigned int i=0; i<packetLength; i++) rmapPacket[i] = spwPacket[i];
                     rmapPacketSize = packetLength;
                     rmapPacketSEMAPHORE->release();
                     //emit sendMessage("RMAP packet of size " + QString::number(packetLength) + " received");
                     return packetLength;
                 case 2: // 0x02 is the protocole identifier for CCSDS packets
                     if (ccsdsPacketSEMAPHORE->available()!=0) return -4; // ERROR === previous CCSDS packet not processed yet
                     for(unsigned int i=0; i<packetLength; i++) ccsdsPacket[i] = spwPacket[i];
                     ccsdsPacketSize = packetLength;
                     ccsdsPacketSEMAPHORE->release();
                     emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
                     return packetLength;
                 }
                 return 0;
             }
             void gresb::Open() // SLOT
             {
                 bool spwRunning = true;
                 RMAPSend_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getGRESBIP()),
 + gresbVirtualLinkSpinBox->value()*2,
                                                 QIODevice::WriteOnly);
                 RMAPReceive_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getGRESBIP()),
 + gresbVirtualLinkSpinBox->value()*2+1,
                                                    QIODevice::ReadOnly);
                 GRESBStatusQuery_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getGRESBIP()),
 ,
                                                         QIODevice::ReadWrite);
                 GRESBStatusQuery_SOCKET->waitForConnected(10000);
                 RMAPReceive_SOCKET->readAll();  // read all remaining data from the reception socket
                 // initialize SPW packet semaphores
                 while (rmapPacketSEMAPHORE->available()!=0) rmapPacketSEMAPHORE->acquire();
                 while (ccsdsPacketSEMAPHORE->available()!=0) ccsdsPacketSEMAPHORE->acquire();
                 if (GRESBStatusQueryRequest(LinkStatus, spwLinkSpinBox->value()) != 0)
                 {
                     spwRunning = gresbStatusQueryDialog->exec();
                 }
                 if (spwRunning == false) this->Close();
                 else
                 {
                     emit appendToLog(QString("SpaceWire running on virtual link ")+ QString::number(spwLinkSpinBox->value()));
                     emit isOpen(true);
                 }
             }
             void gresb::Close() // SLOT
             {
                 RMAPSend_SOCKET->disconnectFromHost();
                 RMAPReceive_SOCKET->disconnectFromHost();
                 GRESBStatusQuery_SOCKET->disconnectFromHost();
                 emit isOpen(false);
             }
             int gresb::GRESBStatusQuery() // SLOT
             {
                 GRESBStatusQueryRequest(LinkStatus, 0);
                 GRESBStatusQueryRequest(LinkStatus, 1);
                 GRESBStatusQueryRequest(LinkStatus, 2);
                 GRESBStatusQueryRequest(LinkStatistics, 0);
                 GRESBStatusQueryRequest(LinkStatistics, 1);
                 GRESBStatusQueryRequest(LinkStatistics, 2);
                 return 0;
             }
             int gresb::GRESBStatusQueryRequest(GresbStatusQueryOption option, char link)
             {
                 gresb_status_query_t statusQueryCommand;
                 gresb_link_status_reply_t linkStatusReply;
                 gresb_link_statistics_reply_t linkStatisticsReply;
                 QTime statusQueryTimeout;
                 QString console_message;
                 statusQueryCommand.protocolIdentifier = (char) 0x02;
                 statusQueryCommand.reserved1 = (char) 0x00;
                 statusQueryCommand.reserved0 = (char) 0x00;
                 statusQueryCommand.option = (char) option;
                 statusQueryCommand.value3 = (char) 0x00;
                 statusQueryCommand.value2 = (char) 0x00;
                 statusQueryCommand.value1 = (char) 0x00;
                 statusQueryCommand.value0 = (char) link;
                 GRESBStatusQuery_SOCKET->write((char*) ((void*) &statusQueryCommand), sizeof(statusQueryCommand));
                 GRESBStatusQuery_SOCKET->flush();
                 GRESBStatusQuery_SOCKET->waitForBytesWritten(1000);
                 statusQueryTimeout.start();
                 while(GRESBStatusQuery_SOCKET->bytesToWrite() > 0)
                 {
                     GRESBStatusQuery_SOCKET->waitForBytesWritten(100);
                     if(statusQueryTimeout.elapsed()>1000)
                     {
                         emit appendToLog("WARNING === in function GRESBStatusQueryRequest of rmapplugin *** sending StatusQueryCommand timeout");
                         return 1;
                     }
                 }
                 switch (option)
                 {
                 case LinkStatus:
                 {
                     statusQueryTimeout.start();
                     while(GRESBStatusQuery_SOCKET->bytesAvailable() < (int) sizeof(linkStatusReply))
                     {
                         GRESBStatusQuery_SOCKET->waitForReadyRead(100);
                         if(statusQueryTimeout.elapsed()>1000)
                         {
                             console_message.sprintf("GRESBStatusQueryRequest / LinkStatus => error timeout bytesAvailable()\n");
                             emit appendToLog(console_message);
                             return 1;
                         }
                     }
                     GRESBStatusQuery_SOCKET->read((char*) ((void*) &linkStatusReply), (int) sizeof(linkStatusReply));
                     console_message.sprintf("%x", linkStatusReply.byte0);
                     spwLinkStatusEnquiry->statusQueryTable->item(0, link)->setText(console_message);
                     console_message.sprintf("%d", linkStatusReply.byte1);
                     spwLinkStatusEnquiry->statusQueryTable->item(1, link)->setText(console_message);
                     if (linkStatusReply.byte0 == 0) return 1;
                     break;
                 }
                 case LinkStatistics:
                 {
                     statusQueryTimeout.start();
                     while(GRESBStatusQuery_SOCKET->bytesAvailable() < (int) sizeof(linkStatisticsReply))
                     {
                         GRESBStatusQuery_SOCKET->waitForReadyRead(100);
                         if(statusQueryTimeout.elapsed()>1000)
                         {
                             console_message.sprintf("GRESBStatusQueryRequest / LinkStatistics => error timeout bytesAvailable()\n");
                             emit appendToLog(console_message);
                             return 1;
                         }
                     }
                     GRESBStatusQuery_SOCKET->read((char*) ((void*) &linkStatisticsReply), sizeof(linkStatisticsReply));
                     /*console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.sizeOfDataTransmitted));
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(9, link)->setText(console_message);
                     console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfPacketsTransmitted));
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(8, link)->setText(console_message);
                     console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfTruncatedPacketsReceived));
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(6, link)->setText(console_message);
                     console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfPacketsWithEEPReceived));
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(5, link)->setText(console_message);
                     console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.sizeOfDataReceived));
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(4, link)->setText(console_message);
                     console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfPacketsReceived));
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(3, link)->setText(console_message);*/
                     break;
                 }
                 case NodeAddressStatistics:
                 {
                     break;
                 }
                 case GetRoute:
                 {
                     break;
                 }
                 }
                 return 0;
             }
             void gresb::processCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size) // SLOT
             {
                 QString message;
                 unsigned int fine_time_value = 0;
                 fine_time_value = ((unsigned int) ccsdsPacket[7]<<24)
                         + ((unsigned int) ccsdsPacket[6]<<16)
                         + ((unsigned int) ccsdsPacket[5]<<8)
                         + ((unsigned int) ccsdsPacket[4]);
                 message.append(QTime::currentTime().toString() +":" + QString::number(QTime::currentTime().msec()) + ": ");
                 message.append("size "
                                + QString::number(size)
                                +" *** header "
                                + QString::number(ccsdsPacket[0], 16)
                                + " "
                                + QString::number(ccsdsPacket[1], 16)
                                + " "
                                + QString::number(ccsdsPacket[2], 16)
                                + " "
                                + QString::number(ccsdsPacket[3], 16)
                                + " *** coarse time "
                                + QString::number(fine_time_value));
                                //+ QString::number(ccsdsPacket[4], 16)
                                //+" "
                                //+ QString::number(ccsdsPacket[5], 16)
                                //+" "
                                //+ QString::number(ccsdsPacket[6], 16)
                                //+" "
                                //+ QString::number(ccsdsPacket[7], 16));
                 ccsdsPacketSEMAPHORE->acquire();
                 emit sendMessage(message);
             }
+            void gresb::reTestSPWLink() // SLOT
+            {
+                if (GRESBStatusQueryRequest(LinkStatus, spwLinkSpinBox->value()) == 0)
+                {
+                    gresbStatusQueryDialog->accept();
+                }
+            }
+            void gresb::RMAPSendConnectionState(QAbstractSocket::SocketState socketState) // SLOT
+            {
+                rmapSendStateLabel->setText("");
+                QString socketMessage = "RMAP Send Socket State: ";
+                switch(socketState)
+                {
+                case QAbstractSocket::UnconnectedState :
+                    socketMessage.append("0 => Unconnected");
+                    break;
+                case 1:
+                    socketMessage.append("1 => HostLookup");
+                    break;
+                case 2:
+                    socketMessage.append("2 => Connecting");
+                    break;
+                case 3:
+                    socketMessage.append("3 => Connected");
+                    break;
+                case 4:
+                    socketMessage.append("4 => Bound");
+                    break;
+                case 5:
+                    socketMessage.append("5 => Closing");
+                    break;
+                case 6:
+                    socketMessage.append("6 => Listening");
+                    break;
+                }
+                rmapSendStateLabel->setText(socketMessage);
+                emit appendToLog(socketMessage);
+            }
+            void gresb::RMAPReceiveConnectionState(QAbstractSocket::SocketState socketState) // SLOT
+            {
+                rmapReceiveStateLabel->setText("");
+                QString socketMessage = "RMAP Receive Socket State: ";
+                switch(socketState)
+                {
+                case QAbstractSocket::UnconnectedState :
+                    socketMessage.append("0 => Unconnected");
+                    break;
+                case 1:
+                    socketMessage.append("1 => HostLookup");
+                    break;
+                case 2:
+                    socketMessage.append("2 => Connecting");
+                    break;
+                case 3:
+                    socketMessage.append("3 => Connected");
+                    break;
+                case 4:
+                    socketMessage.append("4 => Bound");
+                    break;
+                case 5:
+                    socketMessage.append("5 => Closing");
+                    break;
+                case 6:
+                    socketMessage.append("6 => Listening");
+                    break;
+                }
+                rmapReceiveStateLabel->setText(socketMessage);
+                emit appendToLog(socketMessage);
+            }
+            void gresb::GRESBConnectionState(QAbstractSocket::SocketState socketState) // SLOT
+            {
+                gresbStatusQueryLabel->setText("");
+                QString socketMessage = "GRESB status query socket (port 3010): ";
+                switch(socketState)
+                {
+                case QAbstractSocket::UnconnectedState :
+                    socketMessage.append("0 => Unconnected");
+                    break;
+                case 1:
+                    socketMessage.append("1 => HostLookup");
+                    break;
+                case 2:
+                    socketMessage.append("2 => Connecting");
+                    break;
+                case 3:
+                    socketMessage.append("3 => Connected");
+                    break;
+                case 4:
+                    socketMessage.append("4 => Bound");
+                    break;
+                case 5:
+                    socketMessage.append("5 => Closing");
+                    break;
+                case 6:
+                    socketMessage.append("6 => Listening");
+                    break;
+                }
+                gresbStatusQueryLabel->setText(socketMessage);
+            }

rmapplugin/gresb.h +4 -2

             #ifndef GRESB_H
             #define GRESB_H
             #include <QWidget>
             #include <QLabel>
             #include <QPushButton>
             #include <QSpinBox>
             #include <QGridLayout>
             #include <QTcpSocket>
             #include <QDialog>
             #include <QSemaphore>
             #include "gresbstatusenquiry.h"
             #include "spwpacketreceiver.h"
             #include "rmapoperations.h"
             #include "qipdialogbox.h"
             class gresb : public QWidget
             {
                 Q_OBJECT
             public:
                 explicit gresb(QWidget *parent = 0);
                 ~gresb();
                 unsigned int Write(unsigned int *Value,unsigned int count,unsigned int address=0);
                 unsigned int Read(unsigned int *Value,unsigned int count,unsigned int address=0);
                 unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
-                //unsigned int getLinkStatus(unsigned char link);
             signals:
                 void sendMessage(QString message);
                 void isOpen(bool);
                 void RMAP_write_reply_setText(QString);
                 void appendToLog(QString);
                 void ccsdsPacketAvailable(unsigned char*, unsigned int);
             public slots:
                 void Open();
                 void Close();
                 int receiveSPWPacket(unsigned char requestID=0);
                 void processCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size);
+                void reTestSPWLink();
+                void RMAPSendConnectionState(QAbstractSocket::SocketState socketState);
+                void RMAPReceiveConnectionState(QAbstractSocket::SocketState socketState);
+                void GRESBConnectionState(QAbstractSocket::SocketState socketState);
                 void commandCodeHasChanged(RMAP_command_codes code) {this->commandCode = code;}
                 void targetHasChanged(int target) {rmapTargetLogicalAddress = (unsigned char) target;}
-                void sourceHasChanged(int target) {rmapSourceLogicalAddress = (unsigned char) target;}
             private slots:
                 int GRESBStatusQuery();
             private:
                 unsigned int WriteBLOCK(char *data,unsigned int nbBytes,unsigned int address=0);
                 unsigned int ReadBLOCK(unsigned int nbBytes,unsigned int address=0);
                 void acquireRMAPSemaphore() {rmapPacketSEMAPHORE->acquire();}
                 void acquireCCSDSSemaphore() {ccsdsPacketSEMAPHORE->acquire();}
                 int GRESBStatusQueryRequest(GresbStatusQueryOption option, char link);
                 unsigned char rmapTargetLogicalAddress ;
                 unsigned char rmapSourceLogicalAddress ;
                 RMAP_command_codes commandCode;
                 QPushButton *gresbStatusQueryRetryButton;
                 QPushButton *gresbStatusQueryAbortButton;
                 QLabel *gresbBridgeIPLabel;
                 QLabel *gresbVirtualLinkLabel;
                 QLabel *spwLinkLabel;
                 QLabel *rmapSourceLogicalAddressLabel;
                 QLabel *rmapSendStateLabel;
                 QLabel *rmapReceiveStateLabel;
                 QLabel *gresbStatusQueryLabel;
                 QLabel *gresbStatusQueryDialogLabel;
                 QDialog *gresbStatusQueryDialog;
                 QIPDialogBox* gresbBridgeIPDialogBox;
                 QSpinBox *gresbVirtualLinkSpinBox;
                 QSpinBox *spwLinkSpinBox;
                 QSpinBox *rmapSourceLogicalAddressSpinBox;
                 QGridLayout *connectionLayout;
                 QGridLayout *gresbStatusQueryDialogLayout;
                 QTcpSocket *RMAPSend_SOCKET;
                 QTcpSocket *RMAPReceive_SOCKET;
                 QTcpSocket *GRESBStatusQuery_SOCKET;
                 gresbStatusEnquiry* spwLinkStatusEnquiry;
                 // Packet receiver
                 QSemaphore *rmapPacketSEMAPHORE;
                 QSemaphore *ccsdsPacketSEMAPHORE;
                 char* rmapPacket;      // The buffer to receive RMAP READ packets
                 unsigned char *ccsdsPacket;
                 char *spwPacket;
                 unsigned int rmapPacketSize;
                 unsigned int ccsdsPacketSize;
             };
             #endif // GRESB_H

rmapplugin/rmapplugin.cpp +40 -677

This diff has been collapsed as it changes many lines, (717 lines changed) Show them Hide them
	@@ -1,923 +1,286
	1	/*------------------------------------------------------------------------------	1	/*------------------------------------------------------------------------------
	2	-- This file is a part of the LPPMON Software	2	-- This file is a part of the LPPMON Software
	3	-- Copyright (C) 2012, Laboratory of Plasma Physics - CNRS	3	-- Copyright (C) 2012, Laboratory of Plasma Physics - CNRS
	4	--	4	--
	5	-- This program is free software; you can redistribute it and/or modify	5	-- This program is free software; you can redistribute it and/or modify
	6	-- it under the terms of the GNU General Public License as published by	6	-- it under the terms of the GNU General Public License as published by
	7	-- the Free Software Foundation; either version 3 of the License, or	7	-- the Free Software Foundation; either version 3 of the License, or
	8	-- (at your option) any later version.	8	-- (at your option) any later version.
	9	--	9	--
	10	-- This program is distributed in the hope that it will be useful,	10	-- This program is distributed in the hope that it will be useful,
	11	-- but WITHOUT ANY WARRANTY; without even the implied warranty of	11	-- but WITHOUT ANY WARRANTY; without even the implied warranty of
	12	-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the	12	-- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	13	-- GNU General Public License for more details.	13	-- GNU General Public License for more details.
	14	--	14	--
	15	-- You should have received a copy of the GNU General Public License	15	-- You should have received a copy of the GNU General Public License
	16	-- along with this program; if not, write to the Free Software	16	-- along with this program; if not, write to the Free Software
	17	-- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA	17	-- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
	18	-------------------------------------------------------------------------------*/	18	-------------------------------------------------------------------------------*/
	19	/*-- Author : Paul LEROY	19	/*-- Author : Paul LEROY
	20	-- Mail : paul.leroy@lpp.polytechnique.fr	20	-- Mail : paul.leroy@lpp.polytechnique.fr
	21	----------------------------------------------------------------------------*/	21	----------------------------------------------------------------------------*/
	22	#include "rmapplugin.h"	22	#include "rmapplugin.h"
	23	#include <QHostAddress>	23	#include <QHostAddress>
	24	#include <QIODevice>	24	#include <QIODevice>
	25	#include <QApplication>	25	#include <QApplication>
	26	#include <rmappluginpythonwrapper.h>	26	#include <rmappluginpythonwrapper.h>
	27		27
	28	rmapplugin::rmapplugin(QWidget *parent)	28	rmapplugin::rmapplugin(QWidget *parent)
	29	:lppmonplugin(parent,false)	29	:lppmonplugin(parent,false)
	30	{	30	{
	31	this->UI = new rmapPluginUI();	31	this->UI = new rmapPluginUI();
	32	this->setWindowTitle(tr("RMAP and SPW Communication"));	32	this->setWindowTitle(tr("RMAP and SPW Communication"));
	33	this->setWidget((QWidget*)this->UI);	33	this->setWidget((QWidget*)this->UI);
	34	RMAPSend_SOCKET = new QTcpSocket;	34
	35	RMAPReceive_SOCKET = new QTcpSocket;
	36	GRESBStatusQuery_SOCKET = new QTcpSocket;
	37	spwPacketReceiverOBJECT = new spwpacketreceiver;
	38	spwPacketReceiverOBJECT->gresbReceptionSocket = RMAPReceive_SOCKET;
	39	timeCode = 0;	35	timeCode = 0;
	40	time_COARSE = 0;	36	time_COARSE = 0;
	41	time_FINE = 0;	37	time_FINE = 0;
	42	currentBridge = selectedBridgeIsUnknown;	38	currentBridge = selectedBridgeIsUnknown;
	43		39
	44	/Python wrapper/	40	/Python wrapper/
	45	this->pyObject = new rmappluginPythonWrapper();	41	this->pyObject = new rmappluginPythonWrapper();
	46	connect(this->pyObject,SIGNAL(ReadSig(uint,uint,uint)),this,SLOT(Read(uint,uint,uint)));	42	connect(this->pyObject,SIGNAL(ReadSig(uint,uint,uint)),this,SLOT(Read(uint,uint,uint)));
	47	connect(this->pyObject,SIGNAL(WriteSig(uint,uint,uint)),this,SLOT(Write(uint,uint,uint)));	43	connect(this->pyObject,SIGNAL(WriteSig(uint,uint,uint)),this,SLOT(Write(uint,uint,uint)));
	48	/==============/	44	/==============/
	49		45
	50	connect(UI->rmapOpenCommunicationButton, SIGNAL(clicked()), this, SLOT(openBridge()));	46	connect(UI->rmapOpenCommunicationButton, SIGNAL(clicked()), this, SLOT(openBridge()));
	51	connect(UI->rmapCloseCommunicationButton, SIGNAL(clicked()), this, SLOT(closeBridge()));	47	connect(UI->rmapCloseCommunicationButton, SIGNAL(clicked()), this, SLOT(closeBridge()));
	52	connect(RMAPSend_SOCKET, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(RMAPSendConnectionState(QAbstractSocket::SocketState)));
	53	connect(RMAPReceive_SOCKET, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(RMAPReceiveConnectionState(QAbstractSocket::SocketState)));
	54	connect(GRESBStatusQuery_SOCKET, SIGNAL(stateChanged(QAbstractSocket::SocketState)), this, SLOT(GRESBConnectionState(QAbstractSocket::SocketState)));
	55	connect(UI->gresbStatusQueryRetryButton, SIGNAL(clicked()), this, SLOT(reTestSPWLink()));
	56	connect(this->UI->spwLinkStatusEnquiry->readSPWStatusButton, SIGNAL(clicked()), this, SLOT(GRESBStatusQuery()));
	57	connect(this->RMAPReceive_SOCKET, SIGNAL(readyRead()), this->spwPacketReceiverOBJECT, SLOT(receiveSPWPacket()));
	58		48
	59	// CCSDS	49	// CCSDS
	60	connect(this->UI->sendCCSDSCommandButton, SIGNAL(clicked()), this, SLOT(sendCCSDS()));	50	connect(this->UI->sendCCSDSCommandButton, SIGNAL(clicked()), this, SLOT(sendCCSDS()));
	61	connect(this->UI->send_TC_LFR_UPDATE_TIME_Button, SIGNAL(clicked()), this, SLOT(send_TC_LFR_UPDATE_TIME()));	51	connect(this->UI->send_TC_LFR_UPDATE_TIME_Button, SIGNAL(clicked()), this, SLOT(send_TC_LFR_UPDATE_TIME()));
	62	connect(this->UI->reset_TC_LFR_UPDATE_TIME_Button, SIGNAL(clicked()), this, SLOT(reset_TC_LFR_UPDATE_TIME()));	52	connect(this->UI->reset_TC_LFR_UPDATE_TIME_Button, SIGNAL(clicked()), this, SLOT(reset_TC_LFR_UPDATE_TIME()));
	63		53
	64	// CONSOLE
	65	connect(this->spwPacketReceiverOBJECT, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
	66	connect(this->UI->starDundee, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
	67
	68	// spectralMAtricesDMASimulator	54	// spectralMAtricesDMASimulator
	69	connect(this->UI->spectralMatricesDMASimulator, SIGNAL(rmapplugginRead(uint,uint,uint)), this, SLOT(Read(uint,uint,uint)));	55	connect(this->UI->spectralMatricesDMASimulator, SIGNAL(rmapplugginRead(uint,uint,uint)), this, SLOT(Read(uint,uint,uint)));
	70	connect(this->UI->spectralMatricesDMASimulator, SIGNAL(rmapplugginWrite(uint,uint,uint)), this, SLOT(Write(uint,uint,uint)));	56	connect(this->UI->spectralMatricesDMASimulator, SIGNAL(rmapplugginWrite(uint,uint,uint)), this, SLOT(Write(uint,uint,uint)));
	71	connect(this->UI->spectralMatricesDMASimulator, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));	57	connect(this->UI->spectralMatricesDMASimulator, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
	72		58
	73	// GRESB	59	// GRESB
	74	connect(this, SIGNAL(~~gresbIsOpen~~(~~bool~~)), this, SLOT(~~gresbSelection~~(~~bool~~)));	60	connect(this->UI->gresbBridge, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
			61	connect(this->UI->gresbBridge, SIGNAL(isOpen(bool)), this, SLOT(activatePlugin(bool)));
			62	connect(this->UI->gresbBridge, SIGNAL(RMAP_write_reply_setText(QString)), this, SLOT(RMAP_write_reply_setText(QString)));
			63	connect(this->UI->gresbBridge, SIGNAL(appendToLog(QString)), this, SLOT(appendToLog(QString)));
	75		64
	76	// Star Dundee	65	// Star Dundee
	77	connect(this->UI->starDundee, SIGNAL(isOpen(~~bool~~)), this, SLOT(~~activatePluginViaStarDunde~~e(~~bool~~)));	66	connect(this->UI->starDundee, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
			67	connect(this->UI->starDundee, SIGNAL(isOpen(bool)), this, SLOT(activatePlugin(bool)));
	78	connect(this->UI->starDundee, SIGNAL(RMAP_write_reply_setText(QString)), this, SLOT(RMAP_write_reply_setText(QString)));	68	connect(this->UI->starDundee, SIGNAL(RMAP_write_reply_setText(QString)), this, SLOT(RMAP_write_reply_setText(QString)));
	79	connect(this->UI->starDundee, SIGNAL(appendToLog(QString)), this, SLOT(appendToLog(QString)));	69	connect(this->UI->starDundee, SIGNAL(appendToLog(QString)), this, SLOT(appendToLog(QString)));
	80		70
	81	connect(this->UI, SIGNAL(bridgeHasChanged(selectedBridge)), this, SLOT(bridgeHasChanged(selectedBridge)));	71	connect(this->UI, SIGNAL(bridgeHasChanged(selectedBridge)), this, SLOT(bridgeHasChanged(selectedBridge)));
	82	}	72	}
	83		73
	84	rmapplugin::~rmapplugin()	74	rmapplugin::~rmapplugin()
	85	{	75	{
	86	if (!RMAPSend_SOCKET->isOpen()) RMAPSend_SOCKET->disconnectFromHost();	76	if (!RMAPSend_SOCKET->isOpen()) RMAPSend_SOCKET->disconnectFromHost();
	87	if (!RMAPReceive_SOCKET->isOpen()) RMAPReceive_SOCKET->disconnectFromHost();	77	if (!RMAPReceive_SOCKET->isOpen()) RMAPReceive_SOCKET->disconnectFromHost();
	88	if (!GRESBStatusQuery_SOCKET->isOpen()) GRESBStatusQuery_SOCKET->disconnectFromHost();	78	if (!GRESBStatusQuery_SOCKET->isOpen()) GRESBStatusQuery_SOCKET->disconnectFromHost();
	89	}	79	}
	90		80
	91	unsigned int rmapplugin::Write(unsigned int *Value, unsigned int count, unsigned int address)	81	unsigned int rmapplugin::Write(unsigned int *Value, unsigned int count, unsigned int address)
	92	{	82	{
	93	unsigned int result;	83	unsigned int result;
	94	switch(currentBridge)	84	switch(currentBridge)
	95	{	85	{
	96	case selectedBridgeIsGRESB :	86	case selectedBridgeIsGRESB :
	97	result = Write~~GRESB~~(Value, count, address);	87	result = UI->gresbBridge->Write(Value, count, address);
	98	break;	88	break;
	99	case selectedBridgeIsStarDundee :	89	case selectedBridgeIsStarDundee :
	100	result = UI->starDundee->Write(Value, count, address);	90	result = UI->starDundee->Write(Value, count, address);
	101	break;	91	break;
	102	default:	92	default:
	103	result = 1;	93	result = 1;
	104	break;	94	break;
	105	}	95	}
	106	return result;	96	return result;
	107	}	97	}
	108		98
	109	unsigned int rmapplugin::Read(unsigned int *Value, unsigned int count, unsigned int address)	99	unsigned int rmapplugin::Read(unsigned int *Value, unsigned int count, unsigned int address)
	110	{	100	{
	111	unsigned int result;	101	unsigned int result;
	112	switch(currentBridge)	102	switch(currentBridge)
	113	{	103	{
	114	case selectedBridgeIsGRESB :	104	case selectedBridgeIsGRESB :
	115	result = Read~~GRESB~~(Value, count, address);	105	result = UI->gresbBridge->Read(Value, count, address);
	116	break;	106	break;
	117	case selectedBridgeIsStarDundee :	107	case selectedBridgeIsStarDundee :
	118	result = UI->starDundee->Read(Value, count, address);	108	result = UI->starDundee->Read(Value, count, address);
	119	break;	109	break;
	120	default:	110	default:
	121	result = 1;	111	result = 1;
	122	break;	112	break;
	123	}	113	}
	124	return result;	114	return result;
	125	}	115	}
	126		116
	127	unsigned int rmapplugin::WriteGRESB(unsigned int *Value, unsigned int count, unsigned int address)
	128	{
	129	unsigned int remainingCount = count;
	130	unsigned int iOffset = 0;
	131	QString console_message;
	132	char* data;
	133
	134	if(spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->available()!=0)
	135	{
	136	APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** RMAP request already running, WRITE access stopped");
	137	return 1;
	138	}
	139
	140	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: unavailable");
	141
	142	data = (char) malloc(READ_WRITE_MAX_COUNTS4);
	143
	144	APPENDTOLOG(QString("* START * WRITE ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
	145
	146	while (remainingCount > READ_WRITE_MAX_COUNTS)
	147	{
	148	for (int i = 0; i<READ_WRITE_MAX_COUNTS; i++)
	149	{
	150	data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
	151	data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
	152	data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
	153	data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
	154	}
	155
	156	console_message.sprintf("remainingCount: %d => ", remainingCount);
	157	APPENDTOLOG(console_message + QString("Write ")+ QString::number(READ_WRITE_MAX_COUNTS*4) + QString(" byte(s) @0x")+ QString::number(address,16));
	158
	159	if(WriteBLOCK(data, READ_WRITE_MAX_COUNTS*4, address)==0)
	160	{
	161	APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
	162	return 1;
	163	}
	164
	165	remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
	166	address = address + READ_WRITE_MAX_COUNTS * 4;
	167	iOffset = iOffset + READ_WRITE_MAX_COUNTS;
	168	}
	169
	170	if (remainingCount > 0)
	171	{
	172	for (unsigned int i = 0; i<remainingCount; i++)
	173	{
	174	data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
	175	data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
	176	data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
	177	data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
	178	}
	179
	180	console_message.sprintf("remainingCount: %d => ", remainingCount);
	181	APPENDTOLOG(console_message + QString("Write ")+ QString::number(remainingCount*4) + QString(" byte(s) @0x")+ QString::number(address,16));
	182
	183	if (WriteBLOCK(data, remainingCount*4, address)==0)
	184	{
	185	APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
	186	return 1;
	187	}
	188	}
	189
	190	APPENDTOLOG(QString("* STOP * WRITE"));
	191	free(data);
	192	return count;
	193	}
	194
	195	unsigned int rmapplugin::ReadGRESB(unsigned int *Value, unsigned int count, unsigned int address)
	196	{
	197	unsigned int remainingCount = count;
	198	unsigned int iOffset = 0;
	199	QString console_message;
	200
	201	if(spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->available()!=0)
	202	{
	203	APPENDTOLOG("WARNING === in function READ of rmapplugin *** RMAP request already running, READ access stopped");
	204	return 1;
	205	}
	206	APPENDTOLOG(QString("* START * READ ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
	207
	208	while (remainingCount > READ_WRITE_MAX_COUNTS)
	209	{
	210	console_message.sprintf("remainingCount: %d => ", remainingCount);
	211	APPENDTOLOG(console_message + QString("Read ")+ QString::number(4*READ_WRITE_MAX_COUNTS) + QString(" byte(s) @0x")+ QString::number(address,16));
	212
	213	if (ReadBLOCK(READ_WRITE_MAX_COUNTS*4, address)==0)
	214	{
	215	APPENDTOLOG("WARNING === in function READ of rmapplugin *** RMAP packet not received");
	216	return 1;
	217	}
	218
	219	for(int i=0;i<READ_WRITE_MAX_COUNTS;i++)
	220	{
	221	Value[i+iOffset] = (unsigned char) spwPacketReceiverOBJECT->rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
	222	for(int j=1;j<4;j++)
	223	{
	224	Value[i+iOffset]= ((unsigned char)(spwPacketReceiverOBJECT->rmapPacket[i4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]256;
	225	}
	226	}
	227
	228	remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
	229	address = address + READ_WRITE_MAX_COUNTS * 4;
	230	iOffset = iOffset + READ_WRITE_MAX_COUNTS;
	231	spwPacketReceiverOBJECT->acquireRMAPSemaphore();
	232	}
	233
	234	if (remainingCount > 0)
	235	{
	236	console_message.sprintf("remainingCount: %d => ", remainingCount);
	237	APPENDTOLOG(console_message + QString("Read ")+ QString::number(4*remainingCount) + QString(" byte(s) @0x")+ QString::number(address,16));
	238
	239	if (ReadBLOCK(4*remainingCount, address)==0)
	240	{
	241	APPENDTOLOG("WARNING === in function READ of rmapplugin *** RMAP packet not received");
	242	return 1;
	243	}
	244
	245	for(unsigned int i=0;i<remainingCount;i++)
	246	{
	247	Value[i+iOffset] = (unsigned char) spwPacketReceiverOBJECT->rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
	248	for(int j=1;j<4;j++)
	249	{
	250	Value[i+iOffset]= ((unsigned char)(spwPacketReceiverOBJECT->rmapPacket[i4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]256;
	251	}
	252	}
	253	spwPacketReceiverOBJECT->acquireRMAPSemaphore();
	254	}
	255
	256	APPENDTOLOG(QString("* STOP * READ "));
	257	return count;
	258	}
	259
	260	unsigned int rmapplugin::WriteBLOCK(char *data, unsigned int nbBytes, unsigned int address)
	261	{
	262	QTime RMAPTimeout;
	263	RMAP *RMAPCommand;
	264	int errorCode;
	265	QString console_message;
	266
	267	if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 1)
	268	{
	269	RMAP_DISCONNECT();
	270	return 1;
	271	}
	272
	273	RMAPCommand = new RMAP(UI->getCommandCode(),
	274	UI->rmapTargetLogicalAddressSpinBox->value(),
	275	UI->rmapSourceLogicalAddressSpinBox->value(),
	276	address,
	277	nbBytes,
	278	data);
	279
	280	// SEND GRESB HEADER
	281	RMAPSend_SOCKET->write((char) ((void) &RMAPCommand->GRESBHeader), 4);
	282	// SEND SPACEWIRE PACKET HEADER
	283	RMAPSend_SOCKET->write((char) ((void) &RMAPCommand->RMAPHeader), sizeof(RMAPCommand->RMAPHeader));
	284	// SEND DATA
	285	RMAPSend_SOCKET->write( data, nbBytes);
	286	// SEND DATA CRC
	287	RMAPSend_SOCKET->write((char) ((void) &RMAPCommand->dataCRC), 1);
	288	RMAPTimeout.start();
	289	while(RMAPSend_SOCKET->bytesToWrite() > 0)
	290	{
	291	RMAPSend_SOCKET->waitForBytesWritten(100);
	292	if(RMAPTimeout.elapsed()>1000)
	293	{
	294	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** sending Write RMAP Command timeout");
	295	return 0;
	296	}
	297	}
	298
	299	if (UI->RMAP_write_reply->isChecked())
	300	{
	301	// WAIT FOR THE RMAP REPLY PACKET
	302	errorCode = spwPacketReceiverOBJECT->receiveSPWPacket(1);
	303	if (errorCode<=0)
	304	{
	305	APPENDTOLOG("WARNING === in function WriteBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
	306	return 0;
	307	}
	308	if(spwPacketReceiverOBJECT->rmapPacketSize != 8)
	309	{
	310	console_message.sprintf("WARNING === in function WRITE (with reply) of rmapplugin *** write reply format not compliant\n");
	311	APPENDTOLOG(console_message);
	312	return 0;
	313	}
	314	switch (spwPacketReceiverOBJECT->rmapPacket[3]) // byte 4 is the status byte in the reply
	315	{
	316	case 0:
	317	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 0 Successfull");
	318	break;
	319	case 1:
	320	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** General error code");
	321	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 1 General error code");
	322	break;
	323	case 2:
	324	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Unused RMAP packet type or command code");
	325	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 2 Unused RMAP packet type or command code");
	326	break;
	327	case 3:
	328	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid key");
	329	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 3 Invalid key");
	330	break;
	331	case 4:
	332	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid data CRC");
	333	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 4 Invalid data CRC");
	334	break;
	335	case 5:
	336	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Early EOP");
	337	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 5 Early EOP");
	338	break;
	339	case 6:
	340	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Too much data");
	341	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 6 Too much data");
	342	break;
	343	case 7:
	344	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** EEP");
	345	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 7 EEP");
	346	break;
	347	case 8:
	348	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Reserved");
	349	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 8 Reserved");
	350	break;
	351	case 9:
	352	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Verify buffer overrun");
	353	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 9 Verify buffer overrun");
	354	break;
	355	case 10:
	356	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** RMAP command not implemented or not authorised");
	357	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 10 RMAP command not implemented or not authorised");
	358	break;
	359	case 11:
	360	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** RMW data length error");
	361	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 11 RMAP RMW data length error");
	362	break;
	363	case 12:
	364	APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid target logical address");
	365	UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 12 Invalid target logical address");
	366	break;
	367	}
	368	spwPacketReceiverOBJECT->acquireRMAPSemaphore();
	369	}
	370	return nbBytes;
	371	}
	372
	373	unsigned int rmapplugin::ReadBLOCK(unsigned int nbBytes, unsigned int address)
	374	{
	375	int errorCode;
	376	RMAP *RMAPCommand;
	377	QTime RMAPTimeout;
	378	unsigned int dataLength;
	379	if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 1)
	380	{
	381	RMAP_DISCONNECT();
	382	return 1;
	383	}
	384
	385	if (nbBytes > 4)
	386	{
	387	RMAPCommand = new RMAP(read_Inc,
	388	UI->rmapTargetLogicalAddressSpinBox->value(),
	389	UI->rmapSourceLogicalAddressSpinBox->value(),
	390	address,
	391	nbBytes,
	392	NULL);
	393	}
	394	else
	395	{
	396	RMAPCommand = new RMAP(read_Single,
	397	UI->rmapTargetLogicalAddressSpinBox->value(),
	398	UI->rmapSourceLogicalAddressSpinBox->value(),
	399	address,
	400	nbBytes,
	401	NULL);
	402	}
	403
	404	// SEND THE GRESB HEADER FOR THE RMAP READ COMMAND
	405	RMAPSend_SOCKET->write((char) ((void) &RMAPCommand->GRESBHeader), 4);
	406	// SEND THE SPACEWIRE PACKET FOR THE RMAP READ COMMAND
	407	RMAPSend_SOCKET->write((char) ((void) &RMAPCommand->RMAPHeader), sizeof(RMAPCommand->RMAPHeader));
	408	RMAPSend_SOCKET->waitForBytesWritten(100);
	409	RMAPTimeout.start();
	410	// write timeout
	411	while(RMAPSend_SOCKET->bytesToWrite() > 0)
	412	{
	413	RMAPSend_SOCKET->waitForBytesWritten(100);
	414	if(RMAPTimeout.elapsed()>1000)
	415	{
	416	APPENDTOLOG("WARNING === in function READ of rmapplugin *** sending Read RMAP Command timeout\n");
	417	return 0;
	418	}
	419	}
	420
	421	// RECEIVE THE INCOMING RMAP PACKET
	422	errorCode = spwPacketReceiverOBJECT->receiveSPWPacket(1); // request ID 1 is for RMAP packet
	423	if (errorCode<=0)
	424	{
	425	APPENDTOLOG("WARNING === in function ReadBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
	426	return 0;
	427	}
	428	dataLength = spwPacketReceiverOBJECT->rmapPacketSize - RMAP_READ_REPLY_HEADER_LENGTH - RMAP_DATA_CRC_LENGTH;
	429	if(dataLength != nbBytes)
	430	{
	431	APPENDTOLOG("WARNING === in function READ of rmapplugin *** number of data received ("
	432	+QString::number(dataLength)
	433	+") not equal to number of data requested ("
	434	+QString::number(READ_WRITE_MAX_COUNTS*4)
	435	+")");
	436	return 0;
	437	}
	438	return dataLength;
	439	}
	440
	441	////////	117	////////
	442	// SLOTS	118	// SLOTS
	443		119
	444	unsigned int rmapplugin::WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication) // SLOT	120	unsigned int rmapplugin::WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication) // SLOT
	445	{	121	{
	446	unsigned int result;	122	unsigned int result;
	447	switch(currentBridge)	123	switch(currentBridge)
	448	{	124	{
	449	case selectedBridgeIsGRESB :	125	case selectedBridgeIsGRESB :
	450	result = WriteSPW~~GRESB~~(Value, count, targetLogicalAddress, userApplication);	126	result = UI->gresbBridge->WriteSPW(Value, count, targetLogicalAddress, userApplication);
	451	break;	127	break;
	452	case selectedBridgeIsStarDundee :	128	case selectedBridgeIsStarDundee :
	453	result = UI->starDundee->WriteSPW(Value, count, targetLogicalAddress, userApplication);	129	result = UI->starDundee->WriteSPW(Value, count, targetLogicalAddress, userApplication);
	454	break;	130	break;
	455	default:	131	default:
	456	result = 1;	132	result = 1;
	457	break;	133	break;
	458	}	134	}
	459	return result;	135	return result;
	460	}	136	}
	461		137
	462	unsigned int rmapplugin::WriteSPWGRESB(char *Value, unsigned int count, char targetLogicalAddress, char userApplication)
	463	{
	464	char protocoleIdentifier = 0x02;
	465	char reserved = 0x00;
	466	char gresbProtocole = 0x00;
	467	unsigned char size[3];
	468	unsigned int spwPacketSize = count + 4;
	469	QTime SPWTimeout;
	470
	471	if (count>248)
	472	{
	473	APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** CCSDS packet size > 248 bytes\n");
	474	return 1;
	475	}
	476
	477	APPENDTOLOG(QString("* START * Send CCSDS packet of ")+ QString::number(count) + QString(" byte(s)"));
	478
	479	if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 1)
	480	{
	481	RMAP_DISCONNECT();
	482	APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** SPW link not running\n");
	483	return 1;
	484	}
	485
	486	// SEND GRESB HEADER
	487	size[0] = (unsigned char) ((unsigned int) spwPacketSize>>16);
	488	size[1] = (unsigned char) ((unsigned int) spwPacketSize>>8);
	489	size[2] = (unsigned char) ((unsigned int) spwPacketSize);
	490	RMAPSend_SOCKET->write(&gresbProtocole, 1);
	491	RMAPSend_SOCKET->write((char*) size, 3);
	492	// SEND SPW HEADER
	493	RMAPSend_SOCKET->write(&targetLogicalAddress, 1);
	494	RMAPSend_SOCKET->write(&protocoleIdentifier, 1);
	495	RMAPSend_SOCKET->write(&reserved, 1);
	496	RMAPSend_SOCKET->write(&userApplication, 1);
	497	// SEND CCSDS PACKET
	498	RMAPSend_SOCKET->write(Value, count);
	499	SPWTimeout.start();
	500	while(RMAPSend_SOCKET->bytesToWrite() > 0)
	501	{
	502	RMAPSend_SOCKET->waitForBytesWritten(100);
	503	if(SPWTimeout.elapsed()>1000)
	504	{
	505	APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** sending CCSDS packet timeout\n");
	506	return 1;
	507	}
	508	}
	509
	510	APPENDTOLOG(QString("*** CCSDS packet sent"));
	511
	512	return count;
	513	}
	514
	515	void rmapplugin::sendCCSDS() // SLOT	138	void rmapplugin::sendCCSDS() // SLOT
	516	{	139	{
	517	unsigned int nbBYTES_application_data = 8;	140	unsigned int nbBYTES_application_data = 8;
	518	unsigned int count;	141	unsigned int count;
	519	char *tab;	142	char *tab;
	520	unsigned char packetErrorControl1 = 0xaa;	143	unsigned char packetErrorControl1 = 0xaa;
	521	unsigned char packetErrorControl0 = 0xbb;	144	unsigned char packetErrorControl0 = 0xbb;
	522		145
	523	ccsds_command = new ccsds(1, 0, 0, nbBYTES_application_data+12, 0, 0, 0, 0, 0); // +12 => packet header 6 bytes + data field header 4 bytes + packet error control 2 bytes	146	ccsds_command = new ccsds(1, 0, 0, nbBYTES_application_data+12, 0, 0, 0, 0, 0); // +12 => packet header 6 bytes + data field header 4 bytes + packet error control 2 bytes
	524	/* unsigned char data_field_header,	147	/* unsigned char data_field_header,
	525	unsigned char processID,	148	unsigned char processID,
	526	unsigned int sequence_count,	149	unsigned int sequence_count,
	527	unsigned int packet_length,	150	unsigned int packet_length,
	528	unsigned char acceptance,	151	unsigned char acceptance,
	529	unsigned int completion,	152	unsigned int completion,
	530	unsigned char service_type,	153	unsigned char service_type,
	531	unsigned char service_subtype,	154	unsigned char service_subtype,
	532	unsigned char sourceID*/	155	unsigned char sourceID*/
	533		156
	534	count = nbBYTES_application_data+12; // 12 is the size in bytes of the header	157	count = nbBYTES_application_data+12; // 12 is the size in bytes of the header
	535	tab = (char*) malloc(count);	158	tab = (char*) malloc(count);
	536	tab[0] = ccsds_command->ccsds_header->packetId1;	159	tab[0] = ccsds_command->ccsds_header->packetId1;
	537	tab[1] = ccsds_command->ccsds_header->packetId0;	160	tab[1] = ccsds_command->ccsds_header->packetId0;
	538	tab[2] = ccsds_command->ccsds_header->packetSequenceControl1;	161	tab[2] = ccsds_command->ccsds_header->packetSequenceControl1;
	539	tab[3] = ccsds_command->ccsds_header->packetSequenceControl0;	162	tab[3] = ccsds_command->ccsds_header->packetSequenceControl0;
	540	tab[4] = ccsds_command->ccsds_header->packetLength1;	163	tab[4] = ccsds_command->ccsds_header->packetLength1;
	541	tab[5] = ccsds_command->ccsds_header->packetLength0;	164	tab[5] = ccsds_command->ccsds_header->packetLength0;
	542	tab[6] = ccsds_command->ccsds_header->dataFieldHeader3;	165	tab[6] = ccsds_command->ccsds_header->dataFieldHeader3;
	543	tab[7] = ccsds_command->ccsds_header->dataFieldHeader2;	166	tab[7] = ccsds_command->ccsds_header->dataFieldHeader2;
	544	tab[8] = ccsds_command->ccsds_header->dataFieldHeader1;	167	tab[8] = ccsds_command->ccsds_header->dataFieldHeader1;
	545	tab[9] = ccsds_command->ccsds_header->dataFieldHeader0;	168	tab[9] = ccsds_command->ccsds_header->dataFieldHeader0;
	546	tab[10]=0x00;	169	tab[10]=0x00;
	547	tab[11]=0x00;	170	tab[11]=0x00;
	548	tab[12]=0x00;	171	tab[12]=0x00;
	549	tab[13]=0x00;	172	tab[13]=0x00;
	550	tab[14]=0x00;	173	tab[14]=0x00;
	551	tab[15]=0x00;	174	tab[15]=0x00;
	552	tab[nbBYTES_application_data+10] = packetErrorControl1;	175	tab[nbBYTES_application_data+10] = packetErrorControl1;
	553	tab[nbBYTES_application_data+11] = packetErrorControl0;	176	tab[nbBYTES_application_data+11] = packetErrorControl0;
	554		177
	555	WriteSPW(tab, count, UI->CCSDSTargetLogicalAddressSpinBox->value(), 0x00);	178	WriteSPW(tab, count, UI->CCSDSTargetLogicalAddressSpinBox->value(), 0x00);
	556		179
	557	free(tab);	180	free(tab);
	558	}	181	}
	559		182
			183	void rmapplugin::openBridge()
			184	{
			185	switch(currentBridge)
			186	{
			187	case selectedBridgeIsGRESB :
			188	this->UI->gresbBridge->Open();
			189	break;
			190	case selectedBridgeIsStarDundee :
			191	this->UI->starDundee->Open();
			192	break;
			193	default:
			194	break;
			195	}
			196	}
			197
			198	void rmapplugin::closeBridge()
			199	{
			200	switch(currentBridge)
			201	{
			202	case selectedBridgeIsGRESB :
			203	this->UI->gresbBridge->Close();
			204	break;
			205	case selectedBridgeIsStarDundee :
			206	this->UI->starDundee->Close();
			207	break;
			208	default:
			209	break;
			210	}
			211	}
			212
	560	void rmapplugin::send_TC_LFR_UPDATE_TIME()	213	void rmapplugin::send_TC_LFR_UPDATE_TIME()
	561	{	214	{
	562	unsigned int nbBYTES_application_data = 6; // Time at CUC format is on 48 bits / 6 bytes	215	unsigned int nbBYTES_application_data = 6; // Time at CUC format is on 48 bits / 6 bytes
	563	unsigned int count;	216	unsigned int count;
	564	char *tab;	217	char *tab;
	565	unsigned char packetErrorControl1 = 0xaa;	218	unsigned char packetErrorControl1 = 0xaa;
	566	unsigned char packetErrorControl0 = 0xbb;	219	unsigned char packetErrorControl0 = 0xbb;
	567		220
	568	ccsds_command = new ccsds(1, 11, 0, nbBYTES_application_data, 1, 1, 9, 129, 0);	221	ccsds_command = new ccsds(1, 11, 0, nbBYTES_application_data, 1, 1, 9, 129, 0);
	569	/* unsigned char data_field_header,	222	/* unsigned char data_field_header,
	570	unsigned char processID,	223	unsigned char processID,
	571	unsigned int sequence_count,	224	unsigned int sequence_count,
	572	unsigned int packet_length,	225	unsigned int packet_length,
	573	unsigned char acceptance,	226	unsigned char acceptance,
	574	unsigned int completion,	227	unsigned int completion,
	575	unsigned char service_type,	228	unsigned char service_type,
	576	unsigned char service_subtype,	229	unsigned char service_subtype,
	577	unsigned char sourceID*/	230	unsigned char sourceID*/
	578		231
	579	count = nbBYTES_application_data+12; // +12 => packet header 6 bytes + data field header 4 bytes + packet error control 2 bytes	232	count = nbBYTES_application_data+12; // +12 => packet header 6 bytes + data field header 4 bytes + packet error control 2 bytes
	580	tab = (char*) malloc(count);	233	tab = (char*) malloc(count);
	581	tab[0] = ccsds_command->ccsds_header->packetId1;	234	tab[0] = ccsds_command->ccsds_header->packetId1;
	582	tab[1] = ccsds_command->ccsds_header->packetId0;	235	tab[1] = ccsds_command->ccsds_header->packetId0;
	583	tab[2] = ccsds_command->ccsds_header->packetSequenceControl1;	236	tab[2] = ccsds_command->ccsds_header->packetSequenceControl1;
	584	tab[3] = ccsds_command->ccsds_header->packetSequenceControl0;	237	tab[3] = ccsds_command->ccsds_header->packetSequenceControl0;
	585	tab[4] = ccsds_command->ccsds_header->packetLength1;	238	tab[4] = ccsds_command->ccsds_header->packetLength1;
	586	tab[5] = ccsds_command->ccsds_header->packetLength0;	239	tab[5] = ccsds_command->ccsds_header->packetLength0;
	587	tab[6] = ccsds_command->ccsds_header->dataFieldHeader3;	240	tab[6] = ccsds_command->ccsds_header->dataFieldHeader3;
	588	tab[7] = ccsds_command->ccsds_header->dataFieldHeader2;	241	tab[7] = ccsds_command->ccsds_header->dataFieldHeader2;
	589	tab[8] = ccsds_command->ccsds_header->dataFieldHeader1;	242	tab[8] = ccsds_command->ccsds_header->dataFieldHeader1;
	590	tab[9] = ccsds_command->ccsds_header->dataFieldHeader0;	243	tab[9] = ccsds_command->ccsds_header->dataFieldHeader0;
	591	tab[10] = (unsigned char) (time_COARSE>>24);	244	tab[10] = (unsigned char) (time_COARSE>>24);
	592	tab[11] = (unsigned char) (time_COARSE>>18);	245	tab[11] = (unsigned char) (time_COARSE>>18);
	593	tab[12] = (unsigned char) (time_COARSE>>8);	246	tab[12] = (unsigned char) (time_COARSE>>8);
	594	tab[13] = (unsigned char) (time_COARSE);	247	tab[13] = (unsigned char) (time_COARSE);
	595	tab[14] = (unsigned char) (time_FINE>>8);	248	tab[14] = (unsigned char) (time_FINE>>8);
	596	tab[15] = (unsigned char) (time_FINE);	249	tab[15] = (unsigned char) (time_FINE);
	597	tab[nbBYTES_application_data+10] = packetErrorControl1;	250	tab[nbBYTES_application_data+10] = packetErrorControl1;
	598	tab[nbBYTES_application_data+11] = packetErrorControl0;	251	tab[nbBYTES_application_data+11] = packetErrorControl0;
	599		252
	600	WriteSPW(tab, count, UI->CCSDSTargetLogicalAddressSpinBox->value(), 0x00);	253	WriteSPW(tab, count, UI->CCSDSTargetLogicalAddressSpinBox->value(), 0x00);
	601		254
	602	time_COARSE = time_COARSE+1;	255	time_COARSE = time_COARSE+1;
	603		256
	604	free(tab);	257	free(tab);
	605	}	258	}
	606		259
	607	void rmapplugin::reset_TC_LFR_UPDATE_TIME()	260	void rmapplugin::reset_TC_LFR_UPDATE_TIME()
	608	{	261	{
	609	time_COARSE = 0;	262	time_COARSE = 0;
	610	time_FINE = 0;	263	time_FINE = 0;
	611	}	264	}
	612		265
	613	void rmapplugin::openBridge()
	614	{
	615	switch(currentBridge)
	616	{
	617	case selectedBridgeIsGRESB :
	618	RMAP_CONNECT();
	619	break;
	620	case selectedBridgeIsStarDundee :
	621	this->UI->starDundee->Open();
	622	break;
	623	default:
	624	break;
	625	}
	626	}
	627
	628	void rmapplugin::closeBridge()
	629	{
	630	switch(currentBridge)
	631	{
	632	case selectedBridgeIsGRESB :
	633	RMAP_DISCONNECT();
	634	break;
	635	case selectedBridgeIsStarDundee :
	636	this->UI->starDundee->Close();
	637	break;
	638	default:
	639	break;
	640	}
	641	}
	642
	643	void rmapplugin::RMAP_CONNECT() // SLOT
	644	{
	645	bool spwRunning = true;
	646	RMAPSend_SOCKET->connectToHost( QHostAddress(UI->gresbBridgeIPDialogBox->getGRESBIP()),
	647	3000 + UI->gresbVirtualLinkSpinBox->value()*2,
	648	QIODevice::WriteOnly);
	649	RMAPReceive_SOCKET->connectToHost( QHostAddress(UI->gresbBridgeIPDialogBox->getGRESBIP()),
	650	3000 + UI->gresbVirtualLinkSpinBox->value()*2+1,
	651	QIODevice::ReadOnly);
	652	GRESBStatusQuery_SOCKET->connectToHost( QHostAddress(UI->gresbBridgeIPDialogBox->getGRESBIP()),
	653	3010,
	654	QIODevice::ReadWrite);
	655	GRESBStatusQuery_SOCKET->waitForConnected(10000);
	656	RMAPReceive_SOCKET->readAll(); // read all remaining data from the reception socket
	657	// initialize SPW packet semaphores
	658	while (spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->available()!=0) spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->acquire();
	659	while (spwPacketReceiverOBJECT->ccsdsPacketSEMAPHORE->available()!=0) spwPacketReceiverOBJECT->ccsdsPacketSEMAPHORE->acquire();
	660	if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) != 0)
	661	{
	662	spwRunning = UI->gresbStatusQueryDialog->exec();
	663	}
	664	if (spwRunning == false) RMAP_DISCONNECT();
	665	else
	666	{
	667	APPENDTOLOG(QString("SpaceWire running on virtual link ")+ QString::number(UI->spwLinkSpinBox->value()));
	668	emit this->activateSig(true);
	669	emit gresbIsOpen(true);
	670	}
	671	}
	672
	673	void rmapplugin::RMAP_DISCONNECT() // SLOT
	674	{
	675	RMAPSend_SOCKET->disconnectFromHost();
	676	RMAPReceive_SOCKET->disconnectFromHost();
	677	GRESBStatusQuery_SOCKET->disconnectFromHost();
	678	emit this->activateSig(false);
	679	emit gresbIsOpen(false);
	680	}
	681
	682	void rmapplugin::RMAPSendConnectionState(QAbstractSocket::SocketState socketState) // SLOT
	683	{
	684	UI->rmapSendStateLabel->setText("");
	685	QString socketMessage = "RMAP Send Socket State: ";
	686	switch(socketState)
	687	{
	688	case QAbstractSocket::UnconnectedState :
	689	socketMessage.append("0 => Unconnected");
	690	UI->rmapOpenCommunicationButton->setEnabled(true);
	691	UI->rmapCloseCommunicationButton->setEnabled(false);
	692	emit this->activateSig(false);
	693	break;
	694	case 1:
	695	socketMessage.append("1 => HostLookup");
	696	break;
	697	case 2:
	698	socketMessage.append("2 => Connecting");
	699	break;
	700	case 3:
	701	socketMessage.append("3 => Connected");
	702	UI->rmapOpenCommunicationButton->setEnabled(false);
	703	UI->rmapCloseCommunicationButton->setEnabled(true);
	704	break;
	705	case 4:
	706	socketMessage.append("4 => Bound");
	707	break;
	708	case 5:
	709	socketMessage.append("5 => Closing");
	710	break;
	711	case 6:
	712	socketMessage.append("6 => Listening");
	713	break;
	714	}
	715	UI->rmapSendStateLabel->setText(socketMessage);
	716	APPENDTOLOG(socketMessage);
	717	}
	718
	719	void rmapplugin::RMAPReceiveConnectionState(QAbstractSocket::SocketState socketState) // SLOT
	720	{
	721	UI->rmapReceiveStateLabel->setText("");
	722	QString socketMessage = "RMAP Receive Socket State: ";
	723	switch(socketState)
	724	{
	725	case QAbstractSocket::UnconnectedState :
	726	socketMessage.append("0 => Unconnected");
	727	break;
	728	case 1:
	729	socketMessage.append("1 => HostLookup");
	730	break;
	731	case 2:
	732	socketMessage.append("2 => Connecting");
	733	break;
	734	case 3:
	735	socketMessage.append("3 => Connected");
	736	break;
	737	case 4:
	738	socketMessage.append("4 => Bound");
	739	break;
	740	case 5:
	741	socketMessage.append("5 => Closing");
	742	break;
	743	case 6:
	744	socketMessage.append("6 => Listening");
	745	break;
	746	}
	747	UI->rmapReceiveStateLabel->setText(socketMessage);
	748	APPENDTOLOG(socketMessage);
	749	}
	750
	751	void rmapplugin::GRESBConnectionState(QAbstractSocket::SocketState socketState) // SLOT
	752	{
	753	UI->gresbStatusQueryLabel->setText("");
	754	QString socketMessage = "GRESB status query socket (port 3010): ";
	755	switch(socketState)
	756	{
	757	case QAbstractSocket::UnconnectedState :
	758	socketMessage.append("0 => Unconnected");
	759	break;
	760	case 1:
	761	socketMessage.append("1 => HostLookup");
	762	break;
	763	case 2:
	764	socketMessage.append("2 => Connecting");
	765	break;
	766	case 3:
	767	socketMessage.append("3 => Connected");
	768	break;
	769	case 4:
	770	socketMessage.append("4 => Bound");
	771	break;
	772	case 5:
	773	socketMessage.append("5 => Closing");
	774	break;
	775	case 6:
	776	socketMessage.append("6 => Listening");
	777	break;
	778	}
	779	UI->gresbStatusQueryLabel->setText(socketMessage);
	780	}
	781
	782	void rmapplugin::reTestSPWLink() // SLOT
	783	{
	784	if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 0)
	785	{
	786	UI->gresbStatusQueryDialog->accept();
	787	}
	788	}
	789
	790	int rmapplugin::GRESBStatusQuery() // SLOT
	791	{
	792	GRESBStatusQueryRequest(LinkStatus, 0);
	793	GRESBStatusQueryRequest(LinkStatus, 1);
	794	GRESBStatusQueryRequest(LinkStatus, 2);
	795	GRESBStatusQueryRequest(LinkStatistics, 0);
	796	GRESBStatusQueryRequest(LinkStatistics, 1);
	797	GRESBStatusQueryRequest(LinkStatistics, 2);
	798	return 0;
	799	}
	800
	801	void rmapplugin::RMAP_write_reply_setText(QString text)	266	void rmapplugin::RMAP_write_reply_setText(QString text)
	802	{	267	{
	803	this->UI->RMAP_write_reply->setText(text);	268	this->UI->RMAP_write_reply->setText(text);
	804	}	269	}
	805		270
	806	void rmapplugin::appendToLog(QString text)	271	void rmapplugin::appendToLog(QString text)
	807	{	272	{
	808	APPENDTOLOG(text);	273	APPENDTOLOG(text);
	809	}	274	}
	810		275
	811	/////////////////////	276	/////////////////////
	812	// INTERNAL FUNCTIONS	277	// INTERNAL FUNCTIONS
	813		278
	814	int rmapplugin::GRESBStatusQueryRequest(GresbStatusQueryOption option, char link)
	815	{
	816	gresb_status_query_t statusQueryCommand;
	817	gresb_link_status_reply_t linkStatusReply;
	818	gresb_link_statistics_reply_t linkStatisticsReply;
	819	QTime statusQueryTimeout;
	820	QString console_message;
	821
	822	statusQueryCommand.protocolIdentifier = (char) 0x02;
	823	statusQueryCommand.reserved1 = (char) 0x00;
	824	statusQueryCommand.reserved0 = (char) 0x00;
	825	statusQueryCommand.option = (char) option;
	826	statusQueryCommand.value3 = (char) 0x00;
	827	statusQueryCommand.value2 = (char) 0x00;
	828	statusQueryCommand.value1 = (char) 0x00;
	829	statusQueryCommand.value0 = (char) link;
	830
	831	GRESBStatusQuery_SOCKET->write((char) ((void) &statusQueryCommand), sizeof(statusQueryCommand));
	832	GRESBStatusQuery_SOCKET->flush();
	833	GRESBStatusQuery_SOCKET->waitForBytesWritten(1000);
	834
	835	statusQueryTimeout.start();
	836	while(GRESBStatusQuery_SOCKET->bytesToWrite() > 0)
	837	{
	838	GRESBStatusQuery_SOCKET->waitForBytesWritten(100);
	839	if(statusQueryTimeout.elapsed()>1000)
	840	{
	841	APPENDTOLOG("WARNING === in function GRESBStatusQueryRequest of rmapplugin *** sending StatusQueryCommand timeout");
	842	return 1;
	843	}
	844	}
	845
	846	switch (option)
	847	{
	848	case LinkStatus:
	849	{
	850	statusQueryTimeout.start();
	851	while(GRESBStatusQuery_SOCKET->bytesAvailable() < (int) sizeof(linkStatusReply))
	852	{
	853	GRESBStatusQuery_SOCKET->waitForReadyRead(100);
	854	if(statusQueryTimeout.elapsed()>1000)
	855	{
	856	console_message.sprintf("GRESBStatusQueryRequest / LinkStatus => error timeout bytesAvailable()\n");
	857	APPENDTOLOG(console_message);
	858	return 1;
	859	}
	860	}
	861	GRESBStatusQuery_SOCKET->read((char) ((void) &linkStatusReply), (int) sizeof(linkStatusReply));
	862	console_message.sprintf("%x", linkStatusReply.byte0);
	863	UI->spwLinkStatusEnquiry->statusQueryTable->item(0, link)->setText(console_message);
	864	console_message.sprintf("%d", linkStatusReply.byte1);
	865	UI->spwLinkStatusEnquiry->statusQueryTable->item(1, link)->setText(console_message);
	866	if (linkStatusReply.byte0 == 0) return 1;
	867	break;
	868	}
	869	case LinkStatistics:
	870	{
	871	statusQueryTimeout.start();
	872	while(GRESBStatusQuery_SOCKET->bytesAvailable() < (int) sizeof(linkStatisticsReply))
	873	{
	874	GRESBStatusQuery_SOCKET->waitForReadyRead(100);
	875	if(statusQueryTimeout.elapsed()>1000)
	876	{
	877	console_message.sprintf("GRESBStatusQueryRequest / LinkStatistics => error timeout bytesAvailable()\n");
	878	APPENDTOLOG(console_message);
	879	return 1;
	880	}
	881	}
	882	GRESBStatusQuery_SOCKET->read((char) ((void) &linkStatisticsReply), sizeof(linkStatisticsReply));
	883	console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.sizeOfDataTransmitted));
	884	UI->spwLinkStatusEnquiry->statusQueryTable->item(9, link)->setText(console_message);
	885	console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfPacketsTransmitted));
	886	UI->spwLinkStatusEnquiry->statusQueryTable->item(8, link)->setText(console_message);
	887	console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfTruncatedPacketsReceived));
	888	UI->spwLinkStatusEnquiry->statusQueryTable->item(6, link)->setText(console_message);
	889	console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfPacketsWithEEPReceived));
	890	UI->spwLinkStatusEnquiry->statusQueryTable->item(5, link)->setText(console_message);
	891	console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.sizeOfDataReceived));
	892	UI->spwLinkStatusEnquiry->statusQueryTable->item(4, link)->setText(console_message);
	893	console_message.sprintf("%d", charTab_TO_int(linkStatisticsReply.numberOfPacketsReceived));
	894	UI->spwLinkStatusEnquiry->statusQueryTable->item(3, link)->setText(console_message);
	895	break;
	896	}
	897	case NodeAddressStatistics:
	898	{
	899	break;
	900	}
	901	case GetRoute:
	902	{
	903	break;
	904	}
	905	}
	906	return 0;
	907	}
	908
	909	int rmapplugin::charTab_TO_int(char *charTab)
	910	{
	911	int result = 0;
	912	result = (charTab[0]<<24) +(charTab[1]<<16) +(charTab[2]<<8) + charTab[3];
	913	return result;
	914	}
	915
	916	void rmapplugin::gresbSelection(bool flag)	279	void rmapplugin::gresbSelection(bool flag)
	917	{	280	{
	918	if (flag == true) UI->selection_GROUPBOX->setEnabled(false);	281	if (flag == true) UI->selection_GROUPBOX->setEnabled(false);
	919	if (flag == false) UI->selection_GROUPBOX->setEnabled(true);	282	if (flag == false) UI->selection_GROUPBOX->setEnabled(true);
	920	}	283	}
	921		284
	922		285
	923		286

rmapplugin/rmapplugin.h +5 -24

             /*------------------------------------------------------------------------------
             --  This file is a part of the LPPMON Software
             --  Copyright (C) 2011, Laboratory of Plasmas Physic - 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@lpp.polytechnique.fr
             ----------------------------------------------------------------------------*/
             #ifndef DRIVER1_H
             #define DRIVER1_H
             #include <rmappluginui.h>
             #include <rmapoperations.h>
             #include <QMenuBar>
             #include <QMenu>
             #include <QAction>
             #include <QMainWindow>
             #include <QTcpSocket>
             #include <QTime>
             #include <ccsds.h>
             #include <QSemaphore>
             #include <spwpacketreceiver.h>
             #include <lppmonplugin.h>
             #define APPENDTOLOG(message) this->UI->appendToLogFile(QTime::currentTime().toString() +":" + QString::number(QTime::currentTime().msec()) + ": " + message)
             #define READ_WRITE_MAX_COUNTS 4096                      // in words
             #define RMAP_MAX_DATA_LENGTH 4*READ_WRITE_MAX_COUNTS    // in bytes, shall be lower than the limit size of SPW packet of the GRESB bridge
             #define RMAP_READ_REPLY_HEADER_LENGTH 12                // in bytes => ECSS
             #define RMAP_READ_COMMAND_HEADER_LENGTH 16              // in bytes => ECSS
             #define RMAP_DATA_CRC_LENGTH 1                          // in bytes => ECSS
             #define CCSDS_MAX_PACKET_LENGTH 4412                    // in bytes, specified in the LFR Software Requirements Specification
             class rmapplugin : public lppmonplugin
             {
                 Q_OBJECT
             public:
                 explicit rmapplugin(QWidget *parent = 0);
                 ~rmapplugin();
-                int GRESBStatusQueryRequest(GresbStatusQueryOption option, char link);
-                int charTab_TO_int(char *charTab);
-                unsigned int ReadGRESB(unsigned int *Value,unsigned int count,unsigned int address=0);
-                unsigned int WriteGRESB(unsigned int *Value,unsigned int count,unsigned int address=0);
-                unsigned int WriteSPWGRESB(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
             public slots:
                 unsigned int Write(unsigned int *Value,unsigned int count,unsigned int address=0);
                 unsigned int Read(unsigned int *Value,unsigned int count,unsigned int address=0);
+                unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
+                void openBridge();
+                void closeBridge();
                 //
-                unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
                 void sendCCSDS();
                 void send_TC_LFR_UPDATE_TIME();
                 void reset_TC_LFR_UPDATE_TIME();
-                int GRESBStatusQuery();
                 void displayOnConsole(QString message) {this->UI->console->append(message);}
                 //
-                void RMAP_CONNECT();
-                void RMAP_DISCONNECT();
-                void openBridge();
-                void closeBridge();
-                int RMAPSendReadCommand();
-                int RMAPSendWriteCommand();
-                void reTestSPWLink();
-                //
-                void RMAPSendConnectionState(QAbstractSocket::SocketState socketState);
-                void RMAPReceiveConnectionState(QAbstractSocket::SocketState socketState);
-                void GRESBConnectionState(QAbstractSocket::SocketState socketState);
-                //
                 void gresbSelection(bool flag);
-                void activatePluginViaStarDundee(bool flag) {emit activateSig(flag);}
                 void RMAP_write_reply_setText(QString text);
                 void appendToLog(QString text);
+                //
+                void activatePlugin(bool flag) {emit activateSig(flag);}
                 void bridgeHasChanged(selectedBridge bridge) {currentBridge = bridge;}
             signals:
-                void ccsdsPacketReadyRead(char *ccsdsPacket, unsigned int size);
-                void gresbIsOpen(bool);
             private:
                 selectedBridge currentBridge;
                 rmapPluginUI* UI;
                 QTcpSocket* GRESBStatusQuery_SOCKET;
                 QTcpSocket* RMAPSend_SOCKET;
                 QTcpSocket* RMAPReceive_SOCKET;
                 ccsds* ccsds_command;
                 unsigned int rmapPacketSize;
                 unsigned int time_COARSE;
                 unsigned int time_FINE;
                 spwpacketreceiver* spwPacketReceiverOBJECT;
-                unsigned int WriteBLOCK(char *data,unsigned int nbBytes,unsigned int address=0);
-                unsigned int ReadBLOCK(unsigned int nbBytes,unsigned int address=0);
                 char timeCode;
             };
             #endif // DRIVER1_H

rmapplugin/rmappluginui.cpp +11 -28

             /*------------------------------------------------------------------------------
             --  This file is a part of the LPPMON Software
             --  Copyright (C) 2011, Laboratory of Plasmas Physic - 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@lpp.polytechnique.fr
             ----------------------------------------------------------------------------*/
             #include "rmapplugin.h"
             rmapPluginUI::rmapPluginUI(QWidget *parent) :
                 QWidget(parent)
             {
                 spectralMatricesDMASimulator = new SpectralMatricesDMASimulator;
                 spwTabWidget = new QTabWidget;
                 QWidget* spwTabWidgetPage0 = new QWidget;
                 QWidget* spwTabWidgetPage1 = new QWidget;
                 QWidget* spwTabWidgetPage2 = new QWidget;
                 QWidget* spwTabWidgetPage3 = new QWidget;
                 QWidget* spwTabWidgetPage4 = new QWidget;
-                QWidget* spwTabWidgetPage5 = new QWidget;
                 bridgeWidget = new QWidget;
                 mainLayout = new QVBoxLayout;
                 connectionLayout = new QGridLayout;
                 ccsdsLayout = new QVBoxLayout;
                 consoleLayout = new QVBoxLayout;
                 selectionLayout = new QVBoxLayout;
                 bridgeSelection_LAYOUT = new QGridLayout;
                 generalParameters_LAYOUT = new QGridLayout;
                 gresb_GROUPBOX = new QGroupBox(tr("GRESB bridge parameters"));
                 stardundee_GROUPBOX = new QGroupBox(tr("Star Dundee brick parameters"));
                 selection_GROUPBOX = new QGroupBox(tr("Bridge selection"));
                 generalParameters_GROUPBOX = new QGroupBox(tr("General parameters"));
                 //*** QLABEL ***//
                 gresbBridgeIPLabel = new QLabel(tr("Bridge IP: "));
                 gresbVirtualLinkLabel = new QLabel(tr("Virtual Link: "));
                 spwLinkLabel = new QLabel(tr("SPW Link: "));
                 rmapSourceLogicalAddressLabel = new QLabel(tr("RMAP Source Logical Address: "));
                 rmapTargetLogicalAddressLabel = new QLabel(tr("RMAP Target Logical Address: "));
-                rmapSendStateLabel = new QLabel(tr("RMAP Send Socket State: waiting for connection"));
-                rmapReceiveStateLabel = new QLabel(tr("RMAP Receive Socket State: waiting for connection"));
                 logFileName = new QLabel;
                 gresbStatusQueryLabel = new QLabel(tr("Status query socket (port 3010): waiting for connection"));
                 gresbStatusQueryDialogLabel = new QLabel(tr("sockets opened but SpaceWire link not running"));
                 sendCCSDSCommandLabel = new QLabel(tr("Address of the target"));
                 //*** QPUSHBUTTON ***//
                 rmapOpenCommunicationButton = new QPushButton(tr("Open selected bridge"));
                 rmapCloseCommunicationButton = new QPushButton(tr("Close selected bridge"));
                 rmapOpenCommunicationButton->setEnabled(false);
                 rmapCloseCommunicationButton->setEnabled(false);
                 logFileChooseButton = new QPushButton(tr("Choose file"));
                 gresbStatusQueryRetryButton = new QPushButton(tr("Retry"));
                 gresbStatusQueryAbortButton = new QPushButton(tr("Abort"));
                 sendCCSDSCommandButton = new QPushButton(tr("Send CCSDS Command"));
                 send_TC_LFR_UPDATE_TIME_Button = new QPushButton(tr("Send TC_LFR_UPDATE_TIME Packet"));
                 reset_TC_LFR_UPDATE_TIME_Button = new QPushButton(tr("reset the TC_LFR_UPDATE_TIME Packet coarse and fine times"));
                 clearConsoleButton = new QPushButton(tr("Clear"));
                 selectGRESB_BUTTON = new QRadioButton(tr("GRESB"));
                 selectStarDundee_BUTTON = new QRadioButton(tr("Star Dundee"));
                 //*** SPINBOX ***//
                 gresbVirtualLinkSpinBox = new QSpinBox;
                 rmapSourceLogicalAddressSpinBox = new QSpinBox;
                 rmapTargetLogicalAddressSpinBox = new QSpinBox;
                 spwLinkSpinBox = new QSpinBox;;
                 CCSDSTargetLogicalAddressSpinBox = new QSpinBox;
                 gresbVirtualLinkSpinBox->setRange(0, 4);
                 gresbVirtualLinkSpinBox->setValue(1);
                 rmapSourceLogicalAddressSpinBox->setRange(0, 255);
                 rmapSourceLogicalAddressSpinBox->setValue(33);
                 rmapTargetLogicalAddressSpinBox->setRange(0, 255);
                 spwLinkSpinBox->setRange(0, 2);
                 spwLinkSpinBox->setValue(0);
                 CCSDSTargetLogicalAddressSpinBox->setRange(0,255);
                 CCSDSTargetLogicalAddressSpinBox->setValue(254);
                 //*** MISC **//
                 starDundee = new StarDundee;
                 gresbBridge = new gresb;
                 console = new QTextEdit;
                 gresbBridgeIPDialogBox = new QIPDialogBox;
                 gresbStatusQueryDialog = new QDialog;
                 logEnableCheckBox = new QCheckBox(tr("Enable Logs"));
                 RMAP_write_verify = new QCheckBox(tr("data checked before write\nlimited to 4 bytes\nNOT IMPLEMENTED"));
                 RMAP_write_reply = new QCheckBox(tr("reply to the write command required\nlast reply status: unavailable"));
                 spwLinkStatusEnquiry = new gresbStatusEnquiry;
                 logFile = new QFile();
                 logFileEn = false;
-                connectionLayout->addWidget(gresbBridgeIPLabel, 0, 0, 0);
-                connectionLayout->addWidget(gresbBridgeIPDialogBox, 0, 1, 0);
-                connectionLayout->addWidget(gresbVirtualLinkLabel, 1, 0, 0);
-                connectionLayout->addWidget(gresbVirtualLinkSpinBox, 1, 1, 0);
-                connectionLayout->addWidget(spwLinkLabel, 2, 0, 0);
-                connectionLayout->addWidget(spwLinkSpinBox, 2, 1, 0);
-                connectionLayout->addWidget(rmapSourceLogicalAddressLabel, 3, 0, 0);
-                connectionLayout->addWidget(rmapSourceLogicalAddressSpinBox, 3, 1, 0);
-                connectionLayout->addWidget(rmapSendStateLabel, 4, 0, 1, 2);
-                connectionLayout->addWidget(rmapReceiveStateLabel, 5, 0, 1, 2);
-                connectionLayout->addWidget(gresbStatusQueryLabel, 6, 0, 1, 2);
                 connectionLayout->setRowStretch(7, 1);
                 connectionLayout->setColumnStretch(2, 1);
                 bridgeSelection_LAYOUT->addWidget(selectGRESB_BUTTON, 0, 0, 1, 1);
                 bridgeSelection_LAYOUT->addWidget(selectStarDundee_BUTTON, 0, 1, 1, 1);
                 bridgeSelection_LAYOUT->setRowStretch(1, 1);
                 bridgeSelection_LAYOUT->setColumnStretch(2, 1);
                 generalParameters_LAYOUT->addWidget(logEnableCheckBox, 0, 0, 1, 1);
                 generalParameters_LAYOUT->addWidget(logFileChooseButton, 0, 1, 1, 1);
                 generalParameters_LAYOUT->addWidget(rmapTargetLogicalAddressLabel, 1, 0, 0);
                 generalParameters_LAYOUT->addWidget(rmapTargetLogicalAddressSpinBox, 1, 1, 0);
                 generalParameters_LAYOUT->addWidget(rmapOpenCommunicationButton, 2, 0, 1, 1);
                 generalParameters_LAYOUT->addWidget(rmapCloseCommunicationButton, 2, 1, 1, 1);
                 generalParameters_LAYOUT->addWidget(RMAP_write_verify, 3, 0, 1, 2);
                 generalParameters_LAYOUT->addWidget(RMAP_write_reply, 4, 0, 1, 2);
                 generalParameters_LAYOUT->setRowStretch(5, 1);
                 generalParameters_LAYOUT->setColumnStretch(2, 1);
-                gresb_GROUPBOX->setLayout(connectionLayout);
+                gresb_GROUPBOX->setLayout(gresbBridge->layout());
-                //gresb_GROUPBOX->setLayout(gresbBridge->layout());
                 gresb_GROUPBOX->setVisible(false);
                 stardundee_GROUPBOX->setLayout(starDundee->layout());
                 stardundee_GROUPBOX->setVisible(false);
                 selection_GROUPBOX->setLayout(bridgeSelection_LAYOUT);
                 generalParameters_GROUPBOX->setLayout(generalParameters_LAYOUT);
                 selectionLayout->addWidget(selection_GROUPBOX);
                 selectionLayout->addWidget(generalParameters_GROUPBOX);
                 selectionLayout->addWidget(gresb_GROUPBOX);
                 selectionLayout->addWidget(stardundee_GROUPBOX);
                 ccsdsLayout->addWidget(sendCCSDSCommandButton);
                 ccsdsLayout->addWidget(send_TC_LFR_UPDATE_TIME_Button);
                 ccsdsLayout->addWidget(reset_TC_LFR_UPDATE_TIME_Button);
                 ccsdsLayout->addWidget(sendCCSDSCommandLabel);
                 ccsdsLayout->addWidget(CCSDSTargetLogicalAddressSpinBox);
                 consoleLayout->addWidget(console);
                 consoleLayout->addWidget(clearConsoleButton);
                 connect(this->logFileChooseButton, SIGNAL(clicked()), this, SLOT(chooseLogFile()));
                 connect(this, SIGNAL(setLogFileName(QString)), this->logFileName, SLOT(setText(QString)));
                 connect(this->logEnableCheckBox, SIGNAL(stateChanged(int)), this, SLOT(logFileEnDisable(int)));
                 spwTabWidget->addTab(spwTabWidgetPage0, tr("connection"));
                 spwTabWidget->addTab(spwTabWidgetPage1, tr("ccsds"));
                 spwTabWidget->addTab(spwTabWidgetPage2, tr("status"));
                 spwTabWidget->addTab(spwTabWidgetPage3, tr("console"));
                 spwTabWidget->addTab(spwTabWidgetPage4, tr("DMA"));
-                spwTabWidget->addTab(spwTabWidgetPage5, tr("gresb"));
                 spwTabWidgetPage0->setLayout(selectionLayout);
                 spwTabWidgetPage1->setLayout(ccsdsLayout);
                 spwTabWidgetPage2->setLayout(this->spwLinkStatusEnquiry->mainLayout);
                 spwTabWidgetPage3->setLayout(consoleLayout);
                 spwTabWidgetPage4->setLayout(spectralMatricesDMASimulator->mainLayout);
-                spwTabWidgetPage5->setLayout(gresbBridge->layout());
                 mainLayout->addWidget(spwTabWidget);
                 setLayout(mainLayout);
-                // GRESB STATUS QUERY DIALOG
+                //connect(gresbStatusQueryAbortButton, SIGNAL(clicked()), gresbStatusQueryDialog, SLOT(reject()));
-                gresbStatusQueryDialogLayout = new QGridLayout;
-                gresbStatusQueryDialogLayout->addWidget(gresbStatusQueryDialogLabel, 0, 0, 1, 2);
-                gresbStatusQueryDialogLayout->addWidget(gresbStatusQueryRetryButton, 1, 0, 0);
-                gresbStatusQueryDialogLayout->addWidget(gresbStatusQueryAbortButton, 1, 1, 0);
-                gresbStatusQueryDialog->setLayout(gresbStatusQueryDialogLayout);
-                connect(gresbStatusQueryAbortButton, SIGNAL(clicked()), gresbStatusQueryDialog, SLOT(reject()));
                 connect(this->clearConsoleButton, SIGNAL(clicked()), this->console, SLOT(clear()));
+                // briges
                 connect(this->selectGRESB_BUTTON, SIGNAL(clicked()), this, SLOT(selectionBetweenGresbAndStarDundee()));
                 connect(this->selectStarDundee_BUTTON, SIGNAL(clicked()), this, SLOT(selectionBetweenGresbAndStarDundee()));
                 connect(this->starDundee, SIGNAL(isOpen(bool)), this, SLOT(isOpen(bool)));
+                connect(this->gresbBridge, SIGNAL(isOpen(bool)), this, SLOT(isOpen(bool)));
                 connect(this->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->starDundee, SLOT(targetHasChanged(int)));
+                connect(this->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->gresbBridge, SLOT(targetHasChanged(int)));
                 // command code
                 connect(this->RMAP_write_reply, SIGNAL(clicked()), this, SLOT(getCommandCode()));
                 connect(this->RMAP_write_verify, SIGNAL(clicked()), this, SLOT(getCommandCode()));
-                connect(this, SIGNAL(commandCodeHasChanged(RMAP_command_codes)), this->starDundee, SLOT(commandCodeHasChanged(RMAP_command_codes)));
+                connect(this, SIGNAL(commandCodeHasChanged(RMAP_command_codes)),
+                        this->starDundee, SLOT(commandCodeHasChanged(RMAP_command_codes)));
+                connect(this, SIGNAL(commandCodeHasChanged(RMAP_command_codes)),
+                        this->gresbBridge, SLOT(commandCodeHasChanged(RMAP_command_codes)));
                 getCommandCode(); // init the command code value
                 rmapTargetLogicalAddressSpinBox->setValue(254);
             }
             rmapPluginUI::~rmapPluginUI()
             {
                 //delete ui;
             }
             void rmapPluginUI::chooseLogFile()
             {
                 if(this->logFile->isOpen())
                     this->logFile->close();
                 this->logFile->setFileName(QFileDialog::getSaveFileName(this,tr("Open Log file"),
                                                                         QDir::homePath()
                                                                         + "/"
                                                                         + QDate::currentDate().toString()
                                                                         + "_"
                                                                         + QTime::currentTime().toString()
                                                                         + "_rmapPluginUI.log",
                                                                         tr("Log Files (*.txt *.log)")));
                 if(this->logFile->open(QIODevice::WriteOnly))
                 {
                     this->logFileStrm = new QTextStream(this->logFile);
                     emit this->setLogFileName(this->logFile->fileName());
                 }
             }
             void rmapPluginUI::logFileEnDisable(int state)
             {
                 if(state==Qt::Checked)
                 {
                     this->logFileEn = true;
                 }
                 else if(state==Qt::Unchecked)
                 {
                     this->logFileEn = false;
                 }
             }
             bool rmapPluginUI::islogfileenable()
             {
                 return this->logFileEn;
             }
             void rmapPluginUI::appendToLogFile(const QString & text)
             {
                 if(this->logFileEn && this->logFile->isOpen())
                 {
                     *(this->logFileStrm) << text << endl;
                 }
             }
             void rmapPluginUI::closeEvent(QCloseEvent *event)
             {
                 if(this->logFile->isOpen())
                 {
                     this->logFileStrm->flush();
                     this->logFile->waitForBytesWritten(3000);
                     this->logFile->close();
                 }
                 event->accept();
             }
             RMAP_command_codes rmapPluginUI::getCommandCode()
             {
                 RMAP_command_codes commandCode = invalid0;
                 if (RMAP_write_verify->isChecked() and RMAP_write_reply->isChecked()) commandCode = writeSingle_ver_rep;
                 if (RMAP_write_verify->isChecked() and !RMAP_write_reply->isChecked()) commandCode = writeSingle_ver_noRep;
                 if (!RMAP_write_verify->isChecked() and RMAP_write_reply->isChecked()) commandCode = writeSingle_noVer_Rep;
                 if (!RMAP_write_verify->isChecked() and !RMAP_write_reply->isChecked()) commandCode = writeSingle_noVer_noRep;
                 emit commandCodeHasChanged(commandCode);
                 return commandCode;
             }
             // SLOT
             void rmapPluginUI::selectionBetweenGresbAndStarDundee() //SLOT
             {
                 if (selectGRESB_BUTTON->isChecked())
                 {
                     gresb_GROUPBOX->setVisible(true);
                     stardundee_GROUPBOX->setVisible(false);
                     rmapOpenCommunicationButton->setEnabled(true);
                     emit bridgeHasChanged(selectedBridgeIsGRESB);
                 }
                 if (selectStarDundee_BUTTON->isChecked())
                 {
                     stardundee_GROUPBOX->setVisible(true);
                     gresb_GROUPBOX->setVisible(false);
                     rmapOpenCommunicationButton->setEnabled(true);
                     emit bridgeHasChanged(selectedBridgeIsStarDundee);
                 }
             }
             void rmapPluginUI::isOpen(bool flag)
             {
                 if (flag == true)
                 {
                     selection_GROUPBOX->setEnabled(false);
                     this->rmapOpenCommunicationButton->setEnabled(false);
                     this->rmapCloseCommunicationButton->setEnabled(true);
                 }
                 if (flag == false)
                 {
                     selection_GROUPBOX->setEnabled(true);
                     this->rmapOpenCommunicationButton->setEnabled(true);
                     this->rmapCloseCommunicationButton->setEnabled(false);
                 }
             }

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