HG_REPOSITORIES/LPP/INSTRUMENTATION/SOLO_LFR/LPPMON_PLUGINS_PAUL Commit - r3:bf349cb3902d

Minor updates

leroy -

r3:bf349cb3902d default

parent child

Context file:

r3:bf349cb3902d

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-06T08:47:47. -->
+            <!-- Written by Qt Creator 2.4.1, 2012-12-07T14:08:53. -->
             <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/rmapplugin.cpp +23 -36

             /*------------------------------------------------------------------------------
             --  This file is a part of the LPPMON Software
             --  Copyright (C) 2012, Laboratory of Plasma Physics - 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 : Paul LEROY
             --                     Mail : paul.leroy@lpp.polytechnique.fr
             ----------------------------------------------------------------------------*/
             #include "rmapplugin.h"
             #include <QHostAddress>
             #include <QIODevice>
             #include <QApplication>
             #include <rmappluginpythonwrapper.h>
             rmapplugin::rmapplugin(QWidget *parent)
               :lppmonplugin(parent,false)
             {
                 this->UI = new rmapPluginUI();
                 this->setWindowTitle(tr("RMAP and SPW Communication"));
                 this->setWidget((QWidget*)this->UI);
                 RMAPSend_SOCKET = new QTcpSocket;
                 RMAPReceive_SOCKET = new QTcpSocket;
                 GRESBStatusQuery_SOCKET = new QTcpSocket;
                 spwPacketReceiverOBJECT = new spwpacketreceiver;
                 spwPacketReceiverOBJECT->gresbReceptionSocket = RMAPReceive_SOCKET;
                 timeCode = 0;
                 time_COARSE = 0;
                 time_FINE = 0;
                 currentBridge = selectedBridgeIsUnknown;
                 /*Python wrapper*/
                 this->pyObject = new rmappluginPythonWrapper();
                 connect(this->pyObject,SIGNAL(ReadSig(uint*,uint,uint)),this,SLOT(Read(uint*,uint,uint)));
                 connect(this->pyObject,SIGNAL(WriteSig(uint*,uint,uint)),this,SLOT(Write(uint*,uint,uint)));
                 /*==============*/
-                //connect(UI->rmapOpenCommunicationButton, SIGNAL(clicked()), this, SLOT(RMAP_CONNECT()));
-                //connect(UI->rmapCloseCommunicationButton, SIGNAL(clicked()), this, SLOT(RMAP_DISCONNECT()));
                 connect(UI->rmapOpenCommunicationButton, SIGNAL(clicked()), this, SLOT(openBridge()));
                 connect(UI->rmapCloseCommunicationButton, SIGNAL(clicked()), this, SLOT(closeBridge()));
                 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(UI->gresbStatusQueryRetryButton, SIGNAL(clicked()), this, SLOT(reTestSPWLink()));
                 connect(this->UI->spwLinkStatusEnquiry->readSPWStatusButton, SIGNAL(clicked()), this, SLOT(GRESBStatusQuery()));
                 connect(this->RMAPReceive_SOCKET, SIGNAL(readyRead()), this->spwPacketReceiverOBJECT, SLOT(receiveSPWPacket()));
                 // CCSDS
                 connect(this->UI->sendCCSDSCommandButton, SIGNAL(clicked()), this, SLOT(sendCCSDS()));
                 connect(this->UI->send_TC_LFR_UPDATE_TIME_Button, SIGNAL(clicked()), this, SLOT(send_TC_LFR_UPDATE_TIME()));
                 connect(this->UI->reset_TC_LFR_UPDATE_TIME_Button, SIGNAL(clicked()), this, SLOT(reset_TC_LFR_UPDATE_TIME()));
                 // CONSOLE
                 connect(this->spwPacketReceiverOBJECT, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
                 connect(this->UI->starDundee, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
                 // spectralMAtricesDMASimulator
                 connect(this->UI->spectralMatricesDMASimulator, SIGNAL(rmapplugginRead(uint*,uint,uint)), this, SLOT(Read(uint*,uint,uint)));
                 connect(this->UI->spectralMatricesDMASimulator, SIGNAL(rmapplugginWrite(uint*,uint,uint)), this, SLOT(Write(uint*,uint,uint)));
                 connect(this->UI->spectralMatricesDMASimulator, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
                 // GRESB
                 connect(this, SIGNAL(gresbIsOpen(bool)), this, SLOT(gresbSelection(bool)));
                 // Star Dundee
-                connect(this->UI->starDundee, SIGNAL(starDundeeIsOpen(bool)), this, SLOT(activatePluginViaStarDundee(bool)));
+                connect(this->UI->starDundee, SIGNAL(isOpen(bool)), this, SLOT(activatePluginViaStarDundee(bool)));
                 connect(this->UI->starDundee, SIGNAL(RMAP_write_reply_setText(QString)), this, SLOT(RMAP_write_reply_setText(QString)));
                 connect(this->UI->starDundee, SIGNAL(appendToLog(QString)), this, SLOT(appendToLog(QString)));
                 connect(this->UI, SIGNAL(bridgeHasChanged(selectedBridge)), this, SLOT(bridgeHasChanged(selectedBridge)));
             }
             rmapplugin::~rmapplugin()
             {
                 if (!RMAPSend_SOCKET->isOpen()) RMAPSend_SOCKET->disconnectFromHost();
                 if (!RMAPReceive_SOCKET->isOpen()) RMAPReceive_SOCKET->disconnectFromHost();
                 if (!GRESBStatusQuery_SOCKET->isOpen()) GRESBStatusQuery_SOCKET->disconnectFromHost();
             }
             unsigned int rmapplugin::Write(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int result;
                 switch(currentBridge)
                 {
                 case selectedBridgeIsGRESB :
                     result = WriteGRESB(Value, count, address);
                     break;
                 case selectedBridgeIsStarDundee :
-                    result = this->WriteStarDundee(Value, count, address);
+                    result = UI->starDundee->Write(Value, count, address);
                     break;
                 default:
                     result = 1;
                     break;
                 }
                 return result;
             }
             unsigned int rmapplugin::Read(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int result;
                 switch(currentBridge)
                 {
                 case selectedBridgeIsGRESB :
                     result = ReadGRESB(Value, count, address);
                     break;
                 case selectedBridgeIsStarDundee :
-                    result = this->ReadStarDundee(Value, count, address);
+                    result = UI->starDundee->Read(Value, count, address);
                     break;
                 default:
                     result = 1;
                     break;
                 }
                 return result;
             }
             unsigned int rmapplugin::WriteGRESB(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int remainingCount = count;
                 unsigned int iOffset = 0;
                 QString console_message;
                 char* data;
                 if(spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->available()!=0)
                 {
                     APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** RMAP request already running, WRITE access stopped");
                     return 1;
                 }
                 UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: unavailable");
                 data = (char*) malloc(READ_WRITE_MAX_COUNTS*4);
                 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);
                     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)
                     {
                         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);
                     APPENDTOLOG(console_message + QString("Write ")+ QString::number(remainingCount*4) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (WriteBLOCK(data, remainingCount*4, address)==0)
                     {
                         APPENDTOLOG("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
                         return 1;
                     }
                 }
                 APPENDTOLOG(QString("*** STOP *** WRITE"));
                 free(data);
                 return count;
             }
             unsigned int rmapplugin::ReadGRESB(unsigned int *Value, unsigned int count, unsigned int address)
             {
                 unsigned int remainingCount = count;
                 unsigned int iOffset = 0;
                 QString console_message;
                 if(spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->available()!=0)
                 {
                     APPENDTOLOG("WARNING === in function READ of rmapplugin *** RMAP request already running, READ access stopped");
                     return 1;
                 }
                 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);
                     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)
                     {
                         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) spwPacketReceiverOBJECT->rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
                         for(int j=1;j<4;j++)
                         {
                             Value[i+iOffset]= ((unsigned char)(spwPacketReceiverOBJECT->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;
                     spwPacketReceiverOBJECT->acquireRMAPSemaphore();
                 }
                 if (remainingCount > 0)
                 {
                     console_message.sprintf("remainingCount: %d => ", remainingCount);
                     APPENDTOLOG(console_message + QString("Read ")+ QString::number(4*remainingCount) + QString(" byte(s) @0x")+ QString::number(address,16));
                     if (ReadBLOCK(4*remainingCount, address)==0)
                     {
                         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) spwPacketReceiverOBJECT->rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
                         for(int j=1;j<4;j++)
                         {
                             Value[i+iOffset]= ((unsigned char)(spwPacketReceiverOBJECT->rmapPacket[i*4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]*256;
                         }
                     }
                     spwPacketReceiverOBJECT->acquireRMAPSemaphore();
                 }
                 APPENDTOLOG(QString("*** STOP *** READ "));
                 return count;
             }
             unsigned int rmapplugin::WriteBLOCK(char *data, unsigned int nbBytes, unsigned int address)
             {
                 QTime RMAPTimeout;
                 RMAP *RMAPCommand;
                 int errorCode;
                 QString console_message;
                 if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 1)
                 {
                     RMAP_DISCONNECT();
                     return 1;
                 }
                 RMAPCommand = new RMAP(UI->getCommandCode(),
                                        UI->rmapTargetLogicalAddressSpinBox->value(),
                                        UI->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)
                     {
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** sending Write RMAP Command timeout");
                         return 0;
                     }
                 }
                 if (UI->RMAP_write_reply->isChecked())
                 {
                     // WAIT FOR THE RMAP REPLY PACKET
                     errorCode = spwPacketReceiverOBJECT->receiveSPWPacket(1);
                     if (errorCode<=0)
                     {
                         APPENDTOLOG("WARNING === in function WriteBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
                         return 0;
                     }
                     if(spwPacketReceiverOBJECT->rmapPacketSize != 8)
                      {
                         console_message.sprintf("WARNING === in function WRITE (with reply) of rmapplugin *** write reply format not compliant\n");
                         APPENDTOLOG(console_message);
                         return 0;
                      }
                     switch (spwPacketReceiverOBJECT->rmapPacket[3]) // byte 4 is the status byte in the reply
                     {
                     case 0:
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 0 Successfull");
                         break;
                     case 1:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** General error code");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 1 General error code");
                         break;
                     case 2:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Unused RMAP packet type or command code");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 2 Unused RMAP packet type or command code");
                         break;
                     case 3:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid key");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 3 Invalid key");
                         break;
                     case 4:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid data CRC");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 4 Invalid data CRC");
                         break;
                     case 5:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Early EOP");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 5 Early EOP");
                         break;
                     case 6:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Too much data");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 6 Too much data");
                         break;
                     case 7:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** EEP");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 7 EEP");
                         break;
                     case 8:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Reserved");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 8 Reserved");
                         break;
                     case 9:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Verify buffer overrun");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 9 Verify buffer overrun");
                         break;
                     case 10:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** RMAP command not implemented or not authorised");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 10 RMAP command not implemented or not authorised");
                         break;
                     case 11:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** RMW data length error");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 11 RMAP RMW data length error");
                         break;
                     case 12:
                         APPENDTOLOG("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid target logical address");
                         UI->RMAP_write_reply->setText("reply to the write command required\nlast reply status: 12 Invalid target logical address");
                         break;
                     }
                     spwPacketReceiverOBJECT->acquireRMAPSemaphore();
                 }
                 return nbBytes;
             }
             unsigned int rmapplugin::ReadBLOCK(unsigned int nbBytes, unsigned int address)
             {
                 int errorCode;
                 RMAP *RMAPCommand;
                 QTime RMAPTimeout;
                 unsigned int dataLength;
                 if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 1)
                 {
                     RMAP_DISCONNECT();
                     return 1;
                 }
                 if (nbBytes > 4)
                 {
                     RMAPCommand = new RMAP(read_Inc,
                                            UI->rmapTargetLogicalAddressSpinBox->value(),
                                            UI->rmapSourceLogicalAddressSpinBox->value(),
                                            address,
                                            nbBytes,
                                            NULL);
                 }
                 else
                 {
                     RMAPCommand = new RMAP(read_Single,
                                            UI->rmapTargetLogicalAddressSpinBox->value(),
                                            UI->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)
                     {
                         APPENDTOLOG("WARNING === in function READ of rmapplugin *** sending Read RMAP Command timeout\n");
                         return 0;
                     }
                 }
                 // RECEIVE THE INCOMING RMAP PACKET
                 errorCode = spwPacketReceiverOBJECT->receiveSPWPacket(1); // request ID 1 is for RMAP packet
                 if (errorCode<=0)
                 {
                     APPENDTOLOG("WARNING === in function ReadBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
                     return 0;
                 }
                 dataLength = spwPacketReceiverOBJECT->rmapPacketSize - RMAP_READ_REPLY_HEADER_LENGTH - RMAP_DATA_CRC_LENGTH;
                 if(dataLength != nbBytes)
                  {
                     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 rmapplugin::WriteStarDundee(unsigned int *Value, unsigned int count, unsigned int address)
-                unsigned int result;
-                result = UI->starDundee->WriteStarDundee(Value, count, address);
-                return result;
-            unsigned int rmapplugin::ReadStarDundee(unsigned int *Value, unsigned int count, unsigned int address)
-                unsigned int result;
-                result = UI->starDundee->ReadStarDundee(Value, count, address);
-                return result;
             ////////
             // SLOTS
             unsigned int rmapplugin::WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication) // SLOT
             {
+                unsigned int result;
+                switch(currentBridge)
+                {
+                case selectedBridgeIsGRESB :
+                    result = WriteSPWGRESB(Value, count, targetLogicalAddress, userApplication);
+                    break;
+                case selectedBridgeIsStarDundee :
+                    result = UI->starDundee->WriteSPW(Value, count, targetLogicalAddress, userApplication);
+                    break;
+                default:
+                    result = 1;
+                    break;
+                }
+                return result;
+            }
+            unsigned int rmapplugin::WriteSPWGRESB(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, UI->spwLinkSpinBox->value()) == 1)
                 {
                     RMAP_DISCONNECT();
                     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;
             }
             void rmapplugin::sendCCSDS() // SLOT
             {
                 unsigned int nbBYTES_application_data = 8;
                 unsigned int count;
                 char *tab;
                 unsigned char packetErrorControl1 = 0xaa;
                 unsigned char packetErrorControl0 = 0xbb;
                 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
                 /*      unsigned char data_field_header,
                         unsigned char processID,
                         unsigned int sequence_count,
                         unsigned int packet_length,
                         unsigned char acceptance,
                         unsigned int completion,
                         unsigned char service_type,
                         unsigned char service_subtype,
                         unsigned char sourceID*/
                 count = nbBYTES_application_data+12; // 12 is the size in bytes of the header
                 tab = (char*) malloc(count);
                 tab[0] = ccsds_command->ccsds_header->packetId1;
                 tab[1] = ccsds_command->ccsds_header->packetId0;
                 tab[2] = ccsds_command->ccsds_header->packetSequenceControl1;
                 tab[3] = ccsds_command->ccsds_header->packetSequenceControl0;
                 tab[4] = ccsds_command->ccsds_header->packetLength1;
                 tab[5] = ccsds_command->ccsds_header->packetLength0;
                 tab[6] = ccsds_command->ccsds_header->dataFieldHeader3;
                 tab[7] = ccsds_command->ccsds_header->dataFieldHeader2;
                 tab[8] = ccsds_command->ccsds_header->dataFieldHeader1;
                 tab[9] = ccsds_command->ccsds_header->dataFieldHeader0;
                 tab[10]=0x00;
                 tab[11]=0x00;
                 tab[12]=0x00;
                 tab[13]=0x00;
                 tab[14]=0x00;
                 tab[15]=0x00;
                 tab[nbBYTES_application_data+10] = packetErrorControl1;
                 tab[nbBYTES_application_data+11] = packetErrorControl0;
                 WriteSPW(tab, count, UI->CCSDSTargetLogicalAddressSpinBox->value(), 0x00);
                 free(tab);
             }
             void rmapplugin::send_TC_LFR_UPDATE_TIME()
             {
                 unsigned int nbBYTES_application_data = 6; // Time at CUC format is on 48 bits / 6 bytes
                 unsigned int count;
                 char *tab;
                 unsigned char packetErrorControl1 = 0xaa;
                 unsigned char packetErrorControl0 = 0xbb;
                 ccsds_command = new ccsds(1, 11, 0, nbBYTES_application_data, 1, 1, 9, 129, 0);
                 /*      unsigned char data_field_header,
                         unsigned char processID,
                         unsigned int sequence_count,
                         unsigned int packet_length,
                         unsigned char acceptance,
                         unsigned int completion,
                         unsigned char service_type,
                         unsigned char service_subtype,
                         unsigned char sourceID*/
                 count = nbBYTES_application_data+12; // +12 => packet header 6 bytes + data field header 4 bytes + packet error control 2 bytes
                 tab = (char*) malloc(count);
                 tab[0] = ccsds_command->ccsds_header->packetId1;
                 tab[1] = ccsds_command->ccsds_header->packetId0;
                 tab[2] = ccsds_command->ccsds_header->packetSequenceControl1;
                 tab[3] = ccsds_command->ccsds_header->packetSequenceControl0;
                 tab[4] = ccsds_command->ccsds_header->packetLength1;
                 tab[5] = ccsds_command->ccsds_header->packetLength0;
                 tab[6] = ccsds_command->ccsds_header->dataFieldHeader3;
                 tab[7] = ccsds_command->ccsds_header->dataFieldHeader2;
                 tab[8] = ccsds_command->ccsds_header->dataFieldHeader1;
                 tab[9] = ccsds_command->ccsds_header->dataFieldHeader0;
                 tab[10] = (unsigned char) (time_COARSE>>24);
                 tab[11] = (unsigned char) (time_COARSE>>18);
                 tab[12] = (unsigned char) (time_COARSE>>8);
                 tab[13] = (unsigned char) (time_COARSE);
                 tab[14] = (unsigned char) (time_FINE>>8);
                 tab[15] = (unsigned char) (time_FINE);
                 tab[nbBYTES_application_data+10] = packetErrorControl1;
                 tab[nbBYTES_application_data+11] = packetErrorControl0;
                 WriteSPW(tab, count, UI->CCSDSTargetLogicalAddressSpinBox->value(), 0x00);
                 time_COARSE = time_COARSE+1;
                 free(tab);
             }
             void rmapplugin::reset_TC_LFR_UPDATE_TIME()
             {
                 time_COARSE = 0;
                 time_FINE = 0;
             }
             void rmapplugin::openBridge()
             {
                 switch(currentBridge)
                 {
                 case selectedBridgeIsGRESB :
                     RMAP_CONNECT();
                     break;
                 case selectedBridgeIsStarDundee :
-                    this->UI->starDundee->OpenStarDundee();
+                    this->UI->starDundee->Open();
                     break;
                 default:
                     break;
                 }
             }
             void rmapplugin::closeBridge()
             {
                 switch(currentBridge)
                 {
                 case selectedBridgeIsGRESB :
                     RMAP_DISCONNECT();
                     break;
                 case selectedBridgeIsStarDundee :
-                    this->UI->starDundee->CloseStarDundee();
+                    this->UI->starDundee->Close();
                     break;
                 default:
                     break;
                 }
             }
             void rmapplugin::RMAP_CONNECT() // SLOT
             {
                 bool spwRunning = true;
                 RMAPSend_SOCKET->connectToHost( QHostAddress(UI->gresbBridgeIPDialogBox->getGRESBIP()),
 + UI->gresbVirtualLinkSpinBox->value()*2,
                                                 QIODevice::WriteOnly);
                 RMAPReceive_SOCKET->connectToHost( QHostAddress(UI->gresbBridgeIPDialogBox->getGRESBIP()),
 + UI->gresbVirtualLinkSpinBox->value()*2+1,
                                                    QIODevice::ReadOnly);
                 GRESBStatusQuery_SOCKET->connectToHost( QHostAddress(UI->gresbBridgeIPDialogBox->getGRESBIP()),
 ,
                                                         QIODevice::ReadWrite);
                 GRESBStatusQuery_SOCKET->waitForConnected(10000);
                 RMAPReceive_SOCKET->readAll();  // read all remaining data from the reception socket
                 // initialize SPW packet semaphores
                 while (spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->available()!=0) spwPacketReceiverOBJECT->rmapPacketSEMAPHORE->acquire();
                 while (spwPacketReceiverOBJECT->ccsdsPacketSEMAPHORE->available()!=0) spwPacketReceiverOBJECT->ccsdsPacketSEMAPHORE->acquire();
                 if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) != 0)
                 {
                     spwRunning = UI->gresbStatusQueryDialog->exec();
                 }
                 if (spwRunning == false) RMAP_DISCONNECT();
                 else
                 {
                     APPENDTOLOG(QString("SpaceWire running on virtual link ")+ QString::number(UI->spwLinkSpinBox->value()));
                     emit this->activateSig(true);
                     emit gresbIsOpen(true);
                 }
             }
             void rmapplugin::RMAP_DISCONNECT() // SLOT
             {
                 RMAPSend_SOCKET->disconnectFromHost();
                 RMAPReceive_SOCKET->disconnectFromHost();
                 GRESBStatusQuery_SOCKET->disconnectFromHost();
                 emit this->activateSig(false);
                 emit gresbIsOpen(false);
             }
             void rmapplugin::RMAPSendConnectionState(QAbstractSocket::SocketState socketState) // SLOT
             {
                 UI->rmapSendStateLabel->setText("");
                 QString socketMessage = "RMAP Send Socket State: ";
                 switch(socketState)
                 {
                 case QAbstractSocket::UnconnectedState :
                     socketMessage.append("0 => Unconnected");
                     UI->rmapOpenCommunicationButton->setEnabled(true);
                     UI->rmapCloseCommunicationButton->setEnabled(false);
                     emit this->activateSig(false);
                     break;
                 case 1:
                     socketMessage.append("1 => HostLookup");
                     break;
                 case 2:
                     socketMessage.append("2 => Connecting");
                     break;
                 case 3:
                     socketMessage.append("3 => Connected");
                     UI->rmapOpenCommunicationButton->setEnabled(false);
                     UI->rmapCloseCommunicationButton->setEnabled(true);
                     break;
                 case 4:
                     socketMessage.append("4 => Bound");
                     break;
                 case 5:
                     socketMessage.append("5 => Closing");
                     break;
                 case 6:
                     socketMessage.append("6 => Listening");
                     break;
                 }
                 UI->rmapSendStateLabel->setText(socketMessage);
                 APPENDTOLOG(socketMessage);
             }
             void rmapplugin::RMAPReceiveConnectionState(QAbstractSocket::SocketState socketState) // SLOT
             {
                 UI->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;
                 }
                 UI->rmapReceiveStateLabel->setText(socketMessage);
                 APPENDTOLOG(socketMessage);
             }
             void rmapplugin::GRESBConnectionState(QAbstractSocket::SocketState socketState) // SLOT
             {
                 UI->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;
                 }
                 UI->gresbStatusQueryLabel->setText(socketMessage);
             }
             void rmapplugin::reTestSPWLink() // SLOT
             {
                 if (GRESBStatusQueryRequest(LinkStatus, UI->spwLinkSpinBox->value()) == 0)
                 {
                     UI->gresbStatusQueryDialog->accept();
                 }
             }
             int rmapplugin::GRESBStatusQuery() // SLOT
             {
                 GRESBStatusQueryRequest(LinkStatus, 0);
                 GRESBStatusQueryRequest(LinkStatus, 1);
                 GRESBStatusQueryRequest(LinkStatus, 2);
                 GRESBStatusQueryRequest(LinkStatistics, 0);
                 GRESBStatusQueryRequest(LinkStatistics, 1);
                 GRESBStatusQueryRequest(LinkStatistics, 2);
                 return 0;
             }
-            void rmapplugin::displayOnConsole(QString message)
-                this->UI->console->append(message);
-            void rmapplugin::activatePluginViaStarDundee(bool flag)
-                emit activateSig(flag);
             void rmapplugin::RMAP_write_reply_setText(QString text)
             {
                 this->UI->RMAP_write_reply->setText(text);
             }
             void rmapplugin::appendToLog(QString text)
             {
                 APPENDTOLOG(text);
             }
             /////////////////////
             // INTERNAL FUNCTIONS
             int rmapplugin::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)
                     {
                         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");
                             APPENDTOLOG(console_message);
                             return 1;
                         }
                     }
                     GRESBStatusQuery_SOCKET->read((char*) ((void*) &linkStatusReply), (int) sizeof(linkStatusReply));
                     console_message.sprintf("%x", linkStatusReply.byte0);
                     UI->spwLinkStatusEnquiry->statusQueryTable->item(0, link)->setText(console_message);
                     console_message.sprintf("%d", linkStatusReply.byte1);
                     UI->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");
                             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;
             }
             int rmapplugin::charTab_TO_int(char *charTab)
             {
                 int result = 0;
                 result = (charTab[0]<<24) +(charTab[1]<<16) +(charTab[2]<<8) + charTab[3];
                 return result;
             }
             void rmapplugin::gresbSelection(bool flag)
             {
                 if (flag == true) UI->selection_GROUPBOX->setEnabled(false);
                 if (flag == false) UI->selection_GROUPBOX->setEnabled(true);
             }
-            // SLOTS
-            void rmapplugin::bridgeHasChanged(selectedBridge bridge)
-                currentBridge = bridge;

rmapplugin/rmapplugin.h +4 -5

             /*------------------------------------------------------------------------------
             --  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 ReadStarDundee(unsigned int *Value, unsigned int count, unsigned int address=0);
+                unsigned int WriteSPWGRESB(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
-                unsigned int WriteStarDundee(unsigned int *Value, unsigned int count, unsigned int address=0);
             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 sendCCSDS();
                 void send_TC_LFR_UPDATE_TIME();
                 void reset_TC_LFR_UPDATE_TIME();
                 int GRESBStatusQuery();
-                void displayOnConsole(QString message);
+                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);
+                void activatePluginViaStarDundee(bool flag) {emit activateSig(flag);}
                 void RMAP_write_reply_setText(QString text);
                 void appendToLog(QString text);
-                void bridgeHasChanged(selectedBridge bridge);
+                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/rmapplugin.pro +4 -2

             #
             # Project created by QtCreator 2011-09-20T08:15:30
             #
             #-------------------------------------------------
             #include(/etc/lppmon/lppmonplugin.prf)
             CONFIG += lppmonplugin
             TARGET = rmapplugin
             DEFINES += PLUGIN=rmapplugin
             DEFINES += PLUGINHEADER="\"\\\"rmapplugin.h"\\\"\"
             DEFINES += driver_Name="\"\\\"RMAPPlugin"\\\"\"
             DEFINES += driver_Author="\"\\\"Paul Leroy paul.leroy@lpp.polytechnique.fr"\\\"\"
             DEFINES += driver_Version="\"\\\"1.1.2"\\\"\"
             DEFINES += driver_Description="\"\\\"AHB bus controler, works with Gaisler's AHB plugn' play bus."\\\"\"
             DEFINES += driver_can_be_root=1
             DEFINES += driver_can_be_child=0
             DEFINES += driver_VID=0
             DEFINES += driver_PID=0
             QT += network
             LIBS += ../spw_usb_driver_v2.61/lib/x86_64/libSpaceWireUSBAPI.so \
                 ../spw_usb_driver_v2.61/lib/x86_64/libConfigLibraryUSB.so
             INCLUDEPATH += \
                     $${PWD} \
                     ../common_PLE \
                     ../spw_usb_driver_v2.61/inc
             HEADERS += \
                 rmappluginui.h \
                 rmapplugin.h \
                 rmapoperations.h \
                 ccsds.h \
                 spwpacketreceiver.h \
                 ../common_PLE/qipdialogbox.h \
                 ../common_PLE/gresbstatusenquiry.h \
                 spectralmatricesdmasimulator.h \
                 rmappluginpythonwrapper.h \
                 stardundee.h \
                 ../spw_usb_driver_v2.61/inc/spw_usb_api.h \
                 ../spw_usb_driver_v2.61/inc/spw_config_library.h \
-                gresb.h
+                gresb.h \
+                bridge.h
             SOURCES += \
                 rmapplugin.cpp \
                 rmappluginui.cpp \
                 rmapoperations.cpp \
                 ccsds.cpp \
                 spwpacketreceiver.cpp \
                 ../common_PLE/qipdialogbox.cpp \
                 ../common_PLE/gresbstatusenquiry.cpp \
                 spectralmatricesdmasimulator.cpp \
                 rmappluginpythonwrapper.cpp \
                 stardundee.cpp \
-                gresb.cpp
+                gresb.cpp \
+                bridge.cpp

rmapplugin/rmappluginui.cpp +16 -15

             /*------------------------------------------------------------------------------
             --  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("GRESB Bridge IP: "));
+                gresbBridgeIPLabel = new QLabel(tr("Bridge IP: "));
-                gresbVirtualLinkLabel = new QLabel(tr("GRESB Virtual Link: "));
+                gresbVirtualLinkLabel = new QLabel(tr("Virtual Link: "));
-                spwLinkLabel = new QLabel(tr("GRESB SPW 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("GRESB status query socket (port 3010): waiting for connection"));
+                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 RMAP Communication"));
+                rmapOpenCommunicationButton = new QPushButton(tr("Open selected bridge"));
-                rmapCloseCommunicationButton = new QPushButton(tr("Close RMAP Communication"));
+                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);
-                rmapTargetLogicalAddressSpinBox->setValue(254);
                 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, 2);
+                generalParameters_LAYOUT->addWidget(rmapOpenCommunicationButton, 2, 0, 1, 1);
-                generalParameters_LAYOUT->addWidget(rmapCloseCommunicationButton, 3, 0, 1, 2);
+                generalParameters_LAYOUT->addWidget(rmapCloseCommunicationButton, 2, 1, 1, 1);
-                generalParameters_LAYOUT->addWidget(RMAP_write_verify, 4, 0, 1, 2);
+                generalParameters_LAYOUT->addWidget(RMAP_write_verify, 3, 0, 1, 2);
-                generalParameters_LAYOUT->addWidget(RMAP_write_reply, 5, 0, 1, 2);
+                generalParameters_LAYOUT->addWidget(RMAP_write_reply, 4, 0, 1, 2);
-                generalParameters_LAYOUT->setRowStretch(6, 1);
+                generalParameters_LAYOUT->setRowStretch(5, 1);
                 generalParameters_LAYOUT->setColumnStretch(2, 1);
                 gresb_GROUPBOX->setLayout(connectionLayout);
                 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
                 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()));
                 connect(this->selectGRESB_BUTTON, SIGNAL(clicked()), this, SLOT(selectionBetweenGresbAndStarDundee()));
                 connect(this->selectStarDundee_BUTTON, SIGNAL(clicked()), this, SLOT(selectionBetweenGresbAndStarDundee()));
-                connect(this->starDundee, SIGNAL(starDundeeIsOpen(bool)), this, SLOT(starDundeeIsOpen(bool)));
+                connect(this->starDundee, SIGNAL(isOpen(bool)), this, SLOT(isOpen(bool)));
+                connect(this->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->starDundee, 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(updateCommandCode(RMAP_command_codes)));
+                connect(this, SIGNAL(commandCodeHasChanged(RMAP_command_codes)), this->starDundee, SLOT(commandCodeHasChanged(RMAP_command_codes)));
                 getCommandCode(); // init the command code value
+                rmapTargetLogicalAddressSpinBox->setValue(254);
             }
             void rmapPluginUI::connectPort()
             {
                 //emit this->connectPortsig(ui->PortName->text(),ui->PortspeedSlider->value());
             }
             void rmapPluginUI::setConnected(bool connected)
             {
                 /*if(connected == true)
                 {
                     ui->OpenPort->setText(tr("Close port"));
                 }
                 else
                     ui->OpenPort->setText(tr("Open port"));*/
             }
             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::starDundeeIsOpen(bool flag)
+            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);
                 }
             }

rmapplugin/rmappluginui.h +2 -1

             /*------------------------------------------------------------------------------
             --  This file is a part of the LPPMON Software
             --  Copyright (C) 20011, Laboratory of Plasma Physics - 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 : Paul Leroy
             --                     Mail : paul.leroy@lpp.polytechnique.fr
             ----------------------------------------------------------------------------*/
             #ifndef RMAPPLUGINUI_H
             #define RMAPPLUGINUI_H
             #include <QWidget>
             #include <QPushButton>
             #include <QLabel>
             #include <QSlider>
             #include <QSpinBox>
             #include <QGridLayout>
             #include <QCheckBox>
             #include <QFile>
             #include <QTextStream>
             #include <QFileDialog>
             #include <QDir>
             #include <QDialog>
             #include <QCloseEvent>
             #include <QTabWidget>
             #include "qipdialogbox.h"
             #include <rmapoperations.h>
             #include <gresbstatusenquiry.h>
             #include <QTextEdit>
             #include "spectralmatricesdmasimulator.h"
             #include <stardundee.h>
             #include <gresb.h>
             #include <QRadioButton>
             #include <QGroupBox>
             enum selectedBridge{
                 selectedBridgeIsUnknown,
                 selectedBridgeIsGRESB,
                 selectedBridgeIsStarDundee
             };
             class rmapPluginUI : public QWidget
             {
                 Q_OBJECT
             public:
                 explicit rmapPluginUI(QWidget *parent = 0);
                 ~rmapPluginUI();
                 QPushButton* rmapOpenCommunicationButton;
                 QPushButton* rmapCloseCommunicationButton;
                 QPushButton* logFileChooseButton;
                 QPushButton* gresbStatusQueryRetryButton;
                 QPushButton* gresbStatusQueryAbortButton;
                 QPushButton* sendCCSDSCommandButton;
                 QPushButton* send_TC_LFR_UPDATE_TIME_Button;
                 QPushButton* reset_TC_LFR_UPDATE_TIME_Button;
                 QPushButton* clearConsoleButton;
                 QRadioButton* selectGRESB_BUTTON;
                 QRadioButton* selectStarDundee_BUTTON;
                 QGroupBox *selection_GROUPBOX;
                 QSpinBox* gresbVirtualLinkSpinBox;
                 QSpinBox* spwLinkSpinBox;
                 QSpinBox* rmapSourceLogicalAddressSpinBox;
                 QSpinBox* rmapTargetLogicalAddressSpinBox;
                 QSpinBox* CCSDSTargetLogicalAddressSpinBox;
                 QIPDialogBox* gresbBridgeIPDialogBox;
                 QCheckBox *logEnableCheckBox;
                 QCheckBox *RMAP_write_verify;
                 QCheckBox *RMAP_write_reply;
                 QLabel* rmapSendStateLabel;
                 QLabel* rmapReceiveStateLabel;
                 QLabel* gresbStatusQueryLabel;
                 QLabel* gresbStatusQueryDialogLabel;
                 QLabel* sendCCSDSCommandLabel;
                 QDialog* gresbStatusQueryDialog;
                 gresbStatusEnquiry* spwLinkStatusEnquiry;
                 SpectralMatricesDMASimulator *spectralMatricesDMASimulator;
                 QTextEdit* console;
                 StarDundee *starDundee;
                 gresb *gresbBridge;
                 bool islogfileenable();
                 void appendToLogFile(const QString & text);
                 void closeEvent(QCloseEvent *event);
             public slots:
                 void setConnected(bool connected);
                 void connectPort();
                 void chooseLogFile();
                 void logFileEnDisable(int state);
                 RMAP_command_codes getCommandCode();
             private slots:
                 void selectionBetweenGresbAndStarDundee();
-                void starDundeeIsOpen(bool flag);
+                void isOpen(bool flag);
             signals:
                 void connectPortsig(QString PortName,int baudrate);
                 void setLogFileName(QString FileName);
                 void commandCodeHasChanged(RMAP_command_codes commandCode);
                 void bridgeHasChanged(selectedBridge bridge);
+                void targetHasChanged(unsigned char target);
             private:
                 QLabel *gresbBridgeIPLabel;
                 QLabel *gresbVirtualLinkLabel;
                 QLabel *spwLinkLabel;
                 QLabel *rmapSourceLogicalAddressLabel;
                 QLabel *rmapTargetLogicalAddressLabel;
                 QLabel *logFileName;
                 QGridLayout *bridgeSelection_LAYOUT;
                 QVBoxLayout *selectionLayout;
                 QVBoxLayout *mainLayout;
                 QGridLayout *connectionLayout;
                 QVBoxLayout *ccsdsLayout;
                 QVBoxLayout *consoleLayout;
                 QGridLayout *gresbStatusQueryDialogLayout;
                 QGridLayout *generalParameters_LAYOUT;
                 QTabWidget *spwTabWidget;
                 QWidget* bridgeWidget;
                 QGroupBox *gresb_GROUPBOX;
                 QGroupBox *stardundee_GROUPBOX;
                 QGroupBox *generalParameters_GROUPBOX;
                 QFile *logFile;
                 QTextStream *logFileStrm;
                 bool logFileEn;
             };
             #endif // RMAPPLUGINUI_H

rmapplugin/stardundee.cpp +406 -222

This diff has been collapsed as it changes many lines, (628 lines changed) Show them Hide them
	@@ -1,529 +1,713
	1	#include "stardundee.h"	1	#include "stardundee.h"
	2	#include <QTime>	2	#include <QTime>
	3	#include <math.h>	3	#include <math.h>
	4		4
	5	StarDundee::StarDundee(QWidget *parent) :	5	StarDundee::StarDundee(QWidget *parent) :
	6	QWidget(parent)	6	QWidget(parent)
	7	{	7	{
			8	// Packet receiver
			9	rmapPacketSEMAPHORE = new QSemaphore;
			10	ccsdsPacketSEMAPHORE = new QSemaphore;
			11	rmapPacket = (char*) malloc(RMAP_MAX_PACKET_LENGTH);
			12	ccsdsPacket = (unsigned char*) malloc(CCSDS_MAX_PACKET_LENGTH);
			13	spwPacket = (char*) malloc( qMax(RMAP_MAX_PACKET_LENGTH, CCSDS_MAX_PACKET_LENGTH) );
			14
	8	commandCode = invalid0; // initialization of the cmmand code for the RMAP transfers	15	commandCode = invalid0; // initialization of the cmmand code for the RMAP transfers
	9	rmapPacket = (unsigned char*) malloc(RMAP_MAX_PACKET_LENGTH);
	10		16
	11	rmapTargetLogicalAddress = 0xfe;
	12	rmapSourceLogicalAddress = 0x20;	17	rmapSourceLogicalAddress = 0x20;
	13	connection_LAYOUT = new QGridLayout;	18	connection_LAYOUT = new QGridLayout;
	14		19
	15	sendPacket_BUTTON = new QPushButton(tr("Send a packet"));
	16	sendRMAPPacket_BUTTON = new QPushButton(tr("Write RMAP packet to the specified target"));
	17	readRMAPPacket_BUTTON = new QPushButton(tr("Read RMAP packet from the specified target"));
	18	getRoutingTableEntry_BUTTON = new QPushButton(tr("Get routing table entry (target logical address)"));
	19
	20	usbDeviceNumber_LABEL = new QLabel(tr("USB device number: "));	20	usbDeviceNumber_LABEL = new QLabel(tr("USB device number: "));
	21	linkNumber_LABEL = new QLabel(tr("SpaceWire link number: "));	21	linkNumber_LABEL = new QLabel(tr("SpaceWire link number: "));
	22	routingTableEntry_LABEL = new QLabel(tr("Target logical address: "));
	23	sourceLogicalAddress_LABEL = new QLabel(tr("Source logical address: "));	22	sourceLogicalAddress_LABEL = new QLabel(tr("Source logical address: "));
	24		23
	25	usbDeviceNumber_SPINBOX = new QSpinBox;	24	usbDeviceNumber_SPINBOX = new QSpinBox;
	26	usbDeviceNumber_SPINBOX->setRange(0,32);	25	usbDeviceNumber_SPINBOX->setRange(0,32);
	27	usbDeviceNumber_SPINBOX->setValue(0);	26	usbDeviceNumber_SPINBOX->setValue(0);
	28	linkNumber_SPINBOX = new QSpinBox;	27	linkNumber_SPINBOX = new QSpinBox;
	29	linkNumber_SPINBOX->setRange(1,2);	28	linkNumber_SPINBOX->setRange(1,2);
	30	linkNumber_SPINBOX->setValue(1);	29	linkNumber_SPINBOX->setValue(1);
	31	routingTableEntry_SPINBOX = new QSpinBox;
	32	routingTableEntry_SPINBOX->setRange(0, 254);
	33	routingTableEntry_SPINBOX->setValue(254);
	34	sourceLogicalAddress_SPINBOX = new QSpinBox;	30	sourceLogicalAddress_SPINBOX = new QSpinBox;
	35	sourceLogicalAddress_SPINBOX->setRange(0,254);	31	sourceLogicalAddress_SPINBOX->setRange(0,254);
	36	sourceLogicalAddress_SPINBOX->setValue(32);	32	sourceLogicalAddress_SPINBOX->setValue(32);
	37		33
	38	sendPacket_BUTTON->setEnabled(false);
	39	sendRMAPPacket_BUTTON->setEnabled(false);
	40	readRMAPPacket_BUTTON->setEnabled(false);
	41	getRoutingTableEntry_BUTTON->setEnabled(false);
	42
	43	connection_LAYOUT->addWidget(usbDeviceNumber_LABEL, 0, 0, 1, 1);	34	connection_LAYOUT->addWidget(usbDeviceNumber_LABEL, 0, 0, 1, 1);
	44	connection_LAYOUT->addWidget(usbDeviceNumber_SPINBOX, 0, 1, 1, 1);	35	connection_LAYOUT->addWidget(usbDeviceNumber_SPINBOX, 0, 1, 1, 1);
	45	connection_LAYOUT->addWidget(~~sendPacket_BUTTON~~, 1, 0, 1, 2);	36	connection_LAYOUT->addWidget(linkNumber_LABEL, 1, 0, 1, 1);
	46	connection_LAYOUT->addWidget(linkNumber_~~LABEL~~, 2, 0, 1, 1);	37	connection_LAYOUT->addWidget(linkNumber_SPINBOX, 1, 1, 1, 1);
	47	connection_LAYOUT->addWidget(~~linkNumber_SPINBOX~~, 2, 1, 1, 1);	38	connection_LAYOUT->addWidget(sourceLogicalAddress_LABEL, 2, 0, 1, 1);
	48	connection_LAYOUT->addWidget(sourceLogicalAddress_~~LABEL~~, 3, 0, 1, 1);	39	connection_LAYOUT->addWidget(sourceLogicalAddress_SPINBOX, 2, 1, 1, 1);
	49	connection_LAYOUT->addWidget(sourceLogicalAddress_SPINBOX, 3, 1, 1, 1);
	50	connection_LAYOUT->addWidget(routingTableEntry_LABEL, 4, 0, 1, 1);
	51	connection_LAYOUT->addWidget(routingTableEntry_SPINBOX, 4, 1, 1, 1);
	52	connection_LAYOUT->addWidget(sendRMAPPacket_BUTTON, 5, 0, 1, 2);
	53	connection_LAYOUT->addWidget(readRMAPPacket_BUTTON, 6, 0, 1, 2);
	54	connection_LAYOUT->addWidget(getRoutingTableEntry_BUTTON, 7, 0, 1, 2);
	55		40
	56	connection_LAYOUT->setRowStretch(8, 1);	41	connection_LAYOUT->setRowStretch(3, 1);
	57	connection_LAYOUT->setColumnStretch(2, 1);	42	connection_LAYOUT->setColumnStretch(2, 1);
	58		43
	59	this->setLayout(connection_LAYOUT);	44	this->setLayout(connection_LAYOUT);
	60		45
	61	connect(this->s~~endPacket_BUTTON~~, SIGNAL(~~click~~ed()), this, SLOT(~~SendPacket~~()));	46	connect(this->sourceLogicalAddress_SPINBOX, SIGNAL(valueChanged(int)), this, SLOT(sourceHasChanged(int)));
	62	connect(this->readRMAPPacket_BUTTON, SIGNAL(clicked()),this, SLOT(ReadRMAP()));
	63	connect(this->sendRMAPPacket_BUTTON, SIGNAL(clicked()), this, SLOT(SendRMAP()));
	64	connect(this->getRoutingTableEntry_BUTTON, SIGNAL(clicked()), this, SLOT(GetRoutingTableEntry()));
	65	}	47	}
	66		48
	67	StarDundee::~StarDundee()	49	StarDundee::~StarDundee()
	68	{	50	{
			51	free(rmapPacket);
			52	free(ccsdsPacket);
			53	free(spwPacket);
	69	USBSpaceWire_Close(hDevice); // Close the device	54	USBSpaceWire_Close(hDevice); // Close the device
	70	}	55	}
	71		56
	72	unsigned int StarDundee::Open~~StarDundee~~()	57	unsigned int StarDundee::Open()
	73	{	58	{
	74	int status;	59	int status;
	75	U32 statusControl;	60	U32 statusControl;
	76	U32 routingTableEntry;	61	U32 routingTableEntry;
	77	int tableEntry;	62	int tableEntry;
	78		63
	79	if (!USBSpaceWire_Open(&hDevice, usbDeviceNumber_SPINBOX->value())) // Open the USB device	64	if (!USBSpaceWire_Open(&hDevice, usbDeviceNumber_SPINBOX->value())) // Open the USB device
	80	{	65	{
	81	emit sendMessage("stardundee * Open * ERROR: USBSpaceWire_Open(&hDevice, 0))");	66	emit sendMessage("stardundee * Open * ERROR: USBSpaceWire_Open(&hDevice, 0))");
	82	return -1;	67	return -1;
	83	}	68	}
	84	emit sendMessage("stardundee * Open * USBSpaceWire_Open successful, device number: "	69	emit sendMessage("stardundee * Open * USBSpaceWire_Open successful, device number: "
	85	+ QString::number(usbDeviceNumber_SPINBOX->value()));	70	+ QString::number(usbDeviceNumber_SPINBOX->value()));
	86		71
	87	USBSpaceWire_EnableNetworkMode(hDevice, 0); // deactivate the network mode	72	USBSpaceWire_EnableNetworkMode(hDevice, 0); // deactivate the network mode
	88	CFGSpaceWire_EnableRMAP(1); // Enable the use of RMAP	73	CFGSpaceWire_EnableRMAP(1); // Enable the use of RMAP
	89	CFGSpaceWire_SetRMAPDestinationKey(0x20); // Set the destination key expected by STAR-Dundee devices	74	CFGSpaceWire_SetRMAPDestinationKey(0x20); // Set the destination key expected by STAR-Dundee devices
	90		75
	91	// Set the path and return path to the device	76	// Set the path and return path to the device
	92	CFGSpaceWire_StackClear();	77	CFGSpaceWire_StackClear();
	93	CFGSpaceWire_AddrStackPush(0);	78	CFGSpaceWire_AddrStackPush(0);
	94	CFGSpaceWire_AddrStackPush(254);	79	CFGSpaceWire_AddrStackPush(254);
	95	CFGSpaceWire_RetAddrStackPush(254);	80	CFGSpaceWire_RetAddrStackPush(254);
	96		81
	97	// set the base transmit rate to 100 MHz	82	// set the base transmit rate to 100 MHz
	98	status = CFGSpaceWire_SetBrickBaseTransmitRate( hDevice, CFG_BRK_CLK_100_MHZ, CFG_BRK_DVDR_1, 0xff);	83	status = CFGSpaceWire_SetBrickBaseTransmitRate( hDevice, CFG_BRK_CLK_100_MHZ, CFG_BRK_DVDR_1, 0xff);
	99	if (status != CFG_TRANSFER_SUCCESS)	84	if (status != CFG_TRANSFER_SUCCESS)
	100	{	85	{
	101	emit sendMessage("ERROR CFGSpaceWire_SetBrickBaseTransmitRate");	86	emit sendMessage("ERROR CFGSpaceWire_SetBrickBaseTransmitRate");
	102	}	87	}
	103	else emit sendMessage("OK CFGSpaceWire_SetBrickBaseTransmitRate, base rate = 100 MHz");	88	else emit sendMessage("OK CFGSpaceWire_SetBrickBaseTransmitRate, base rate = 100 MHz");
	104	// read the link status	89	// read the link status
	105	if (CFGSpaceWire_GetLinkStatusControl(hDevice, linkNumber_SPINBOX->value(), &statusControl) != CFG_TRANSFER_SUCCESS)	90	if (CFGSpaceWire_GetLinkStatusControl(hDevice, linkNumber_SPINBOX->value(), &statusControl) != CFG_TRANSFER_SUCCESS)
	106	{	91	{
	107	emit sendMessage("Could not read link status control for link " + QString::number(linkNumber_SPINBOX->value()));	92	emit sendMessage("Could not read link status control for link " + QString::number(linkNumber_SPINBOX->value()));
	108	}	93	}
	109	else	94	else
	110	{	95	{
	111	emit sendMessage("OK CFGSpaceWire_GetLinkStatusControl of link " + QString::number(linkNumber_SPINBOX->value()));	96	emit sendMessage("OK CFGSpaceWire_GetLinkStatusControl of link " + QString::number(linkNumber_SPINBOX->value()));
	112		97
	113	// Set the link status control register properties	98	// Set the link status control register properties
	114	CFGSpaceWire_LSEnableAutoStart(&statusControl, 1);	99	CFGSpaceWire_LSEnableAutoStart(&statusControl, 1);
	115	CFGSpaceWire_LSEnableStart(&statusControl, 1);	100	CFGSpaceWire_LSEnableStart(&statusControl, 1);
	116	CFGSpaceWire_LSEnableDisabled(&statusControl, 0);	101	CFGSpaceWire_LSEnableDisabled(&statusControl, 0);
	117	CFGSpaceWire_LSEnableTristate(&statusControl, 0);	102	CFGSpaceWire_LSEnableTristate(&statusControl, 0);
	118	CFGSpaceWire_LSSetOperatingSpeed(&statusControl, 9); // sets the link speed to ( 100 MHz / (9+1) ) = 10 MHz	103	CFGSpaceWire_LSSetOperatingSpeed(&statusControl, 9); // sets the link speed to ( 100 MHz / (9+1) ) = 10 MHz
	119		104
	120	// Set the link status control register	105	// Set the link status control register
	121	if (CFGSpaceWire_SetLinkStatusControl(hDevice, linkNumber_SPINBOX->value(), statusControl) != CFG_TRANSFER_SUCCESS)	106	if (CFGSpaceWire_SetLinkStatusControl(hDevice, linkNumber_SPINBOX->value(), statusControl) != CFG_TRANSFER_SUCCESS)
	122	{	107	{
	123	emit sendMessage("Could not set the link status control for link " + QString::number(linkNumber_SPINBOX->value()));	108	emit sendMessage("Could not set the link status control for link " + QString::number(linkNumber_SPINBOX->value()));
	124	}	109	}
	125	else emit sendMessage("Set the link status control for link " + QString::number(linkNumber_SPINBOX->value()));	110	else emit sendMessage("Set the link status control for link " + QString::number(linkNumber_SPINBOX->value()));
	126	}	111	}
	127		112
	128	// SET THE ROUTING TABLE ENTRY FOR LOGICAL ADDRESSING, TARGET 254 <=> 0xfe	113	// SET THE ROUTING TABLE ENTRY FOR LOGICAL ADDRESSING, TARGET 254 <=> 0xfe
	129	tableEntry = routingTableEntry_SPINBOX->value();	114	tableEntry = rmapTargetLogicalAddress;
	130	if (CFGSpaceWire_ClearRoutingTableEntry(hDevice, tableEntry) != CFG_TRANSFER_SUCCESS)	115	if (CFGSpaceWire_ClearRoutingTableEntry(hDevice, tableEntry) != CFG_TRANSFER_SUCCESS)
	131	{	116	{
	132	emit sendMessage("Could not clear routing table entry " + QString::number(tableEntry));	117	emit sendMessage("Could not clear routing table entry " + QString::number(tableEntry));
	133	}	118	}
	134	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] cleared");	119	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] cleared");
	135	// Build the routing table entry to route out of port 1 with header deletion disabled and priority normal	120	// Build the routing table entry to route out of port 1 with header deletion disabled and priority normal
	136	CFGSpaceWire_RTBuildRoutingTableEntry(&routingTableEntry,	121	CFGSpaceWire_RTBuildRoutingTableEntry(&routingTableEntry,
	137	(1<<linkNumber_SPINBOX->value()), // 0x02 = 0000 0010	122	(1<<linkNumber_SPINBOX->value()), // 0x02 = 0000 0010
	138	0,	123	0,
	139	0);	124	0);
	140	// Set the routing table entry for logical address tableEntry	125	// Set the routing table entry for logical address tableEntry
	141	if (CFGSpaceWire_SetRoutingTableEntry(hDevice, tableEntry, routingTableEntry) != CFG_TRANSFER_SUCCESS)	126	if (CFGSpaceWire_SetRoutingTableEntry(hDevice, tableEntry, routingTableEntry) != CFG_TRANSFER_SUCCESS)
	142	{	127	{
	143	emit sendMessage("Could not set routing table entry [" + QString::number(tableEntry) + "]");	128	emit sendMessage("Could not set routing table entry [" + QString::number(tableEntry) + "]");
	144	}	129	}
	145	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] set" );	130	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] set" );
	146		131
	147	// SET THE ROUTING TABLE ENTRY FOR LOGICAL ADDRESSING, TARGET 32 <=> 0x20	132	// SET THE ROUTING TABLE ENTRY FOR LOGICAL ADDRESSING, TARGET 32 <=> 0x20
	148	tableEntry = sourceLogicalAddress_SPINBOX->value();	133	tableEntry = sourceLogicalAddress_SPINBOX->value();
	149	if (CFGSpaceWire_ClearRoutingTableEntry(hDevice, tableEntry) != CFG_TRANSFER_SUCCESS)	134	if (CFGSpaceWire_ClearRoutingTableEntry(hDevice, tableEntry) != CFG_TRANSFER_SUCCESS)
	150	{	135	{
	151	emit sendMessage("Could not clear routing table entry " + QString::number(tableEntry));	136	emit sendMessage("Could not clear routing table entry " + QString::number(tableEntry));
	152	}	137	}
	153	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] cleared");	138	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] cleared");
	154		139
	155	// Build the routing table entry to route out of port 3 with header deletion disabled and priority normal	140	// Build the routing table entry to route out of port 3 with header deletion disabled and priority normal
	156	CFGSpaceWire_RTBuildRoutingTableEntry(&routingTableEntry,	141	CFGSpaceWire_RTBuildRoutingTableEntry(&routingTableEntry,
	157	(1<<3), // 0x02 = 0000 0010	142	(1<<3), // 0x02 = 0000 0010
	158	0,	143	0,
	159	0);	144	0);
	160	// Set the routing table entry for logical address tableEntry	145	// Set the routing table entry for logical address tableEntry
	161	if (CFGSpaceWire_SetRoutingTableEntry(hDevice, tableEntry, routingTableEntry) != CFG_TRANSFER_SUCCESS)	146	if (CFGSpaceWire_SetRoutingTableEntry(hDevice, tableEntry, routingTableEntry) != CFG_TRANSFER_SUCCESS)
	162	{	147	{
	163	emit sendMessage("Could not set routing table entry [" + QString::number(tableEntry) + "]");	148	emit sendMessage("Could not set routing table entry [" + QString::number(tableEntry) + "]");
	164	}	149	}
	165	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] set" );	150	else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] set" );
	166		151
	167	emit sendMessage("The driver's current send buffer size is " + QString::number(USBSpaceWire_GetDriverSendBufferSize(hDevice)) + " bytes");	152	emit sendMessage("The driver's current send buffer size is " + QString::number(USBSpaceWire_GetDriverSendBufferSize(hDevice)) + " bytes");
	168		153
	169	sendPacket_BUTTON->setEnabled(true);	154	USBSpaceWire_RegisterReceiveOnAllPorts(hDevice); // Register to receive on all ports
	170	sendRMAPPacket_BUTTON->setEnabled(true);	155	USBSpaceWire_ClearEndpoints(hDevice); // clear the USB endpoints
	171	readRMAPPacket_BUTTON->setEnabled(true);
	172	getRoutingTableEntry_BUTTON->setEnabled(true);
	173		156
	174	USBSpaceWire_RegisterReceiveOnAllPorts(hDevice); // Register to receive on all ports	157	// initialize SPW packet semaphores
			158	while (rmapPacketSEMAPHORE->available()!=0) rmapPacketSEMAPHORE->acquire();
			159	while (ccsdsPacketSEMAPHORE->available()!=0) ccsdsPacketSEMAPHORE->acquire();
	175		160
	176	emit ~~starDundeeI~~sOpen(true);	161	emit isOpen(true);
	177
	178	emit sendMessage("command code: " + QString::number(commandCode,16) );
	179		162
	180	return 1;	163	return 1;
	181	}	164	}
	182		165
	183	unsigned int StarDundee::Close~~StarDundee~~()	166	unsigned int StarDundee::Close()
	184	{	167	{
	185	USBSpaceWire_Close(hDevice); // Close the device	168	USBSpaceWire_Close(hDevice); // Close the device
	186	emit sendMessage("stardundee * Close * USBSpaceWire_Close, device: " + QString::number(usbDeviceNumber_SPINBOX->value()));	169	emit sendMessage("stardundee * Close * USBSpaceWire_Close, device: " + QString::number(usbDeviceNumber_SPINBOX->value()));
	187	sendPacket_BUTTON->setEnabled(false);
	188	sendRMAPPacket_BUTTON->setEnabled(false);
	189	readRMAPPacket_BUTTON->setEnabled(false);
	190	getRoutingTableEntry_BUTTON->setEnabled(false);
	191		170
	192	USBSpaceWire_UnregisterReceiveOnAllPorts(hDevice); // Stop receiving on all ports	171	USBSpaceWire_UnregisterReceiveOnAllPorts(hDevice); // Stop receiving on all ports
	193		172
	194	emit ~~starDundeeI~~sOpen(false);	173	emit isOpen(false);
	195		174
	196	return 1;	175	return 1;
	197	}	176	}
	198		177
	199	unsigned int StarDundee::GetRoutingTableEntry()	178	unsigned int StarDundee::GetRoutingTableEntry()
	200	{	179	{
	201	U32 routingTableEntry, outputPorts;	180	U32 routingTableEntry, outputPorts;
	202	char enabled, delHead, priority;	181	char enabled, delHead, priority;
	203	int portNum;	182	int portNum;
	204	int tableEntry;	183	int tableEntry;
	205		184
	206	tableEntry = routingTableEntry_SPINBOX->value();	185	tableEntry = rmapTargetLogicalAddress;
	207		186
	208	// Set the path and return path to the device	187	// Set the path and return path to the device
	209	CFGSpaceWire_StackClear();	188	CFGSpaceWire_StackClear();
	210	CFGSpaceWire_AddrStackPush(0);	189	CFGSpaceWire_AddrStackPush(0);
	211	CFGSpaceWire_AddrStackPush(254);	190	CFGSpaceWire_AddrStackPush(254);
	212	CFGSpaceWire_RetAddrStackPush(254);	191	CFGSpaceWire_RetAddrStackPush(254);
	213		192
	214	// Read the routing table entry	193	// Read the routing table entry
	215	if (CFGSpaceWire_GetRoutingTableEntry(hDevice, tableEntry, &routingTableEntry) != CFG_TRANSFER_SUCCESS)	194	if (CFGSpaceWire_GetRoutingTableEntry(hDevice, tableEntry, &routingTableEntry) != CFG_TRANSFER_SUCCESS)
	216	{	195	{
	217	emit sendMessage("Could not read routing table entry [" + QString::number(tableEntry) + "]");	196	emit sendMessage("Could not read routing table entry [" + QString::number(tableEntry) + "]");
	218	}	197	}
	219	else	198	else
	220	{	199	{
	221	// Display the routing table entry properties	200	// Display the routing table entry properties
	222	CFGSpaceWire_RTIsEnabled(routingTableEntry, &enabled);	201	CFGSpaceWire_RTIsEnabled(routingTableEntry, &enabled);
	223	CFGSpaceWire_RTIsDelHead(routingTableEntry, &delHead);	202	CFGSpaceWire_RTIsDelHead(routingTableEntry, &delHead);
	224	CFGSpaceWire_RTIsPriority(routingTableEntry, &priority);	203	CFGSpaceWire_RTIsPriority(routingTableEntry, &priority);
	225	CFGSpaceWire_RTGetOutputPorts(routingTableEntry, &outputPorts);	204	CFGSpaceWire_RTGetOutputPorts(routingTableEntry, &outputPorts);
	226	emit sendMessage("CFGSpaceWire_RTIsEnabled : " + QString::number(enabled));	205	emit sendMessage("CFGSpaceWire_RTIsEnabled : " + QString::number(enabled));
	227	emit sendMessage("CFGSpaceWire_RTIsDelHead : " + QString::number(delHead));	206	emit sendMessage("CFGSpaceWire_RTIsDelHead : " + QString::number(delHead));
	228	emit sendMessage("CFGSpaceWire_RTIsPriority : " + QString::number(priority));	207	emit sendMessage("CFGSpaceWire_RTIsPriority : " + QString::number(priority));
	229	emit sendMessage("CFGSpaceWire_RTGetOutputPorts : ");	208	emit sendMessage("CFGSpaceWire_RTGetOutputPorts : ");
	230	for (portNum = 0; portNum < 32; portNum++)	209	for (portNum = 0; portNum < 32; portNum++)
	231	{	210	{
	232	if (outputPorts & (1 << portNum))	211	if (outputPorts & (1 << portNum))
	233	{	212	{
	234	emit sendMessage(QString::number(portNum));	213	emit sendMessage(QString::number(portNum));
	235	}	214	}
	236	}	215	}
	237	}	216	}
	238		217
	239	return 1;	218	return 1;
	240	}	219	}
	241		220
	242	unsigned int StarDundee::SendPacket()	221	unsigned int StarDundee::Write(unsigned int *Value, unsigned int count, unsigned int address)
	243	{	222	{
	244	U32 nBufferSize; // The amount of data, in bytes, to be transmitted.	223	unsigned int remainingCount = count;
	245	char bWait; // If bWait is 0 then the transfer is started and the function returns immediately.	224	unsigned int iOffset = 0;
	246	// If bWait is not 0 then the function will return only when the transfer is completed or an error is detected.	225	QString console_message;
			226	char* data;
			227
			228	if(rmapPacketSEMAPHORE->available()!=0)
			229	{
			230	emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP request already running, WRITE access stopped");
			231	return 1;
			232	}
			233
			234	emit this->RMAP_write_reply_setText("reply to the write command required\nlast reply status: unavailable");
			235
			236	data = (char) malloc(READ_WRITE_MAX_COUNTS4);
			237
			238	emit appendToLog(QString("* START * WRITE ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
			239
			240	while (remainingCount > READ_WRITE_MAX_COUNTS)
			241	{
			242	for (int i = 0; i<READ_WRITE_MAX_COUNTS; i++)
			243	{
			244	data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
			245	data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
			246	data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
			247	data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
			248	}
			249
			250	console_message.sprintf("remainingCount: %d => ", remainingCount);
			251	emit appendToLog(console_message + QString("Write ")+ QString::number(READ_WRITE_MAX_COUNTS*4) + QString(" byte(s) @0x")+ QString::number(address,16));
	247		252
	248	nBufferSize = 10;	253	if(WriteBLOCK(data, READ_WRITE_MAX_COUNTS*4, address)==0)
	249	bWait = 1;	254	{
	250	// Send the packet and wait on it completing	255	emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
	251	result = USBSpaceWire_SendPacket(hDevice, pBuffer, nBufferSize, bWait, &pIdentifier);	256	return 1;
	252	if (result != TRANSFER_SUCCESS)	257	}
			258
			259	remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
			260	address = address + READ_WRITE_MAX_COUNTS * 4;
			261	iOffset = iOffset + READ_WRITE_MAX_COUNTS;
			262	}
			263
			264	if (remainingCount > 0)
	253	{	265	{
	254	emit sendMessage("Error: Could not send the packet");	266	for (unsigned int i = 0; i<remainingCount; i++)
	255	}	267	{
	256	else emit sendMessage("The packet has been successfully sent");	268	data[i*4+3] = (char) ((unsigned int) Value[i+iOffset]);
			269	data[i*4+2] = (char) ((unsigned int) Value[i+iOffset]>>8);
			270	data[i*4+1] = (char) ((unsigned int) Value[i+iOffset]>>16);
			271	data[i*4+0] = (char) ((unsigned int) Value[i+iOffset]>>24);
			272	}
			273
			274	console_message.sprintf("remainingCount: %d => ", remainingCount);
			275	emit appendToLog(console_message + QString("Write ")+ QString::number(remainingCount*4) + QString(" byte(s) @0x")+ QString::number(address,16));
	257		276
	258	// Free the send	277	if (WriteBLOCK(data, remainingCount*4, address)==0)
	259	USBSpaceWire_FreeSend(hDevice, pIdentifier);	278	{
			279	emit appendToLog("WARNING === in function WRITE of rmapplugin *** RMAP write command failed");
			280	return 1;
			281	}
			282	}
	260		283
	261	return 1;	284	emit appendToLog(QString("* STOP * WRITE"));
			285	free(data);
			286	return count;
	262	}	287	}
	263		288
	264	unsigned int StarDundee::SendRMAP()	289	unsigned int StarDundee::Read(unsigned int *Value, unsigned int count, unsigned int address)
	265	{	290	{
	266	unsigned int ~~Value~~[4];	291	unsigned int remainingCount = count;
	267	unsigned int ~~coun~~t = 4;	292	unsigned int iOffset = 0;
	268	unsigned int address = 0x40000000;	293	QString console_message;
	269	Value[0] = 0xabcd1234;	294
	270	Value[1] = 0xbb;	295	if(rmapPacketSEMAPHORE->available()!=0)
	271	Value[2] = 0xab;	296	{
	272	Value[3] = 0xcd;	297	emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP request already running, READ access stopped");
	273	WriteStarDundee(Value, count, address);	298	return 1;
	274	return 1;	299	}
			300	emit appendToLog(QString("* START * READ ")+ QString::number(count) + QString(" word(s) @0x")+ QString::number(address,16));
			301
			302	while (remainingCount > READ_WRITE_MAX_COUNTS)
			303	{
			304	console_message.sprintf("remainingCount: %d => ", remainingCount);
			305	emit appendToLog(console_message + QString("Read ")+ QString::number(4*READ_WRITE_MAX_COUNTS) + QString(" byte(s) @0x")+ QString::number(address,16));
			306
			307	if (this->ReadBLOCK(READ_WRITE_MAX_COUNTS*4, address)==0)
			308	{
			309	emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP packet not received");
			310	return 1;
			311	}
			312
			313	for(int i=0;i<READ_WRITE_MAX_COUNTS;i++)
			314	{
			315	Value[i+iOffset] = (unsigned char) rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
			316	for(int j=1;j<4;j++)
			317	{
			318	Value[i+iOffset]= ((unsigned char) (rmapPacket[i*4+j+RMAP_READ_REPLY_HEADER_LENGTH]))
			319	+ Value[i+iOffset]*256;
			320	}
			321	}
			322
			323	remainingCount = remainingCount - READ_WRITE_MAX_COUNTS;
			324	address = address + READ_WRITE_MAX_COUNTS * 4;
			325	iOffset = iOffset + READ_WRITE_MAX_COUNTS;
			326	this->acquireRMAPSemaphore();
			327	}
			328
			329	if (remainingCount > 0)
			330	{
			331	console_message.sprintf("remainingCount: %d => ", remainingCount);
			332	emit appendToLog(console_message + QString("Read ")+ QString::number(4*remainingCount) + QString(" byte(s) @0x")+ QString::number(address,16));
			333
			334	if (this->ReadBLOCK(4*remainingCount, address)==0)
			335	{
			336	emit appendToLog("WARNING === in function READ of rmapplugin *** RMAP packet not received");
			337	return 1;
			338	}
			339
			340	for(unsigned int i=0;i<remainingCount;i++)
			341	{
			342	Value[i+iOffset] = (unsigned char) rmapPacket[i*4+RMAP_READ_REPLY_HEADER_LENGTH];
			343	for(int j=1;j<4;j++)
			344	{
			345	Value[i+iOffset]= ((unsigned char)(rmapPacket[i4+j+RMAP_READ_REPLY_HEADER_LENGTH])) + Value[i+iOffset]256;
			346	}
			347	}
			348	this->acquireRMAPSemaphore();
			349	}
			350
			351	emit appendToLog(QString("* STOP * READ "));
			352	return count;
	275	}	353	}
	276		354
	277	unsigned int StarDundee::ReadRMAP()	355	unsigned int StarDundee::WriteBLOCK(char *data, unsigned int nbBytes, unsigned int address)
	278	{
	279	unsigned int Value[100000];
	280	unsigned int count = 100000;
	281	unsigned int address = 0x40000000;
	282	unsigned int result;
	283	result = ReadStarDundee(Value, count, address);
	284	emit sendMessage("ReadRMAP, nbBytes: " + QString::number(result));
	285	emit sendMessage("Value[0]: " + QString::number(Value[0], 16));
	286	emit sendMessage("Value[1]: " + QString::number(Value[1], 16));
	287	emit sendMessage("Value[2]: " + QString::number(Value[2], 16));
	288	emit sendMessage("Value[3]: " + QString::number(Value[3], 16));
	289	return 1;
	290	}
	291
	292	unsigned int StarDundee::ReadStarDundee(unsigned int *Value, unsigned int count, unsigned int address)
	293	{	356	{
	294	RMAP *RMAPCommand;	357	RMAP *RMAPCommand;
	295	rmap_read_reply_PcktHdr_t rmapReplyHeader;	358	char * packet;
	296	USB_SPACEWIRE_STATUS result; // The result of the receive operation	359	unsigned char offset, headerSize, CRCSize;
	297	USB_SPACEWIRE_PACKET_PROPERTIES properties; // The properties of the read	360	char* aux;
	298	unsigned int ~~nbBytes~~;	361	unsigned int totalSize;
	299	unsigned char* packet;	362	int errorCode;
	300	U32 nPacketNum;	363	QString console_message;
	301	unsigned int offset;
	302	unsigned int i;
	303		364
	304	//**********************	365	if (getLinkStatus(this->linkNumber_SPINBOX->value()) == 0)
	305	// SEND THE READ COMMAND
	306	nbBytes = 4 * count;
	307	if (nbBytes > 4)
	308	{	366	{
	309	RMAPCommand = new RMAP(read_Inc, // build the command	367	this->Close();
	310	rmapTargetLogicalAddress,	368	return 1;
	311	rmapSourceLogicalAddress,
	312	address,
	313	nbBytes,
	314	NULL);
	315	}
	316	else
	317	{
	318	RMAPCommand = new RMAP(read_Single, // build the command
	319	rmapTargetLogicalAddress,
	320	rmapSourceLogicalAddress,
	321	address,
	322	nbBytes,
	323	NULL);
	324	}	369	}
	325		370
	326	result = USBSpaceWire_SendPacket(hDevice,	371	RMAPCommand = new RMAP(this->commandCode,
	327	(unsigned char) ((void) &RMAPCommand->RMAPHeader),
	328	sizeof(RMAPCommand->RMAPHeader),
	329	BWAIT_1, &pIdentifier);
	330	if (result != TRANSFER_SUCCESS) emit sendMessage("ERROR *** ReadStarDundee when sending the READ command ");
	331	else emit sendMessage("OK *** ReadStarDundee when sending the READ command");
	332
	333	//*****************
	334	// RECEIVE THE DATA
	335	nbBytes = sizeof(rmapReplyHeader) + 4 * count + 1; // 1 is for the data CRC
	336	packet = (unsigned char *) malloc(nbBytes);
	337	nPacketNum = 1;
	338	result = USBSpaceWire_ReadPackets(hDevice, packet, nbBytes, nPacketNum, BWAIT_1, &properties, &pIdentifier);
	339	if (result != TRANSFER_SUCCESS) emit sendMessage("Error: Could not receive the packet");
	340	else
	341	{
	342	emit sendMessage("A packet of length " + QString::number(properties.len) + " has been successfully received");
	343	offset = sizeof(rmapReplyHeader);
	344	for(i=0; i<count; i++)
	345	{
	346	Value[i] = packet[offset+3];
	347	Value[i] = Value[i] + packet[offset+2] * pow(2, 8);
	348	Value[i] = Value[i] + packet[offset+1] * pow(2, 16);
	349	Value[i] = Value[i] + packet[offset+0] * pow(2, 24);
	350	offset = offset + 4;
	351	}
	352	free(packet);
	353	USBSpaceWire_FreeRead(hDevice, pIdentifier); // Free the receive
	354	return count;
	355	}
	356
	357	return 1;
	358	}
	359
	360	unsigned int StarDundee::WriteStarDundee(unsigned int *Value, unsigned int count, unsigned int address)
	361	{
	362	RMAP *RMAPCommand;
	363	unsigned char *data;
	364	char *dataCHAR;
	365	unsigned char *aux;
	366	unsigned int offset;
	367	U32 dataSize, headerSize, CRCSize, totalSize; // sizes in bytes
	368	U32 nPacketNum;
	369	USB_SPACEWIRE_PACKET_PROPERTIES properties; // The properties of the read
	370	rmap_write_reply_t rmapReplyHeader;
	371
	372	dataSize = count * 4;
	373	dataCHAR = (char *) malloc(dataSize);
	374	for (unsigned int i = 0; i<count; i++)
	375	{
	376	dataCHAR[i*4+3] = (char) ((unsigned int) Value[i]);
	377	dataCHAR[i*4+2] = (char) ((unsigned int) Value[i]>>8);
	378	dataCHAR[i*4+1] = (char) ((unsigned int) Value[i]>>16);
	379	dataCHAR[i*4+0] = (char) ((unsigned int) Value[i]>>24);
	380	}
	381
	382	RMAPCommand = new RMAP(commandCode,
	383	rmapTargetLogicalAddress,	372	rmapTargetLogicalAddress,
	384	rmapSourceLogicalAddress,	373	rmapSourceLogicalAddress,
	385	address,	374	address,
	386	~~dataSize~~,	375	nbBytes,
	387	data~~CHAR~~);	376	data);
	388	free(dataCHAR);
	389	headerSize = sizeof(RMAPCommand->RMAPHeader);	377	headerSize = sizeof(RMAPCommand->RMAPHeader);
	390	CRCSize = 1;	378	CRCSize = 1;
	391		379
	392	//*************************	380	//*************************
	393	// BUILD THE PACKET TO SEND	381	// BUILD THE PACKET TO SEND
	394	totalSize = headerSize + ~~dataSize~~ + CRCSize;	382	totalSize = headerSize + nbBytes + CRCSize;
	395	~~data~~ = (~~unsigned~~ char*) malloc( totalSize );	383	packet = (char*) malloc( totalSize );
	396	aux = (~~unsigned~~ char) ((void) &RMAPCommand->RMAPHeader);	384	aux = (char) ((void) &RMAPCommand->RMAPHeader);
	397	for(unsigned int i = 0; i<headerSize; i++) ~~data~~[i] = aux[i];	385	for(unsigned int i = 0; i<headerSize; i++) packet[i] = aux[i];
	398	offset = headerSize;	386	offset = headerSize;
	399	for(unsigned int i = 0; i<~~cou~~nt; i++)	387	for(unsigned int i = 0; i<nbBytes; i++)
	400	{	388	{
	401	~~data~~[offset+3] = (~~unsigned~~ ~~char~~) (~~Value~~[i]);	389	packet[i+offset] = data[i];
	402	data[offset+2] = (unsigned char) (Value[i]>>8);
	403	data[offset+1] = (unsigned char) (Value[i]>>16);
	404	data[offset] = (unsigned char) (Value[i]>>24);
	405	offset = offset + 4;
	406	}	390	}
	407	~~data~~[offset] = RMAPCommand->dataCRC;	391	packet[nbBytes+offset] = RMAPCommand->dataCRC;
	408		392
	409	//************	393	//****************
	410	// SEND THE PACKET	394	// SEND THE PACKET
	411	result = USBSpaceWire_SendPacket(hDevice,	395	result = USBSpaceWire_SendPacket(hDevice,
	412	~~data~~,	396	packet,
	413	totalSize,	397	totalSize,
	414	BWAIT_1, &pIdentifier);	398	BWAIT_1, &pIdentifier);
	415	if (result != TRANSFER_SUCCESS)	399	if (result != TRANSFER_SUCCESS)
	416	{	400	{
	417	emit sendMessage("ERROR *** WriteStarDundee when sending packet of size "	401	emit sendMessage("ERROR *** WriteStarDundee when sending packet of size "
	418	+ QString::number(totalSize) +", with code: " + QString::number(result));	402	+ QString::number(totalSize) +", with code: " + QString::number(result));
	419	USBSpaceWire_FreeSend(hDevice, pIdentifier);	403	USBSpaceWire_FreeSend(hDevice, pIdentifier);
	420	free(data);	404	free(data);
	421	return 1;	405	return 1;
	422	}	406	}
	423	else emit sendMessage("OK *** WriteStarDundee when sending packet of size " + QString::number(totalSize));	407	else emit sendMessage("OK *** WriteStarDundee when sending packet of size " + QString::number(totalSize));
	424		408
	425	//**************	409	//**************
	426	// Free the send	410	// Free the send
	427	USBSpaceWire_FreeSend(hDevice, pIdentifier);	411	USBSpaceWire_FreeSend(hDevice, pIdentifier);
	428	free(~~data~~);	412	free(packet);
	429		413
	430	if ( (commandCode == writeSingle_noVer_Rep) \| (commandCode == writeInc_noVer_Rep) \|	414	if ( (commandCode == writeSingle_noVer_Rep) \| (commandCode == writeInc_noVer_Rep) \|
	431	(commandCode == writeSingle_ver_rep) \| (commandCode == writeInc_ver_rep) )	415	(commandCode == writeSingle_ver_rep) \| (commandCode == writeInc_ver_rep) )
	432	{	416	{
	433	//***********************	417	// WAIT FOR THE RMAP REPLY PACKET
	434	// RECEIVE THE RMAP REPLY	418	errorCode = this->receiveSPWPacket(1);
	435	totalSize = sizeof(rmapReplyHeader);	419	if (errorCode<=0)
	436	nPacketNum = 1;
	437	result = USBSpaceWire_ReadPackets(hDevice, (char *) &rmapReplyHeader, totalSize, nPacketNum, BWAIT_1, &properties, &pIdentifier);
	438	if (result != TRANSFER_SUCCESS)
	439	{	420	{
	440	emit sendMessage("Error: Could not receive the RMAP reply");	421	emit appendToLog("WARNING === in function WriteBLOCK of rmapplugin *** RMAP packet reception failed with code " + QString::number(errorCode));
	441	USBSpaceWire_FreeRead(hDevice, pIdentifier); // Free the receive	422	return 0;
	442	return 1;
	443	}
	444	else
	445	{
	446	emit sendMessage("An RMAP reply of length " + QString::number(properties.len) + " has been successfully received");
	447	USBSpaceWire_FreeRead(hDevice, pIdentifier); // Free the receive
	448	}	423	}
	449	if(~~properties~~.~~len~~ != 8)	424	if(rmapPacketSize != 8)
	450	{	425	{
	451	~~emit~~ ~~appendToLog~~("WARNING === in function WRITE (with reply) of rmapplugin *** write reply format not compliant\n");	426	console_message.sprintf("WARNING === in function WRITE (with reply) of rmapplugin *** write reply format not compliant\n");
	452	return 1;	427	emit appendToLog(console_message);
			428	return 0;
	453	}	429	}
	454	emit sendMessage("data CRC " + QString::number(RMAPCommand->dataCRC, 16) );	430	switch (this->rmapPacket[3]) // byte 4 is the status byte in the reply
	455	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.initiatorLogicalAddress, 16) );
	456	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.protocolIdentifier, 16) );
	457	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.instruction, 16) );
	458	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.status, 16) );
	459	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.targetLogicalAddress, 16) );
	460	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.transactionIdentifier1, 16) );
	461	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.transactionIdentifier2, 16) );
	462	emit sendMessage("rmapReplyHeader " + QString::number(rmapReplyHeader.headerCRC, 16) );
	463	switch (rmapReplyHeader.status) // byte 4 is the status byte in the reply
	464	{	431	{
	465	case 0:	432	case 0:
	466	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 0 Successfull");	433	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 0 Successfull");
	467	break;	434	break;
	468	case 1:	435	case 1:
	469	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** General error code");	436	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** General error code");
	470	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 1 General error code");	437	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 1 General error code");
	471	break;	438	break;
	472	case 2:	439	case 2:
	473	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Unused RMAP packet type or command code");	440	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Unused RMAP packet type or command code");
	474	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 2 Unused RMAP packet type or command code");	441	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 2 Unused RMAP packet type or command code");
	475	break;	442	break;
	476	case 3:	443	case 3:
	477	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid key");	444	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid key");
	478	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 3 Invalid key");	445	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 3 Invalid key");
	479	break;	446	break;
	480	case 4:	447	case 4:
	481	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid data CRC");	448	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid data CRC");
	482	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 4 Invalid data CRC");	449	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 4 Invalid data CRC");
	483	break;	450	break;
	484	case 5:	451	case 5:
	485	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Early EOP");	452	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Early EOP");
	486	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 5 Early EOP");	453	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 5 Early EOP");
	487	break;	454	break;
	488	case 6:	455	case 6:
	489	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Too much data");	456	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Too much data");
	490	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 6 Too much data");	457	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 6 Too much data");
	491	break;	458	break;
	492	case 7:	459	case 7:
	493	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** EEP");	460	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** EEP");
	494	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 7 EEP");	461	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 7 EEP");
	495	break;	462	break;
	496	case 8:	463	case 8:
	497	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Reserved");	464	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Reserved");
	498	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 8 Reserved");	465	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 8 Reserved");
	499	break;	466	break;
	500	case 9:	467	case 9:
	501	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Verify buffer overrun");	468	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Verify buffer overrun");
	502	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 9 Verify buffer overrun");	469	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 9 Verify buffer overrun");
	503	break;	470	break;
	504	case 10:	471	case 10:
	505	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** RMAP command not implemented or not authorised");	472	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** RMAP command not implemented or not authorised");
	506	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 10 RMAP command not implemented or not authorised");	473	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 10 RMAP command not implemented or not authorised");
	507	break;	474	break;
	508	case 11:	475	case 11:
	509	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** RMW data length error");	476	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** RMW data length error");
	510	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 11 RMAP RMW data length error");	477	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 11 RMAP RMW data length error");
	511	break;	478	break;
	512	case 12:	479	case 12:
	513	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid target logical address");	480	emit appendToLog("WARNING === in function WRITE (with reply) of rmapplugin *** Invalid target logical address");
	514	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 12 Invalid target logical address");	481	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: 12 Invalid target logical address");
	515	break;	482	break;
	516	}	483	}
			484	this->acquireRMAPSemaphore();
	517	}	485	}
	518	else	486	else
	519	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: unavailable");	487	emit RMAP_write_reply_setText("reply to the write command required\nlast reply status: unavailable");
	520	return count;	488
			489	return nbBytes;
			490	}
			491
			492	unsigned int StarDundee::ReadBLOCK(unsigned int nbBytes, unsigned int address)
			493	{
			494	int errorCode;
			495	RMAP *RMAPCommand;
			496	unsigned int dataLength;
			497
			498	//**********************
			499	// Check the link status
			500	if ( getLinkStatus( this->linkNumber_SPINBOX->value() ) == 0 )
			501	{
			502	this->Close();
			503	emit appendToLog("WARNING === in function WriteSPW of StarDundee *** SPW link not running\n");
			504	return 0;
			505	}
			506
			507	//**********************
			508	// SEND THE READ COMMAND
			509	if (nbBytes > 4)
			510	{
			511	RMAPCommand = new RMAP(read_Inc,
			512	rmapTargetLogicalAddress,
			513	rmapSourceLogicalAddress,
			514	address,
			515	nbBytes,
			516	NULL);
			517	}
			518	else
			519	{
			520	RMAPCommand = new RMAP(read_Single,
			521	rmapTargetLogicalAddress,
			522	rmapSourceLogicalAddress,
			523	address,
			524	nbBytes,
			525	NULL);
			526	}
			527	result = USBSpaceWire_SendPacket(hDevice,
			528	(unsigned char) ((void) &RMAPCommand->RMAPHeader),
			529	sizeof(RMAPCommand->RMAPHeader),
			530	BWAIT_1, &pIdentifier);
			531	if (result != TRANSFER_SUCCESS) emit sendMessage("ERR * ReadStarDundee * ReadBLOCK *** sending the READ command ");
			532	else emit sendMessage("OK * ReadStarDundee * ReadBLOCK *** sending the READ command");
			533
			534	//*********************************
			535	// RECEIVE THE INCOMING RMAP PACKET
			536	errorCode = this->receiveSPWPacket(1); // request ID 1 is for RMAP packet
			537	if (errorCode<=0)
			538	{
			539	emit appendToLog("WARNING === in function ReadBLOCK of StarDundee *** RMAP packet reception failed with code " + QString::number(errorCode));
			540	return 0;
			541	}
			542	dataLength = rmapPacketSize - RMAP_READ_REPLY_HEADER_LENGTH - RMAP_DATA_CRC_LENGTH;
			543	if(dataLength != nbBytes)
			544	{
			545	emit appendToLog("WARNING === in function READ of StarDundee *** number of data received ("
			546	+QString::number(dataLength)
			547	+") not equal to number of data requested ("
			548	+QString::number(nbBytes)
			549	+")");
			550	return 0;
			551	}
			552	return dataLength;
	521	}	553	}
	522		554
	523	//******	555	unsigned int StarDundee::WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication)
	524	// SLOTS	556	{
			557	char protocoleIdentifier = 0x02;
			558	char reserved = 0x00;
			559	char *SPWData;
			560	unsigned int totalSize;
			561
			562	if (count>248)
			563	{
			564	emit appendToLog("WARNING === in function WRITE of rmapplugin *** CCSDS packet size > 248 bytes\n");
			565	return 1;
			566	}
			567
			568	emit appendToLog("* START * Send CCSDS packet of "+ QString::number(count) + " byte(s)");
			569
			570	if ( getLinkStatus( this->linkNumber_SPINBOX->value() ) == 0 )
			571	{
			572	this->Close();
			573	emit appendToLog("WARNING === in function WriteSPW of StarDundee *** SPW link not running\n");
			574	return 1;
			575	}
			576
			577	totalSize = count + 4;
			578	SPWData = (char*) malloc(totalSize);
			579	// SPW HEADER
			580	SPWData[0] = targetLogicalAddress;
			581	SPWData[1] = protocoleIdentifier;
			582	SPWData[2] = reserved;
			583	SPWData[3] = userApplication;
			584	// CCSDS PACKET
			585	for (unsigned int i = 0; i<count; i++)
			586	{
			587	SPWData[i+4] = Value[i];
			588	}
			589
			590	//************
			591	// SEND THE PACKET
			592	result = USBSpaceWire_SendPacket(hDevice,
			593	SPWData,
			594	totalSize,
			595	BWAIT_1, &pIdentifier);
			596	if (result != TRANSFER_SUCCESS)
			597	{
			598	emit sendMessage("ERROR *** WriteSPW when sending packet of size "
			599	+ QString::number(totalSize) +", with code: " + QString::number(result));
			600	USBSpaceWire_FreeSend(hDevice, pIdentifier);
			601	free(SPWData);
			602	return 0;
			603	}
			604	else emit sendMessage("OK *** WriteSPW when sending packet of size " + QString::number(totalSize));
			605
			606	//**************
			607	// Free the send
			608	USBSpaceWire_FreeSend(hDevice, pIdentifier);
			609	free(SPWData);
			610
			611	emit appendToLog(QString("*** CCSDS packet sent"));
			612
			613	return 1;
			614	}
			615
			616	unsigned int StarDundee::getLinkStatus(unsigned char link)
			617	{
			618	U32 statusControl, errorStatus, portType;
			619	U32 linkStatus, operatingSpeed, outputPortConnection;
			620	char isLinkRunning, isAutoStart, isStart, isDisabled, isTristate;
	525		621
	526	void StarDundee::updateCommandCode(RMAP_command_codes code)	622	// Read the link status control register
			623	if (CFGSpaceWire_GetLinkStatusControl(hDevice, 1, &statusControl) != CFG_TRANSFER_SUCCESS)
			624	{
			625	emit appendToLog("Could not read link status control for link" + QString::number(link));
			626	}
			627	else
			628	{
			629	// Display the link status control register properties
			630	CFGSpaceWire_LSPortType(statusControl, &portType);
			631	if (portType == CFG_CONFIGURATION_PORT)
			632	{
			633	CFGSpaceWire_LSConfigErrorStatus(statusControl, &errorStatus);
			634	//emit appendToLog("Configuration port error status = " + QString::number(errorStatus));
			635	}
			636	else if (portType == CFG_SPACEWIRE_EXTERNAL_PORT)
			637	{
			638	CFGSpaceWire_LSExternalErrorStatus(statusControl, &errorStatus);
			639	//emit appendToLog("External port error status = " + QString::number(errorStatus));
			640	}
			641	else
			642	{
			643	CFGSpaceWire_LSErrorStatus(statusControl, &errorStatus);
			644	//emit appendToLog("SpaceWire link error status = " + QString::number(errorStatus));
			645	}
			646	CFGSpaceWire_LSLinkState(statusControl, &linkStatus);
			647	CFGSpaceWire_LSIsLinkRunning(statusControl, &isLinkRunning);
			648	CFGSpaceWire_LSIsAutoStart(statusControl, &isAutoStart);
			649	CFGSpaceWire_LSIsStart(statusControl, &isStart);
			650	CFGSpaceWire_LSIsDisabled(statusControl, &isDisabled);
			651	CFGSpaceWire_LSIsTristate(statusControl, &isTristate);
			652	CFGSpaceWire_LSOperatingSpeed(statusControl, &operatingSpeed);
			653	CFGSpaceWire_LSOutputPortConnection(statusControl, &outputPortConnection);
			654	//emit appendToLog("The link state is = " + QString::number(linkStatus));
			655	//emit appendToLog("The link is running = " + QString::number(isLinkRunning));
			656	//emit appendToLog("The autostart bit is enabled = " + QString::number(isAutoStart));
			657	//emit appendToLog("The start bit is enabled = " + QString::number(isStart));
			658	//emit appendToLog("The link is disabled = " + QString::number(isDisabled));
			659	//emit appendToLog("The tri-state bit is enabled = " + QString::number(isAutoStart));
			660	//emit appendToLog("The operating speed is = " + QString::number(operatingSpeed));
			661	//emit appendToLog("This port is currently connected to output port = " + QString::number(outputPortConnection));
			662	}
			663	if (linkStatus == 5) return 1;
			664	else return 0;
			665	}
			666
			667	int StarDundee::receiveSPWPacket(unsigned char requestID) // SLOT
	527	{	668	{
	528	this->commandCode = code;	669	unsigned int packetLength;
			670	unsigned int nbBytes;
			671	unsigned nPacketNum;
			672	USB_SPACEWIRE_PACKET_PROPERTIES properties; // The properties of the read
			673
			674	if (requestID==1)
			675	{
			676	if (rmapPacketSEMAPHORE->available()) return rmapPacketSize;
			677	}
			678
			679	//********************
			680	// TRY TO RECEIVE DATA
			681	nbBytes = qMax(RMAP_MAX_PACKET_LENGTH, CCSDS_MAX_PACKET_LENGTH); // maximum size of the packet to receive
			682	nPacketNum = 1;
			683	result = USBSpaceWire_ReadPackets(hDevice, spwPacket, nbBytes, nPacketNum, BWAIT_1, &properties, &pIdentifier);
			684	if (result != TRANSFER_SUCCESS) emit sendMessage("Error: Could not receive the packet");
			685	else
			686	{
			687	emit sendMessage("A packet of length " + QString::number(properties.len) + " has been successfully received");
			688	USBSpaceWire_FreeRead(hDevice, pIdentifier); // Free the receive
			689	}
			690	packetLength = properties.len;
			691
			692	switch(spwPacket[1]) // byte 1 is the protocole identifier in the SPW packet
			693	{
			694	case 1: // 0x01 is the protocole identifier for RMAP packets
			695	if (rmapPacketSEMAPHORE->available()!=0) return -3; // ERROR === previous RMAP packet not processed yet
			696	for(unsigned int i=0; i<packetLength; i++) rmapPacket[i] = spwPacket[i];
			697	rmapPacketSize = packetLength;
			698	rmapPacketSEMAPHORE->release();
			699	emit sendMessage("RMAP packet of size " + QString::number(packetLength) + " received");
			700	return packetLength;
			701
			702	case 2: // 0x02 is the protocole identifier for CCSDS packets
			703	if (ccsdsPacketSEMAPHORE->available()!=0) return -4; // ERROR === previous CCSDS packet not processed yet
			704	for(unsigned int i=0; i<packetLength; i++) ccsdsPacket[i] = spwPacket[i];
			705	ccsdsPacketSize = packetLength;
			706	ccsdsPacketSEMAPHORE->release();
			707	emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
			708	return packetLength;
			709	}
			710	return 0;
	529	}	711	}
			712
			713

rmapplugin/stardundee.h +31 -21

             #ifndef STARDUNDEE_H
             #define STARDUNDEE_H
             #include <QWidget>
             #include "spw_usb_api.h"
             #include "spw_config_library.h"
             #include <QPushButton>
             #include <QGridLayout>
             #include <QSpinBox>
             #include <QLabel>
+            #include <QSemaphore>
             #include "rmapoperations.h"
             #define BWAIT_0 0
             #define BWAIT_1 1
             class StarDundee : public QWidget
             {
                 Q_OBJECT
             public:
                 explicit StarDundee(QWidget *parent = 0);
                 ~StarDundee();
-                unsigned int WriteStarDundee(unsigned int *Value,unsigned int count,unsigned int address=0);
+                unsigned int Write(unsigned int *Value,unsigned int count,unsigned int address=0);
-                unsigned int ReadStarDundee(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 WriteStarDundee(unsigned int *Value, unsigned int count, unsigned int address);
+                unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
+                unsigned int getLinkStatus(unsigned char link);
             signals:
                 void sendMessage(QString message);
-                void starDundeeIsOpen(bool);
+                void isOpen(bool);
                 void RMAP_write_reply_setText(QString);
                 void appendToLog(QString);
+                void ccsdsPacketAvailable(unsigned char*, unsigned int);
             public slots:
-                unsigned int OpenStarDundee();
+                unsigned int Open();
-                unsigned int CloseStarDundee();
+                unsigned int Close();
-                unsigned int SendPacket();
+                int receiveSPWPacket(unsigned char requestID);
-                unsigned int SendRMAP();
+                void commandCodeHasChanged(RMAP_command_codes code) {this->commandCode = code;}
-                unsigned int ReadRMAP();
+                void targetHasChanged(int target) {rmapTargetLogicalAddress = (unsigned char) target;}
-                unsigned int GetRoutingTableEntry();
+                void sourceHasChanged(int target) {rmapSourceLogicalAddress = (unsigned char) target;}
-                void updateCommandCode(RMAP_command_codes code);
             private:
-                char rmapTargetLogicalAddress ;
+                unsigned int GetRoutingTableEntry();
-                char rmapSourceLogicalAddress ;
+                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();}
-                QPushButton *sendPacket_BUTTON;
+                unsigned char rmapTargetLogicalAddress ;
-                QPushButton *sendRMAPPacket_BUTTON;
+                unsigned char rmapSourceLogicalAddress ;
-                QPushButton *readRMAPPacket_BUTTON;
-                QPushButton *getRoutingTableEntry_BUTTON;
+                RMAP_command_codes commandCode;
                 QLabel *usbDeviceNumber_LABEL;
                 QLabel *linkNumber_LABEL;
-                QLabel *routingTableEntry_LABEL;
                 QLabel *sourceLogicalAddress_LABEL;
                 QSpinBox *usbDeviceNumber_SPINBOX;
                 QSpinBox *linkNumber_SPINBOX;
-                QSpinBox *routingTableEntry_SPINBOX;
                 QSpinBox *sourceLogicalAddress_SPINBOX;
                 QGridLayout *connection_LAYOUT;
                 unsigned char pBuffer[10];      // Pointer to the start of the user buffer from which to transmit data
-                unsigned char* rmapPacket;      // The buffer to receive RMAP READ packets
                 USB_SPACEWIRE_ID pIdentifier;   // A pointer to a variable which will be set to contain a unique identifier for the send
-                RMAP_command_codes commandCode;
                 star_device_handle hDevice;     // Handle to the SpaceWire device
                 USB_SPACEWIRE_STATUS result;    // The result of the send operation
+                // 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 // STARDUNDEE_H

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