##// END OF EJS Templates
HG_REPOSITORIES » LPP » INSTRUMENTATION » SOLO_LFR » LPPMON_PLUGINS_PAUL
RSS

Clone from http://pc-instru.lpp.polytechnique.fr:5000/LPPMON_GROUP/LPPMON_PLUGINS_PAUL

Plugin modified to allow the launch of interactiv tests from the python interpreter...
leroy -
r11:0c9852fa341b default
parent child
Show More
Show file before | Show file after | Hide comments
@@ -1,6 +1,6
1 1 #############################################################################
2 2 # Makefile for building: PAULs_LPPMON_PLUGINS
3 # Generated by qmake (2.01a) (Qt 4.8.3) on: Mon Dec 10 09:02:30 2012
3 # Generated by qmake (2.01a) (Qt 4.8.4) on: Tue Mar 5 08:11:23 2013
4 4 # Project: PAULs_LPPMON_PLUGINS.pro
5 5 # Template: subdirs
6 6 # Command: /usr/bin/qmake-qt4 -spec /usr/lib64/qt4/mkspecs/linux-g++ -o Makefile PAULs_LPPMON_PLUGINS.pro
Show file before | Show file after | Hide comments
@@ -1,6 +1,6
1 1 <?xml version="1.0" encoding="UTF-8"?>
2 2 <!DOCTYPE QtCreatorProject>
3 <!-- Written by Qt Creator 2.4.1, 2012-12-11T14:32:09. -->
3 <!-- Written by Qt Creator 2.4.1, 2013-03-21T08:38:26. -->
4 4 <qtcreator>
5 5 <data>
6 6 <variable>ProjectExplorer.Project.ActiveTarget</variable>
Show file before | Show file after | Hide comments
@@ -59,11 +59,21 void QIPDialogBox::valueChanged() // SLO
59 59 gresbIP.append(addressPart3->cleanText());
60 60 gresbIP.append(".");
61 61 gresbIP.append(addressPart4->cleanText());
62 //labelGRESBIP->setText("IP used for the gresb module: " + gresbIP);
63 62 }
64 63
65 QString QIPDialogBox::getGRESBIP()
64 QString QIPDialogBox::getIP()
66 65 {
67 66 return(gresbIP);
68 67 }
69 68
69 void QIPDialogBox::setIP(unsigned char address1, unsigned char address2, unsigned char address3, unsigned char address4)
70 {
71 addressPart1->setValue(address1);
72 addressPart2->setValue(address2);
73 addressPart3->setValue(address3);
74 addressPart4->setValue(address4);
75 addressPart1->repaint();
76 addressPart2->repaint();
77 addressPart3->repaint();
78 addressPart4->repaint();
79 }
Show file before | Show file after | Hide comments
@@ -11,12 +11,13 class QIPDialogBox : public QWidget
11 11 Q_OBJECT
12 12 public:
13 13 explicit QIPDialogBox(QWidget *parent = 0);
14 QString getGRESBIP();
14 void setIP(unsigned char address1, unsigned char address2, unsigned char address3, unsigned char address4);
15 15
16 16 signals:
17 17
18 18 public slots:
19 19 void valueChanged();
20 QString getIP();
20 21
21 22 private:
22 23 QSpinBox *addressPart1;
Show file before | Show file after | Hide comments
@@ -1,6 +1,6
1 1 #############################################################################
2 2 # Makefile for building: librmapplugin.so.1.0.0
3 # Generated by qmake (2.01a) (Qt 4.8.3) on: Mon Dec 10 16:03:39 2012
3 # Generated by qmake (2.01a) (Qt 4.8.4) on: Tue Mar 19 07:43:19 2013
4 4 # Project: rmapplugin.pro
5 5 # Template: lib
6 6 # Command: /usr/bin/qmake-qt4 -spec /usr/lib64/qt4/mkspecs/linux-g++ -o Makefile rmapplugin.pro
@@ -10,13 +10,13
10 10
11 11 CC = gcc
12 12 CXX = g++
13 DEFINES = -DPLUGIN=rmapplugin -DPLUGINHEADER="\"rmapplugin.h\"" -Ddriver_Name="\"RMAPPlugin\"" -Ddriver_Author="\"Paul Leroy paul.leroy@lpp.polytechnique.fr\"" -Ddriver_Version="\"1.1.2\"" -Ddriver_Description="\"AHB bus controler, works with Gaisler's AHB plugn' play bus.\"" -Ddriver_can_be_root=1 -Ddriver_can_be_child=0 -Ddriver_VID=0 -Ddriver_PID=0 -DUNIXTRANSLATIONPATH -DLPPMON_PLUGINS_INSTALL_PATH="QDir::homePath()+\"/.lppmon/plugins\"" -DLPPMON_TRANSLATION_PATH="\"/etc/lppmon/translations\"" -DLPPMONPLUGIN_LIBRARY -DQT_NO_DEBUG -DQT_GUI_LIB -DQT_NETWORK_LIB -DQT_CORE_LIB -DQT_SHARED
13 DEFINES = -DPLUGIN=rmapplugin -DPLUGINHEADER="\"rmapplugin.h\"" -Ddriver_Name="\"RMAPPlugin\"" -Ddriver_Author="\"Paul Leroy paul.leroy@lpp.polytechnique.fr\"" -Ddriver_Version="\"1.1.2\"" -Ddriver_Description="\"AHB bus controler, works with Gaisler's AHB plugn' play bus.\"" -Ddriver_can_be_root=1 -Ddriver_can_be_child=0 -Ddriver_VID=0 -Ddriver_PID=0 -DUNIXTRANSLATIONPATH -DLPPMON_PLUGINS_INSTALL_PATH="QDir::homePath()+\"/.lppmon/plugins\"" -DLPPMON_CONFIG_PATH="QDir::homePath()+\"/.lppmon/config\"" -DLPPMON_TRANSLATION_PATH="\"/etc/lppmon/translations\"" -DLPPMONPLUGIN_LIBRARY -DQT_NO_DEBUG -DQT_XML_LIB -DQT_GUI_LIB -DQT_NETWORK_LIB -DQT_CORE_LIB -DQT_SHARED
14 14 CFLAGS = -pipe -O2 -g -pipe -Wall -Wp,-D_FORTIFY_SOURCE=2 -fstack-protector --param=ssp-buffer-size=4 -m64 -mtune=generic -O2 -Wall -W -D_REENTRANT -fPIC $(DEFINES)
15 15 CXXFLAGS = -pipe -O2 -g -pipe -Wall -Wp,-D_FORTIFY_SOURCE=2 -fstack-protector --param=ssp-buffer-size=4 -m64 -mtune=generic -O2 -I/usr/include/python2.7 -I/usr/include/python2.7 -Wall -W -D_REENTRANT -fPIC $(DEFINES)
16 INCPATH = -I/usr/lib64/qt4/mkspecs/linux-g++ -I. -I/usr/include/QtCore -I/usr/include/QtNetwork -I/usr/include/QtGui -I/usr/include -I. -I../common_PLE -I../spw_usb_driver_v2.61/inc -I/usr/include/lppmon/pluginsInterface -I/usr/include/PythonQt -Imoc
16 INCPATH = -I/usr/lib64/qt4/mkspecs/linux-g++ -I. -I/usr/include/QtCore -I/usr/include/QtNetwork -I/usr/include/QtGui -I/usr/include/QtXml -I/usr/include -I. -I../common_PLE -I../spw_usb_driver_v2.61/inc -I/usr/include/lppmon/common -I/usr/include/lppmon -I/usr/include/lppmon/pluginsInterface -I/usr/include/PythonQt -Imoc
17 17 LINK = g++
18 18 LFLAGS = -Wl,-O1 -Wl,-z,relro -shared -Wl,-soname,librmapplugin.so.1
19 LIBS = $(SUBLIBS) -L/usr/lib64 ../spw_usb_driver_v2.61/lib/x86_64/libSpaceWireUSBAPI.so ../spw_usb_driver_v2.61/lib/x86_64/libConfigLibraryUSB.so -ldl -lutil -lm -lpython2.7 -lPythonQt_QtAll -lPythonQt -lQtGui -lQtNetwork -lQtCore -lpthread
19 LIBS = $(SUBLIBS) -L/usr/lib64 ../spw_usb_driver_v2.61/lib/x86_64/libSpaceWireUSBAPI.so ../spw_usb_driver_v2.61/lib/x86_64/libConfigLibraryUSB.so -ldl -lutil -lm -lpython2.7 -lPythonQt_QtAll -lPythonQt -lQtXml -lQtGui -lQtNetwork -lQtCore -lpthread
20 20 AR = ar cqs
21 21 RANLIB =
22 22 QMAKE = /usr/bin/qmake-qt4
@@ -53,7 +53,7 SOURCES = rmapplugin.cpp \
53 53 rmappluginpythonwrapper.cpp \
54 54 stardundee.cpp \
55 55 gresb.cpp \
56 bridge.cpp \
56 tcpackettosend.cpp \
57 57 /usr/include/lppmon/pluginsInterface/lppmonplugininterface.cpp moc/moc_rmappluginui.cpp \
58 58 moc/moc_rmapplugin.cpp \
59 59 moc/moc_qipdialogbox.cpp \
@@ -62,7 +62,7 SOURCES = rmapplugin.cpp \
62 62 moc/moc_rmappluginpythonwrapper.cpp \
63 63 moc/moc_stardundee.cpp \
64 64 moc/moc_gresb.cpp \
65 moc/moc_bridge.cpp \
65 moc/moc_tcpackettosend.cpp \
66 66 moc/moc_genericPySysdriver.cpp \
67 67 moc/moc_lppmonplugin.cpp
68 68 OBJECTS = obj/rmapplugin.o \
@@ -75,7 +75,7 OBJECTS = obj/rmapplugin.o \
75 75 obj/rmappluginpythonwrapper.o \
76 76 obj/stardundee.o \
77 77 obj/gresb.o \
78 obj/bridge.o \
78 obj/tcpackettosend.o \
79 79 obj/lppmonplugininterface.o \
80 80 obj/moc_rmappluginui.o \
81 81 obj/moc_rmapplugin.o \
@@ -85,7 +85,7 OBJECTS = obj/rmapplugin.o \
85 85 obj/moc_rmappluginpythonwrapper.o \
86 86 obj/moc_stardundee.o \
87 87 obj/moc_gresb.o \
88 obj/moc_bridge.o \
88 obj/moc_tcpackettosend.o \
89 89 obj/moc_genericPySysdriver.o \
90 90 obj/moc_lppmonplugin.o
91 91 DIST = /usr/lib64/qt4/mkspecs/common/unix.conf \
@@ -195,8 +195,9 Makefile: rmapplugin.pro /usr/lib64/qt4
195 195 /usr/lib64/qt4/mkspecs/features/yacc.prf \
196 196 /usr/lib64/qt4/mkspecs/features/lex.prf \
197 197 /usr/lib64/qt4/mkspecs/features/include_source_dir.prf \
198 /usr/lib64/libQtXml.prl \
199 /usr/lib64/libQtCore.prl \
198 200 /usr/lib64/libQtGui.prl \
199 /usr/lib64/libQtCore.prl \
200 201 /usr/lib64/libQtNetwork.prl
201 202 $(QMAKE) -spec /usr/lib64/qt4/mkspecs/linux-g++ -o Makefile rmapplugin.pro
202 203 /usr/lib64/qt4/mkspecs/common/unix.conf:
@@ -225,15 +226,16 Makefile: rmapplugin.pro /usr/lib64/qt4
225 226 /usr/lib64/qt4/mkspecs/features/yacc.prf:
226 227 /usr/lib64/qt4/mkspecs/features/lex.prf:
227 228 /usr/lib64/qt4/mkspecs/features/include_source_dir.prf:
229 /usr/lib64/libQtXml.prl:
230 /usr/lib64/libQtCore.prl:
228 231 /usr/lib64/libQtGui.prl:
229 /usr/lib64/libQtCore.prl:
230 232 /usr/lib64/libQtNetwork.prl:
231 233 qmake: FORCE
232 234 @$(QMAKE) -spec /usr/lib64/qt4/mkspecs/linux-g++ -o Makefile rmapplugin.pro
233 235
234 236 dist:
235 237 @$(CHK_DIR_EXISTS) obj/rmapplugin1.0.0 || $(MKDIR) obj/rmapplugin1.0.0
236 $(COPY_FILE) --parents $(SOURCES) $(DIST) obj/rmapplugin1.0.0/ && $(COPY_FILE) --parents rmappluginui.h rmapplugin.h rmapoperations.h ccsds.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 bridge.h /usr/include/genericPySysdriver.h /usr/include/lppmonplugin.h obj/rmapplugin1.0.0/ && $(COPY_FILE) --parents rmapplugin.cpp rmappluginui.cpp rmapoperations.cpp ccsds.cpp ../common_PLE/qipdialogbox.cpp ../common_PLE/gresbstatusenquiry.cpp spectralmatricesdmasimulator.cpp rmappluginpythonwrapper.cpp stardundee.cpp gresb.cpp bridge.cpp /usr/include/lppmon/pluginsInterface/lppmonplugininterface.cpp obj/rmapplugin1.0.0/ && (cd `dirname obj/rmapplugin1.0.0` && $(TAR) rmapplugin1.0.0.tar rmapplugin1.0.0 && $(COMPRESS) rmapplugin1.0.0.tar) && $(MOVE) `dirname obj/rmapplugin1.0.0`/rmapplugin1.0.0.tar.gz . && $(DEL_FILE) -r obj/rmapplugin1.0.0
238 $(COPY_FILE) --parents $(SOURCES) $(DIST) obj/rmapplugin1.0.0/ && $(COPY_FILE) --parents rmappluginui.h rmapplugin.h rmapoperations.h ccsds.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 tcpackettosend.h /usr/include/genericPySysdriver.h /usr/include/lppmonplugin.h obj/rmapplugin1.0.0/ && $(COPY_FILE) --parents rmapplugin.cpp rmappluginui.cpp rmapoperations.cpp ccsds.cpp ../common_PLE/qipdialogbox.cpp ../common_PLE/gresbstatusenquiry.cpp spectralmatricesdmasimulator.cpp rmappluginpythonwrapper.cpp stardundee.cpp gresb.cpp tcpackettosend.cpp /usr/include/lppmon/pluginsInterface/lppmonplugininterface.cpp obj/rmapplugin1.0.0/ && (cd `dirname obj/rmapplugin1.0.0` && $(TAR) rmapplugin1.0.0.tar rmapplugin1.0.0 && $(COMPRESS) rmapplugin1.0.0.tar) && $(MOVE) `dirname obj/rmapplugin1.0.0`/rmapplugin1.0.0.tar.gz . && $(DEL_FILE) -r obj/rmapplugin1.0.0
237 239
238 240
239 241 clean:compiler_clean
@@ -255,12 +257,13 mocclean: compiler_moc_header_clean comp
255 257
256 258 mocables: compiler_moc_header_make_all compiler_moc_source_make_all
257 259
258 compiler_moc_header_make_all: moc/moc_rmappluginui.cpp moc/moc_rmapplugin.cpp moc/moc_qipdialogbox.cpp moc/moc_gresbstatusenquiry.cpp moc/moc_spectralmatricesdmasimulator.cpp moc/moc_rmappluginpythonwrapper.cpp moc/moc_stardundee.cpp moc/moc_gresb.cpp moc/moc_bridge.cpp moc/moc_genericPySysdriver.cpp moc/moc_lppmonplugin.cpp
260 compiler_moc_header_make_all: moc/moc_rmappluginui.cpp moc/moc_rmapplugin.cpp moc/moc_qipdialogbox.cpp moc/moc_gresbstatusenquiry.cpp moc/moc_spectralmatricesdmasimulator.cpp moc/moc_rmappluginpythonwrapper.cpp moc/moc_stardundee.cpp moc/moc_gresb.cpp moc/moc_tcpackettosend.cpp moc/moc_genericPySysdriver.cpp moc/moc_lppmonplugin.cpp
259 261 compiler_moc_header_clean:
260 -$(DEL_FILE) moc/moc_rmappluginui.cpp moc/moc_rmapplugin.cpp moc/moc_qipdialogbox.cpp moc/moc_gresbstatusenquiry.cpp moc/moc_spectralmatricesdmasimulator.cpp moc/moc_rmappluginpythonwrapper.cpp moc/moc_stardundee.cpp moc/moc_gresb.cpp moc/moc_bridge.cpp moc/moc_genericPySysdriver.cpp moc/moc_lppmonplugin.cpp
262 -$(DEL_FILE) moc/moc_rmappluginui.cpp moc/moc_rmapplugin.cpp moc/moc_qipdialogbox.cpp moc/moc_gresbstatusenquiry.cpp moc/moc_spectralmatricesdmasimulator.cpp moc/moc_rmappluginpythonwrapper.cpp moc/moc_stardundee.cpp moc/moc_gresb.cpp moc/moc_tcpackettosend.cpp moc/moc_genericPySysdriver.cpp moc/moc_lppmonplugin.cpp
261 263 moc/moc_rmappluginui.cpp: rmapoperations.h \
262 264 spectralmatricesdmasimulator.h \
263 265 stardundee.h \
266 ccsds.h \
264 267 gresb.h \
265 268 rmappluginui.h
266 269 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) rmappluginui.h -o moc/moc_rmappluginui.cpp
@@ -269,8 +272,8 moc/moc_rmapplugin.cpp: rmappluginui.h \
269 272 rmapoperations.h \
270 273 spectralmatricesdmasimulator.h \
271 274 stardundee.h \
275 ccsds.h \
272 276 gresb.h \
273 ccsds.h \
274 277 rmapplugin.h
275 278 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) rmapplugin.h -o moc/moc_rmapplugin.cpp
276 279
@@ -283,20 +286,23 moc/moc_gresbstatusenquiry.cpp: ../commo
283 286 moc/moc_spectralmatricesdmasimulator.cpp: spectralmatricesdmasimulator.h
284 287 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) spectralmatricesdmasimulator.h -o moc/moc_spectralmatricesdmasimulator.cpp
285 288
286 moc/moc_rmappluginpythonwrapper.cpp: rmappluginpythonwrapper.h
289 moc/moc_rmappluginpythonwrapper.cpp: rmapoperations.h \
290 ccsds.h \
291 rmappluginpythonwrapper.h
287 292 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) rmappluginpythonwrapper.h -o moc/moc_rmappluginpythonwrapper.cpp
288 293
289 294 moc/moc_stardundee.cpp: rmapoperations.h \
295 ccsds.h \
290 296 stardundee.h
291 297 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) stardundee.h -o moc/moc_stardundee.cpp
292 298
293 299 moc/moc_gresb.cpp: rmapoperations.h \
300 ccsds.h \
294 301 gresb.h
295 302 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) gresb.h -o moc/moc_gresb.cpp
296 303
297 moc/moc_bridge.cpp: rmapoperations.h \
298 bridge.h
299 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) bridge.h -o moc/moc_bridge.cpp
304 moc/moc_tcpackettosend.cpp: tcpackettosend.h
305 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) tcpackettosend.h -o moc/moc_tcpackettosend.cpp
300 306
301 307 moc/moc_genericPySysdriver.cpp: /usr/include/genericPySysdriver.h
302 308 /usr/lib64/qt4/bin/moc $(DEFINES) $(INCPATH) /usr/include/genericPySysdriver.h -o moc/moc_genericPySysdriver.cpp
@@ -328,8 +334,8 obj/rmapplugin.o: rmapplugin.cpp rmapplu
328 334 rmapoperations.h \
329 335 spectralmatricesdmasimulator.h \
330 336 stardundee.h \
337 ccsds.h \
331 338 gresb.h \
332 ccsds.h \
333 339 rmappluginpythonwrapper.h
334 340 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/rmapplugin.o rmapplugin.cpp
335 341
@@ -338,8 +344,8 obj/rmappluginui.o: rmappluginui.cpp rma
338 344 rmapoperations.h \
339 345 spectralmatricesdmasimulator.h \
340 346 stardundee.h \
341 gresb.h \
342 ccsds.h
347 ccsds.h \
348 gresb.h
343 349 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/rmappluginui.o rmappluginui.cpp
344 350
345 351 obj/rmapoperations.o: rmapoperations.cpp rmapoperations.h
@@ -357,20 +363,24 obj/gresbstatusenquiry.o: ../common_PLE/
357 363 obj/spectralmatricesdmasimulator.o: spectralmatricesdmasimulator.cpp spectralmatricesdmasimulator.h
358 364 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/spectralmatricesdmasimulator.o spectralmatricesdmasimulator.cpp
359 365
360 obj/rmappluginpythonwrapper.o: rmappluginpythonwrapper.cpp rmappluginpythonwrapper.h
366 obj/rmappluginpythonwrapper.o: rmappluginpythonwrapper.cpp rmappluginpythonwrapper.h \
367 rmapoperations.h \
368 ccsds.h \
369 tcpackettosend.h
361 370 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/rmappluginpythonwrapper.o rmappluginpythonwrapper.cpp
362 371
363 372 obj/stardundee.o: stardundee.cpp stardundee.h \
364 rmapoperations.h
373 rmapoperations.h \
374 ccsds.h
365 375 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/stardundee.o stardundee.cpp
366 376
367 377 obj/gresb.o: gresb.cpp gresb.h \
368 rmapoperations.h
378 rmapoperations.h \
379 ccsds.h
369 380 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/gresb.o gresb.cpp
370 381
371 obj/bridge.o: bridge.cpp bridge.h \
372 rmapoperations.h
373 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/bridge.o bridge.cpp
382 obj/tcpackettosend.o: tcpackettosend.cpp tcpackettosend.h
383 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/tcpackettosend.o tcpackettosend.cpp
374 384
375 385 obj/lppmonplugininterface.o: /usr/include/lppmon/pluginsInterface/lppmonplugininterface.cpp /usr/include/lppmon/pluginsInterface/lppmonplugininterface.h \
376 386 /usr/include/lppmon/pluginsInterface/lppmonplugininterface_global.h
@@ -400,8 +410,8 obj/moc_stardundee.o: moc/moc_stardundee
400 410 obj/moc_gresb.o: moc/moc_gresb.cpp
401 411 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/moc_gresb.o moc/moc_gresb.cpp
402 412
403 obj/moc_bridge.o: moc/moc_bridge.cpp
404 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/moc_bridge.o moc/moc_bridge.cpp
413 obj/moc_tcpackettosend.o: moc/moc_tcpackettosend.cpp
414 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/moc_tcpackettosend.o moc/moc_tcpackettosend.cpp
405 415
406 416 obj/moc_genericPySysdriver.o: moc/moc_genericPySysdriver.cpp
407 417 $(CXX) -c $(CXXFLAGS) $(INCPATH) -o obj/moc_genericPySysdriver.o moc/moc_genericPySysdriver.cpp
Show file before | Show file after | Hide comments
@@ -1,6 +1,15
1 1 #ifndef CCSDS_H
2 2 #define CCSDS_H
3 3
4 #define CCSDS_MAX_PACKET_LENGTH 4412 // in bytes, specified in the LFR Software Requirements Specification
5
6 struct ccsdsPacketToProcess_str
7 {
8 unsigned int size;
9 unsigned char data[CCSDS_MAX_PACKET_LENGTH];
10 };
11 typedef ccsdsPacketToProcess_str ccsdsPacketToProcess_t;
12
4 13 struct ccsds_telecommand_source_packet_hdr_str
5 14 {
6 15 unsigned char packetId1;
Show file before | Show file after | Hide comments
@@ -16,12 +16,13 gresb::gresb(QWidget *parent) :
16 16 spwPacket = (char*) malloc( qMax(RMAP_MAX_PACKET_LENGTH, CCSDS_MAX_PACKET_LENGTH) );
17 17
18 18 commandCode = invalid0; // initialization of the command code for the RMAP transfers
19 rmapTargetLogicalAddress = DEFAULT_TARGET;
20 rmapSourceLogicalAddress = DEFAULT_SOURCE;
19 21
20 22 //*** QLABEL ***//
21 23 gresbBridgeIPLabel = new QLabel(tr("GRESB Bridge IP: "));
22 24 gresbVirtualLinkLabel = new QLabel(tr("GRESB Virtual Link: "));
23 25 spwLinkLabel = new QLabel(tr("GRESB SPW Link: "));
24 rmapSourceLogicalAddressLabel = new QLabel(tr("RMAP Source Logical Address: "));
25 26 rmapSendStateLabel = new QLabel(tr("RMAP Send Socket State: waiting for connection"));
26 27 rmapReceiveStateLabel = new QLabel(tr("RMAP Receive Socket State: waiting for connection"));
27 28 gresbStatusQueryLabel = new QLabel(tr("GRESB status query socket (port 3010): waiting for connection"));
@@ -29,12 +30,9 gresb::gresb(QWidget *parent) :
29 30
30 31 //*** SPINBOX ***//
31 32 gresbVirtualLinkSpinBox = new QSpinBox;
32 rmapSourceLogicalAddressSpinBox = new QSpinBox;
33 33 spwLinkSpinBox = new QSpinBox;;
34 34 gresbVirtualLinkSpinBox->setRange(0, 4);
35 35 gresbVirtualLinkSpinBox->setValue(1);
36 rmapSourceLogicalAddressSpinBox->setRange(0, 255);
37 rmapSourceLogicalAddressSpinBox->setValue(33);
38 36 spwLinkSpinBox->setRange(0, 2);
39 37 spwLinkSpinBox->setValue(0);
40 38
@@ -56,13 +54,11 gresb::gresb(QWidget *parent) :
56 54 connectionLayout->addWidget(gresbVirtualLinkSpinBox, 1, 1, 0);
57 55 connectionLayout->addWidget(spwLinkLabel, 2, 0, 0);
58 56 connectionLayout->addWidget(spwLinkSpinBox, 2, 1, 0);
59 connectionLayout->addWidget(rmapSourceLogicalAddressLabel, 3, 0, 0);
60 connectionLayout->addWidget(rmapSourceLogicalAddressSpinBox, 3, 1, 0);
61 connectionLayout->addWidget(rmapSendStateLabel, 4, 0, 1, 2);
62 connectionLayout->addWidget(rmapReceiveStateLabel, 5, 0, 1, 2);
63 connectionLayout->addWidget(gresbStatusQueryLabel, 6, 0, 1, 2);
57 connectionLayout->addWidget(rmapSendStateLabel, 3, 0, 1, 2);
58 connectionLayout->addWidget(rmapReceiveStateLabel, 4, 0, 1, 2);
59 connectionLayout->addWidget(gresbStatusQueryLabel, 5, 0, 1, 2);
64 60
65 connectionLayout->setRowStretch(7, 1);
61 connectionLayout->setRowStretch(6, 1);
66 62 connectionLayout->setColumnStretch(2, 1);
67 63
68 64 // GRESB STATUS QUERY DIALOG
@@ -80,7 +76,7 gresb::gresb(QWidget *parent) :
80 76 connect(gresbStatusQueryRetryButton, SIGNAL(clicked()), this, SLOT(reTestSPWLink()));
81 77 connect(gresbStatusQueryAbortButton, SIGNAL(clicked()), gresbStatusQueryDialog, SLOT(reject()));
82 78 connect(spwLinkStatusEnquiry->readSPWStatusButton, SIGNAL(clicked()), this, SLOT(GRESBStatusQuery()));
83 connect(this->RMAPReceive_SOCKET, SIGNAL(readyRead()), this, SLOT(receiveSPWPacket()));
79 connect(this->RMAPReceive_SOCKET, SIGNAL(readyRead()), this, SLOT(receiveSPWPacketLoop()));
84 80 }
85 81
86 82 gresb::~gresb()
@@ -238,7 +234,7 unsigned int gresb::WriteBLOCK(char *dat
238 234
239 235 RMAPCommand = new RMAP(commandCode,
240 236 rmapTargetLogicalAddress,
241 rmapSourceLogicalAddressSpinBox->value(),
237 rmapSourceLogicalAddress,
242 238 address,
243 239 nbBytes,
244 240 data);
@@ -353,7 +349,7 unsigned int gresb::ReadBLOCK(unsigned i
353 349 {
354 350 RMAPCommand = new RMAP(read_Inc,
355 351 rmapTargetLogicalAddress,
356 rmapSourceLogicalAddressSpinBox->value(),
352 rmapSourceLogicalAddress,
357 353 address,
358 354 nbBytes,
359 355 NULL);
@@ -362,7 +358,7 unsigned int gresb::ReadBLOCK(unsigned i
362 358 {
363 359 RMAPCommand = new RMAP(read_Single,
364 360 rmapTargetLogicalAddress,
365 rmapSourceLogicalAddressSpinBox->value(),
361 rmapSourceLogicalAddress,
366 362 address,
367 363 nbBytes,
368 364 NULL);
@@ -458,6 +454,20 unsigned int gresb::WriteSPW(char *Value
458 454 return count;
459 455 }
460 456
457 int gresb::receiveSPWPacketLoop(unsigned char requestID)
458 {
459 int result = 0;
460 while (RMAPReceive_SOCKET->bytesAvailable())
461 {
462 result = receiveSPWPacket(requestID);
463 }
464 if (!ccsdsPacketStore.isEmpty())
465 {
466 emit packetStoreNotEmpty();
467 }
468 return result;
469 }
470
461 471 int gresb::receiveSPWPacket(unsigned char requestID) // SLOT
462 472 {
463 473 QTime spwPacketReceiverTimeout;
@@ -508,31 +518,51 int gresb::receiveSPWPacket(unsigned cha
508 518 return packetLength;
509 519
510 520 case 2: // 0x02 is the protocole identifier for CCSDS packets
511 if (ccsdsPacketSEMAPHORE->available()!=0) return -4; // ERROR === previous CCSDS packet not processed yet
521 /*if (ccsdsPacketSEMAPHORE->available()!=0)
522 {
523 emit sendMessage("in function [receiveSPWPacket] === ERROR === previous CCSDS packet not processed yet");
524 return -4; // ERROR === previous CCSDS packet not processed yet
525 }*/
512 526 for(unsigned int i=0; i<packetLength; i++) ccsdsPacket[i] = spwPacket[i];
513 527 ccsdsPacketSize = packetLength;
514 ccsdsPacketSEMAPHORE->release();
515 emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
528 //ccsdsPacketSEMAPHORE->release();
529 //emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
516 530 //emit sendMessage("CCSDS packet of size " + QString::number(packetLength) + " received");
531 storeCCSDSPacket(ccsdsPacket, packetLength);
517 532 return packetLength;
518 533 }
519 534 return 0;
520 535 }
521 536
537 unsigned int gresb::storeCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size)
538 {
539 unsigned int i;
540 ccsdsPacketToProcess_t ccsdsPacketToStore;
541
542 ccsdsPacketToStore.size = size;
543 for(i=0; i<size; i++)
544 {
545 ccsdsPacketToStore.data[i] = ccsdsPacket[i];
546 }
547 ccsdsPacketStore << ccsdsPacketToStore;
548 //emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
549 //emit ccsdsPacketIsAvailable(size);
550 return 1;
551 }
552
522 553 void gresb::Open() // SLOT
523 554 {
524 555 bool spwRunning = true;
525 RMAPSend_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getGRESBIP()),
556 RMAPSend_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getIP()),
526 557 3000 + gresbVirtualLinkSpinBox->value()*2,
527 558 QIODevice::WriteOnly);
528 RMAPReceive_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getGRESBIP()),
559 RMAPReceive_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getIP()),
529 560 3000 + gresbVirtualLinkSpinBox->value()*2+1,
530 561 QIODevice::ReadOnly);
531 GRESBStatusQuery_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getGRESBIP()),
562 GRESBStatusQuery_SOCKET->connectToHost( QHostAddress(gresbBridgeIPDialogBox->getIP()),
532 563 3010,
533 564 QIODevice::ReadWrite);
534 565 GRESBStatusQuery_SOCKET->waitForConnected(10000);
535 RMAPReceive_SOCKET->readAll(); // read all remaining data from the reception socket
536 566 // initialize SPW packet semaphores
537 567 while (rmapPacketSEMAPHORE->available()!=0) rmapPacketSEMAPHORE->acquire();
538 568 while (ccsdsPacketSEMAPHORE->available()!=0) ccsdsPacketSEMAPHORE->acquire();
@@ -543,7 +573,8 void gresb::Open() // SLOT
543 573 if (spwRunning == false) this->Close();
544 574 else
545 575 {
546 emit appendToLog(QString("SpaceWire running on virtual link ")+ QString::number(spwLinkSpinBox->value()));
576 emit appendToLog(QString("SpaceWire running on link ")+ QString::number(spwLinkSpinBox->value()));
577 RMAPReceive_SOCKET->readAll(); // read all remaining data from the reception socket
547 578 emit isOpen(true);
548 579 }
549 580 }
@@ -764,3 +795,4 void gresb::GRESBConnectionState(QAbstra
764 795 }
765 796 gresbStatusQueryLabel->setText(socketMessage);
766 797 }
798
Show file before | Show file after | Hide comments
@@ -13,6 +13,7
13 13 #include "gresbstatusenquiry.h"
14 14 #include "rmapoperations.h"
15 15 #include "qipdialogbox.h"
16 #include "ccsds.h"
16 17
17 18 class gresb : public QWidget
18 19 {
@@ -23,6 +24,9 public:
23 24 unsigned int Write(unsigned int *Value,unsigned int count,unsigned int address=0);
24 25 unsigned int Read(unsigned int *Value,unsigned int count,unsigned int address=0);
25 26 unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
27
28 unsigned int storeCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size);
29 QList<ccsdsPacketToProcess_t> ccsdsPacketStore;
26 30
27 31 signals:
28 32 void sendMessage(QString message);
@@ -30,19 +34,25 signals:
30 34 void RMAP_write_reply_setText(QString);
31 35 void appendToLog(QString);
32 36 void ccsdsPacketAvailable(unsigned char*, unsigned int);
37 void packetStoreNotEmpty();
33 38
34 39 public slots:
35 40 void Open();
36 41 void Close();
42 int receiveSPWPacketLoop(unsigned char requestID=0);
37 43 int receiveSPWPacket(unsigned char requestID=0);
38 44 void commandCodeHasChanged(RMAP_command_codes code) {this->commandCode = code;}
39 45 void targetHasChanged(int target) {rmapTargetLogicalAddress = (unsigned char) target;}
46 void sourceHasChanged(int source) {rmapSourceLogicalAddress = (unsigned char) source;}
40 47 void ccsdsPacketIsProcessed() {ccsdsPacketSEMAPHORE->tryAcquire();}
41 48 void reTestSPWLink();
42 49 //
43 50 void RMAPSendConnectionState(QAbstractSocket::SocketState socketState);
44 51 void RMAPReceiveConnectionState(QAbstractSocket::SocketState socketState);
45 52 void GRESBConnectionState(QAbstractSocket::SocketState socketState);
53 //
54 void setIP(unsigned char address1, unsigned char address2, unsigned char address3, unsigned char address4)
55 {this->gresbBridgeIPDialogBox->setIP(address1, address2, address3, address4);}
46 56
47 57 private slots:
48 58 int GRESBStatusQuery();
@@ -65,7 +75,6 private:
65 75 QLabel *gresbBridgeIPLabel;
66 76 QLabel *gresbVirtualLinkLabel;
67 77 QLabel *spwLinkLabel;
68 QLabel *rmapSourceLogicalAddressLabel;
69 78 QLabel *rmapSendStateLabel;
70 79 QLabel *rmapReceiveStateLabel;
71 80 QLabel *gresbStatusQueryLabel;
@@ -77,7 +86,6 private:
77 86
78 87 QSpinBox *gresbVirtualLinkSpinBox;
79 88 QSpinBox *spwLinkSpinBox;
80 QSpinBox *rmapSourceLogicalAddressSpinBox;
81 89
82 90 QGridLayout *connectionLayout;
83 91 QGridLayout *gresbStatusQueryDialogLayout;
Show file before | Show file after | Hide comments
@@ -1,6 +1,7
1 1 #include "rmapoperations.h"
2 2
3 RMAP::RMAP(RMAP_command_codes commandCode, char targetLogicalAddress, char initiatorLogicalAddress, int startAddress, int nbBytes, char* data)
3 RMAP::RMAP(RMAP_command_codes commandCode, unsigned char targetLogicalAddress, unsigned char initiatorLogicalAddress,
4 int startAddress, int nbBytes, char* data)
4 5 {
5 6 char packetType; // 2 most Significant Bits
6 7 char command; // 4 bits
@@ -37,9 +38,9 RMAP::RMAP(RMAP_command_codes commandCod
37 38 break;
38 39 }
39 40 RMAPHeader.targetLogicalAddress = targetLogicalAddress ;
40 RMAPHeader.protocolIdentifier = 0x01; // 0x01 is the protocole identifier for RMAP
41 RMAPHeader.protocolIdentifier = 0x01; // 0x01 is the protocole identifier for RMAP
41 42 RMAPHeader.instruction = (packetType<<6) + (command<<2) + (replyAddressLength);
42 RMAPHeader.key = 0; // used for command authorization
43 RMAPHeader.key = initiatorLogicalAddress; // used for command authorization
43 44 RMAPHeader.initiatorLogicalAddress = initiatorLogicalAddress; // 0 is the default address for the GRESB module
44 45 RMAPHeader.transactionIdentifier1 = 0x00;
45 46 RMAPHeader.transactionIdentifier0 = 0x01;
Show file before | Show file after | Hide comments
@@ -9,7 +9,9
9 9 #define RMAP_READ_COMMAND_HEADER_LENGTH 16 // in bytes => ECSS
10 10 #define RMAP_DATA_CRC_LENGTH 1 // in bytes => ECSS
11 11 #define RMAP_MAX_PACKET_LENGTH RMAP_READ_REPLY_HEADER_LENGTH + RMAP_MAX_DATA_LENGTH + RMAP_DATA_CRC_LENGTH
12 #define CCSDS_MAX_PACKET_LENGTH 4412 // in bytes, specified in the LFR Software Requirements Specification
12
13 #define DEFAULT_SOURCE 0
14 #define DEFAULT_TARGET 254
13 15
14 16 static const unsigned char RMAP_CRCTable[] = {
15 17 0x00, 0x91, 0xe3, 0x72, 0x07, 0x96, 0xe4, 0x75,
@@ -71,9 +73,9 struct rmap_command_format_str
71 73 char targetLogicalAddress;
72 74 char protocolIdentifier;
73 75 char instruction;
74 char key; // used for command authorization => check Gaisler GRSPW for compliance
76 unsigned char key; // used for command authorization => check Gaisler GRSPW for compliance
75 77 //char replyAddress[]; // not needed if logical addressing is used (replyAddressLength = 0b00)
76 char initiatorLogicalAddress;
78 unsigned char initiatorLogicalAddress;
77 79 char transactionIdentifier1;
78 80 char transactionIdentifier0;
79 81 char extendedAddress;
@@ -132,8 +134,8 class RMAP
132 134 {
133 135 public:
134 136 RMAP(RMAP_command_codes commandCode,
135 char targetLogicalAddress,
136 char initiatorLogicalAddress,
137 unsigned char targetLogicalAddress,
138 unsigned char initiatorLogicalAddress,
137 139 int startAddress,
138 140 int nbBytes,
139 141 char *data);
Show file before | Show file after | Hide comments
@@ -24,6 +24,8
24 24 #include <QIODevice>
25 25 #include <QApplication>
26 26 #include <rmappluginpythonwrapper.h>
27 #include <PythonQt.h>
28 #include <QTimer>
27 29
28 30 rmapplugin::rmapplugin(QWidget *parent)
29 31 :lppmonplugin(parent,false)
@@ -37,11 +39,35 rmapplugin::rmapplugin(QWidget *parent)
37 39 time_FINE = 0;
38 40 currentBridge = selectedBridgeIsUnknown;
39 41
40 /*Python wrapper*/
42 //**************
43 //Python wrapper
41 44 this->pyObject = new rmappluginPythonWrapper();
42 45 connect(this->pyObject,SIGNAL(ReadSig(uint*,uint,uint)),this,SLOT(Read(uint*,uint,uint)));
43 46 connect(this->pyObject,SIGNAL(WriteSig(uint*,uint,uint)),this,SLOT(Write(uint*,uint,uint)));
44 /*==============*/
47 //**
48 connect( (rmappluginPythonWrapper*)this->pyObject, SIGNAL( WriteSPWSig(char*,uint,char,char) ),
49 this, SLOT( WriteSPW(char*,uint,char,char)), Qt::DirectConnection );
50 //**
51 connect( (rmappluginPythonWrapper*)this->pyObject, SIGNAL( updateTargetAddress(unsigned char) ),
52 this, SLOT( setValueTargetAddress(unsigned char)) );
53 //**
54 connect( (rmappluginPythonWrapper*)this->pyObject, SIGNAL( updateSourceAddress(unsigned char) ),
55 this, SLOT( setValueSourceAddress(unsigned char)) );
56 //**
57 connect( (rmappluginPythonWrapper*)this->pyObject, SIGNAL(sendMessage(QString)),
58 this, SLOT(displayOnConsole(QString)) );
59 //**************
60
61 //**************
62 // get a smart pointer to the __main__ module of the Python interpreter
63 PythonQtObjectPtr context = PythonQt::self()->getMainModule();
64 // add a QObject as variable of name "BUTTON_rmapOpenCommunication" to the namespace of the __main__ module
65 context.addObject("BUTTON_rmapOpenCommunication", UI->rmapOpenCommunicationButton);
66 context.addObject("BUTTON_rmapCloseCommunication", UI->rmapCloseCommunicationButton);
67 context.addObject("BUTTON_selectStarDundee", UI->selectStarDundee_BUTTON);
68 context.addObject("BUTTON_selectGRESB", UI->selectGRESB_BUTTON);
69 context.addObject("GRESB_Bridge", UI->gresbBridge);
70 //**************
45 71
46 72 connect(UI->rmapOpenCommunicationButton, SIGNAL(clicked()), this, SLOT(openBridge()));
47 73 connect(UI->rmapCloseCommunicationButton, SIGNAL(clicked()), this, SLOT(closeBridge()));
@@ -64,6 +90,12 rmapplugin::rmapplugin(QWidget *parent)
64 90 connect(this->UI->gresbBridge, SIGNAL(ccsdsPacketAvailable(unsigned char*,uint)),
65 91 this, SLOT(processCCSDSPacket(unsigned char*,uint)));
66 92 connect(this, SIGNAL(ccsdsPacketIsProcessed()), this->UI->gresbBridge, SLOT(ccsdsPacketIsProcessed()));
93 connect(this->UI->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)),
94 this->UI->gresbBridge, SLOT(targetHasChanged(int)));
95 connect(this->UI->rmapSourceLogicalAddressSpinBox, SIGNAL(valueChanged(int)),
96 this->UI->gresbBridge, SLOT(sourceHasChanged(int)));
97 connect(this->UI->gresbBridge, SIGNAL(packetStoreNotEmpty()),
98 this, SLOT(processPacketStore()));
67 99
68 100 // Star Dundee
69 101 connect(this->UI->starDundee, SIGNAL(sendMessage(QString)), this, SLOT(displayOnConsole(QString)));
@@ -73,15 +105,31 rmapplugin::rmapplugin(QWidget *parent)
73 105 connect(this->UI->starDundee, SIGNAL(ccsdsPacketAvailable(unsigned char*,uint)),
74 106 this, SLOT(processCCSDSPacket(unsigned char*,uint)));
75 107 connect(this, SIGNAL(ccsdsPacketIsProcessed()), this->UI->starDundee, SLOT(ccsdsPacketIsProcessed()));
108 connect(this->UI->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)),
109 this->UI->starDundee, SLOT(targetHasChanged(int)));
110 connect(this->UI->rmapSourceLogicalAddressSpinBox, SIGNAL(valueChanged(int)),
111 this->UI->starDundee, SLOT(sourceHasChanged(int)));
112 connect(this->UI->starDundee, SIGNAL(packetStoreNotEmpty()),
113 this, SLOT(processPacketStore()));
76 114
77 115 connect(this->UI, SIGNAL(bridgeHasChanged(selectedBridge)), this, SLOT(bridgeHasChanged(selectedBridge)));
116
78 117 }
79 118
80 119 rmapplugin::~rmapplugin()
81 120 {
82 if (!RMAPSend_SOCKET->isOpen()) RMAPSend_SOCKET->disconnectFromHost();
83 if (!RMAPReceive_SOCKET->isOpen()) RMAPReceive_SOCKET->disconnectFromHost();
84 if (!GRESBStatusQuery_SOCKET->isOpen()) GRESBStatusQuery_SOCKET->disconnectFromHost();
121 switch(currentBridge)
122 {
123 case selectedBridgeIsGRESB :
124 if (RMAPSend_SOCKET->isOpen()) RMAPSend_SOCKET->disconnectFromHost();
125 if (RMAPReceive_SOCKET->isOpen()) RMAPReceive_SOCKET->disconnectFromHost();
126 if (GRESBStatusQuery_SOCKET->isOpen()) GRESBStatusQuery_SOCKET->disconnectFromHost();
127 break;
128 case selectedBridgeIsStarDundee :
129 break;
130 default:
131 break;
132 }
85 133 }
86 134
87 135 unsigned int rmapplugin::Write(unsigned int *Value, unsigned int count, unsigned int address)
@@ -279,6 +327,16 void rmapplugin::appendToLog(QString tex
279 327 APPENDTOLOG(text);
280 328 }
281 329
330 void rmapplugin::setValueTargetAddress(unsigned char newAddress)
331 {
332 this->UI->rmapTargetLogicalAddressSpinBox->setValue(newAddress);
333 }
334
335 void rmapplugin::setValueSourceAddress(unsigned char newAddress)
336 {
337 this->UI->rmapSourceLogicalAddressSpinBox->setValue(newAddress);
338 }
339
282 340 /////////////////////
283 341 // INTERNAL FUNCTIONS
284 342
@@ -311,6 +369,22 void rmapplugin::processCCSDSPacket(unsi
311 369 //+" "
312 370 //+ QString::number(ccsdsPacket[7], 16));
313 371 displayOnConsole(message);
372 ((rmappluginPythonWrapper*)this->pyObject)->storeCCSDSPacket(ccsdsPacket, size);
314 373 emit ccsdsPacketIsProcessed();
315 374 }
316 375
376 void rmapplugin::processPacketStore()
377 {
378 switch(currentBridge)
379 {
380 case selectedBridgeIsGRESB :
381 ((rmappluginPythonWrapper*)this->pyObject)->ccsdsPacketStore = &(this->UI->gresbBridge->ccsdsPacketStore);
382 break;
383 case selectedBridgeIsStarDundee :
384 ((rmappluginPythonWrapper*)this->pyObject)->ccsdsPacketStore = &(this->UI->starDundee->ccsdsPacketStore);
385 break;
386 default:
387 break;
388 }
389 ((rmappluginPythonWrapper*)this->pyObject)->processPacketStore();
390 }
Show file before | Show file after | Hide comments
@@ -54,9 +54,12 public slots:
54 54 unsigned int Write(unsigned int *Value,unsigned int count,unsigned int address=0);
55 55 unsigned int Read(unsigned int *Value,unsigned int count,unsigned int address=0);
56 56 unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
57 void setValueTargetAddress(unsigned char newAddress);
58 void setValueSourceAddress(unsigned char newAddress);
57 59 void openBridge();
58 60 void closeBridge();
59 61 void processCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size);
62 void processPacketStore();
60 63 //
61 64 void sendCCSDS();
62 65 void send_TC_LFR_UPDATE_TIME();
Show file before | Show file after | Hide comments
@@ -43,7 +43,7 HEADERS += \
43 43 ../spw_usb_driver_v2.61/inc/spw_usb_api.h \
44 44 ../spw_usb_driver_v2.61/inc/spw_config_library.h \
45 45 gresb.h \
46 bridge.h
46 tcpackettosend.h
47 47
48 48
49 49 SOURCES += \
@@ -57,7 +57,7 SOURCES += \
57 57 rmappluginpythonwrapper.cpp \
58 58 stardundee.cpp \
59 59 gresb.cpp \
60 bridge.cpp
60 tcpackettosend.cpp
61 61
62 62
63 63
Show file before | Show file after | Hide comments
@@ -1,12 +1,16
1 1 #include "rmappluginpythonwrapper.h"
2 2 #include <math.h>
3 #include <QApplication>
3 4
4 5 rmappluginPythonWrapper::rmappluginPythonWrapper(QObject *parent) :
5 6 genericPySysdriver(parent)
6 7 {
8 timer = new QTimer;
9 timer->setSingleShot(true);
10 connect(timer, SIGNAL(timeout()), this, SLOT(sendTC()));
11 connect(this, SIGNAL(activateTCLoopSig()), this, SLOT(sendTCLoop()));
7 12 }
8 13
9
10 14 QList<QVariant> rmappluginPythonWrapper::getData()
11 15 {
12 16 QList<QVariant> data;
@@ -17,3 +21,154 QList<QVariant> rmappluginPythonWrapper:
17 21 }
18 22 return data;
19 23 }
24
25 QList<QVariant> rmappluginPythonWrapper::ReadSPW(unsigned int size)
26 {
27 QList<QVariant> result;
28 ccsdsPacketToProcess_t ccsdsPacket;
29
30 if (!ccsdsPacketStore->isEmpty())
31 {
32 ccsdsPacket = ccsdsPacketStore->takeFirst();
33 for(unsigned int i = 0;i<size;i++)
34 {
35 result.append((QVariant)ccsdsPacket.data[i]);
36 }
37 }
38 return result;
39 }
40
41 void rmappluginPythonWrapper::WriteSPW(QList<int> dataList)
42 {
43 char targetLogicalAddress;
44 char userApplication;
45 unsigned int count;
46 char *Value;
47
48 unsigned char data[dataList.count()];
49
50 for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char
51 {
52 data[i] = (unsigned char)dataList.at(i);
53 }
54 // read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters
55 targetLogicalAddress = data[0];
56 userApplication = data[3];
57
58 count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON
59 Value = (char*) &data[4];
60
61 emit WriteSPWSig(Value, count, targetLogicalAddress, userApplication);
62 }
63
64 void rmappluginPythonWrapper::WriteSPWDelay(QList<int> dataList, unsigned int delay)
65 {
66 char targetLogicalAddress;
67 char userApplication;
68 unsigned int count;
69 char *Value;
70 TCPacketToSend *packet;
71
72 unsigned char data[dataList.count()];
73
74 for(int i = 0; i<dataList.count(); i++) // get the data as unsigned char
75 {
76 data[i] = (unsigned char)dataList.at(i);
77 }
78 // read the first bytes of the data to get the targetLogicalAddress and the userApplication parameters
79 targetLogicalAddress = data[0];
80 userApplication = data[3];
81
82 count = dataList.count() - 4; // the CCSDS header (4 bytes) is added by LPPMON
83 Value = (char*) &data[4];
84
85 packet = new TCPacketToSend(Value, count, targetLogicalAddress, userApplication, delay);
86 TCPacketStore.append(packet);
87
88 emit(activateTCLoopSig());
89
90 }
91
92 void rmappluginPythonWrapper::processPacketStoreLater(unsigned int delay)
93 {
94 emit sendMessage(
95 "*** process packet store in " + QString::number(delay) + " ms"
96 );
97 QTimer::singleShot(delay, this, SLOT(sendProcessPacketStoreNowSig()));
98 }
99
100 void rmappluginPythonWrapper::sendTCLoop()
101 {
102 unsigned int delay;
103
104 if (!timer->isActive())
105 {
106 if (!TCPacketStore.isEmpty())
107 {
108 delay = TCPacketStore.at(0)->delay;
109 timer->setInterval(delay);
110 timer->start();
111 }
112 }
113 }
114
115 void rmappluginPythonWrapper::sendTC()
116 {
117 TCPacketToSend *packet;
118 unsigned int delay;
119
120 packet = TCPacketStore.takeFirst();
121 // the signal is connected with the option Qt::DirectConnection, thus it is processed immediately
122 emit(WriteSPWSig(packet->Value, packet->count,packet->targetLogicalAddress, packet->userApplication));
123 delete(packet);
124 if (!TCPacketStore.isEmpty())
125 {
126 delay = TCPacketStore.at(0)->delay;
127 timer->setInterval(delay);
128 timer->start();
129 }
130 }
131
132 unsigned int rmappluginPythonWrapper::storeCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size)
133 {
134 unsigned int i;
135 ccsdsPacketToProcess_t ccsdsPacketToStore;
136
137 ccsdsPacketToStore.size = size;
138 for(i=0; i<size; i++)
139 {
140 //ccsdsPacket0[i] = ccsdsPacket[i];
141 ccsdsPacketToStore.data[i] = ccsdsPacket[i];
142 }
143 ccsdsPacketStore->append(ccsdsPacketToStore);
144 emit ccsdsPacketIsAvailable(size);
145 return 1;
146 }
147
148 void rmappluginPythonWrapper::processPacketStore()
149 {
150 while (!ccsdsPacketStore->isEmpty())
151 {
152 emit ccsdsPacketIsAvailable(ccsdsPacketStore->at(0).size);
153 ProcessPendingEvents();
154 }
155 }
156
157 void rmappluginPythonWrapper::setTargetAddressValue(unsigned int address)
158 {
159 unsigned char newAddress;
160 newAddress = (unsigned char) address;
161 emit updateTargetAddress(newAddress);
162 }
163
164 void rmappluginPythonWrapper::setSourceAddressValue(unsigned int address)
165 {
166 unsigned char newAddress;
167 newAddress = (unsigned char) address;
168 emit updateSourceAddress(newAddress);
169 }
170
171 void rmappluginPythonWrapper::ProcessPendingEvents()
172 {
173 QCoreApplication::processEvents();
174 }
Show file before | Show file after | Hide comments
@@ -5,17 +5,50
5 5 #include <genericPySysdriver.h>
6 6 #include <QList>
7 7 #include <QVariant>
8 #include "rmapoperations.h"
9 #include "ccsds.h"
10 #include <tcpackettosend.h>
11 #include <QTimer>
8 12
9 13 class rmappluginPythonWrapper : public genericPySysdriver
10 14 {
11 15 Q_OBJECT
12 16 public:
13 17 explicit rmappluginPythonWrapper(QObject *parent = 0);
18
19 QList<ccsdsPacketToProcess_t> *ccsdsPacketStore;
20 void processPacketStore();
21 unsigned int storeCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size);
22
23 QList<TCPacketToSend*> TCPacketStore;
24 QTimer *timer;
14 25
15 26 signals:
27 void ccsdsPacketIsAvailable(unsigned int size);
28 void wakeUpCallingThread();
29 unsigned int WriteSPWSig(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
30 void updateTargetAddress(unsigned char newAddress);
31 void updateSourceAddress(unsigned char newAddress);
32 void activateTCLoopSig();
33 void processPacketStoreNowSig();
34 void sendMessage(QString message);
16 35
17 36 public slots:
18 37 QList<QVariant> getData();
38
39 QList<QVariant> ReadSPW(unsigned int size);
40 void WriteSPW(QList<int> dataList);
41 void WriteSPWDelay(QList<int> dataList, unsigned int delay=0);
42 void processPacketStoreLater(unsigned int delay);
43 void sendProcessPacketStoreNowSig(){emit processPacketStoreNowSig();}
44 void sendTCLoop();
45 void sendTC();
46 void reEmitWriteSPWSig(char *Value, unsigned int count, char targetLogicalAddress, char userApplication)
47 {emit WriteSPWSig(Value, count, targetLogicalAddress, userApplication);}
48
49 void setTargetAddressValue(unsigned int address);
50 void setSourceAddressValue(unsigned int address);
51 void ProcessPendingEvents();
19 52
20 53 };
21 54
Show file before | Show file after | Hide comments
@@ -81,18 +81,18 rmapPluginUI::rmapPluginUI(QWidget *pare
81 81 gresbVirtualLinkSpinBox->setRange(0, 4);
82 82 gresbVirtualLinkSpinBox->setValue(1);
83 83 rmapSourceLogicalAddressSpinBox->setRange(0, 255);
84 rmapSourceLogicalAddressSpinBox->setValue(33);
84 rmapSourceLogicalAddressSpinBox->setValue(0);
85 85 rmapTargetLogicalAddressSpinBox->setRange(0, 255);
86 86 spwLinkSpinBox->setRange(0, 2);
87 87 spwLinkSpinBox->setValue(0);
88 88 CCSDSTargetLogicalAddressSpinBox->setRange(0,255);
89 CCSDSTargetLogicalAddressSpinBox->setValue(254);
89 CCSDSTargetLogicalAddressSpinBox->setValue(0);
90 90
91 91 //*** MISC **//
92 92 starDundee = new StarDundee;
93 93 gresbBridge = new gresb;
94 94 console = new QTextEdit;
95 gresbBridgeIPDialogBox = new QIPDialogBox;
95 //gresbBridgeIPDialogBox = new QIPDialogBox;
96 96 gresbStatusQueryDialog = new QDialog;
97 97 logEnableCheckBox = new QCheckBox(tr("Enable Logs"));
98 98 RMAP_write_verify = new QCheckBox(tr("data checked before write\nlimited to 4 bytes\nNOT IMPLEMENTED"));
@@ -112,13 +112,15 rmapPluginUI::rmapPluginUI(QWidget *pare
112 112
113 113 generalParameters_LAYOUT->addWidget(logEnableCheckBox, 0, 0, 1, 1);
114 114 generalParameters_LAYOUT->addWidget(logFileChooseButton, 0, 1, 1, 1);
115 generalParameters_LAYOUT->addWidget(rmapTargetLogicalAddressLabel, 1, 0, 0);
116 generalParameters_LAYOUT->addWidget(rmapTargetLogicalAddressSpinBox, 1, 1, 0);
117 generalParameters_LAYOUT->addWidget(rmapOpenCommunicationButton, 2, 0, 1, 1);
118 generalParameters_LAYOUT->addWidget(rmapCloseCommunicationButton, 2, 1, 1, 1);
119 generalParameters_LAYOUT->addWidget(RMAP_write_verify, 3, 0, 1, 2);
120 generalParameters_LAYOUT->addWidget(RMAP_write_reply, 4, 0, 1, 2);
121 generalParameters_LAYOUT->setRowStretch(5, 1);
115 generalParameters_LAYOUT->addWidget(rmapSourceLogicalAddressLabel, 1, 0, 0);
116 generalParameters_LAYOUT->addWidget(rmapSourceLogicalAddressSpinBox, 1, 1, 0);
117 generalParameters_LAYOUT->addWidget(rmapTargetLogicalAddressLabel, 2, 0, 0);
118 generalParameters_LAYOUT->addWidget(rmapTargetLogicalAddressSpinBox, 2, 1, 0);
119 generalParameters_LAYOUT->addWidget(rmapOpenCommunicationButton, 3, 0, 1, 1);
120 generalParameters_LAYOUT->addWidget(rmapCloseCommunicationButton, 3, 1, 1, 1);
121 generalParameters_LAYOUT->addWidget(RMAP_write_verify, 4, 0, 1, 2);
122 generalParameters_LAYOUT->addWidget(RMAP_write_reply, 5, 0, 1, 2);
123 generalParameters_LAYOUT->setRowStretch(6, 1);
122 124 generalParameters_LAYOUT->setColumnStretch(2, 1);
123 125
124 126 gresb_GROUPBOX->setLayout(gresbBridge->layout());
@@ -168,8 +170,10 rmapPluginUI::rmapPluginUI(QWidget *pare
168 170 connect(this->starDundee, SIGNAL(isOpen(bool)), this, SLOT(isOpen(bool)));
169 171 connect(this->gresbBridge, SIGNAL(isOpen(bool)), this, SLOT(isOpen(bool)));
170 172
173 connect(this->rmapSourceLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->gresbBridge, SLOT(sourceHasChanged(int)));
174 connect(this->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->gresbBridge, SLOT(targetHasChanged(int)));
175 connect(this->rmapSourceLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->starDundee, SLOT(sourceHasChanged(int)));
171 176 connect(this->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->starDundee, SLOT(targetHasChanged(int)));
172 connect(this->rmapTargetLogicalAddressSpinBox, SIGNAL(valueChanged(int)), this->gresbBridge, SLOT(targetHasChanged(int)));
173 177
174 178 // command code
175 179 connect(this->RMAP_write_reply, SIGNAL(clicked()), this, SLOT(getCommandCode()));
@@ -180,7 +184,8 rmapPluginUI::rmapPluginUI(QWidget *pare
180 184 this->gresbBridge, SLOT(commandCodeHasChanged(RMAP_command_codes)));
181 185
182 186 getCommandCode(); // init the command code value
183 rmapTargetLogicalAddressSpinBox->setValue(254);
187 rmapSourceLogicalAddressSpinBox->setValue(DEFAULT_SOURCE);
188 rmapTargetLogicalAddressSpinBox->setValue(DEFAULT_TARGET);
184 189 }
185 190
186 191 rmapPluginUI::~rmapPluginUI()
Show file before | Show file after | Hide comments
@@ -81,7 +81,7 public:
81 81 QSpinBox* rmapTargetLogicalAddressSpinBox;
82 82 QSpinBox* CCSDSTargetLogicalAddressSpinBox;
83 83
84 QIPDialogBox* gresbBridgeIPDialogBox;
84 //QIPDialogBox* gresbBridgeIPDialogBox;
85 85
86 86 QCheckBox *logEnableCheckBox;
87 87 QCheckBox *RMAP_write_verify;
@@ -101,8 +101,8 public:
101 101
102 102 QTextEdit* console;
103 103
104 // SPACEWIRE BRIDGES
104 105 StarDundee *starDundee;
105
106 106 gresb *gresbBridge;
107 107
108 108 bool islogfileenable();
@@ -124,6 +124,7 signals:
124 124 void commandCodeHasChanged(RMAP_command_codes commandCode);
125 125 void bridgeHasChanged(selectedBridge bridge);
126 126 void targetHasChanged(unsigned char target);
127 void sourceHasChanged(unsigned char source);
127 128
128 129 private:
129 130 QLabel *gresbBridgeIPLabel;
Show file before | Show file after | Hide comments
@@ -1,6 +1,7
1 1 #include "stardundee.h"
2 2 #include <QTime>
3 3 #include <math.h>
4 #include "ccsds.h"
4 5
5 6 StarDundee::StarDundee(QWidget *parent) :
6 7 QWidget(parent)
@@ -16,13 +17,13 StarDundee::StarDundee(QWidget *parent)
16 17 starDundeeStatusQueryDialog = new QDialog;
17 18
18 19 commandCode = invalid0; // initialization of the cmmand code for the RMAP transfers
20 rmapTargetLogicalAddress = DEFAULT_TARGET;
21 rmapSourceLogicalAddress = DEFAULT_SOURCE;
19 22
20 rmapSourceLogicalAddress = 0x20;
21 23 connection_LAYOUT = new QGridLayout;
22 24
23 25 usbDeviceNumber_LABEL = new QLabel(tr("USB device number: "));
24 26 linkNumber_LABEL = new QLabel(tr("SpaceWire link number: "));
25 sourceLogicalAddress_LABEL = new QLabel(tr("Source logical address: "));
26 27 starDundeeStatusQueryDialogLabel = new QLabel(tr("SpaceWire link not running"));
27 28
28 29 //*** QPUSHBUTTON ***//
@@ -35,9 +36,6 StarDundee::StarDundee(QWidget *parent)
35 36 linkNumber_SPINBOX = new QSpinBox;
36 37 linkNumber_SPINBOX->setRange(1,2);
37 38 linkNumber_SPINBOX->setValue(1);
38 sourceLogicalAddress_SPINBOX = new QSpinBox;
39 sourceLogicalAddress_SPINBOX->setRange(0,254);
40 sourceLogicalAddress_SPINBOX->setValue(32);
41 39
42 40 // STAR DUNDEE STATUS QUERY DIALOG
43 41 starDundeeStatusQueryDialogLayout = new QGridLayout;
@@ -50,21 +48,17 StarDundee::StarDundee(QWidget *parent)
50 48 connection_LAYOUT->addWidget(usbDeviceNumber_SPINBOX, 0, 1, 1, 1);
51 49 connection_LAYOUT->addWidget(linkNumber_LABEL, 1, 0, 1, 1);
52 50 connection_LAYOUT->addWidget(linkNumber_SPINBOX, 1, 1, 1, 1);
53 connection_LAYOUT->addWidget(sourceLogicalAddress_LABEL, 2, 0, 1, 1);
54 connection_LAYOUT->addWidget(sourceLogicalAddress_SPINBOX, 2, 1, 1, 1);
55 51
56 connection_LAYOUT->setRowStretch(3, 1);
52 connection_LAYOUT->setRowStretch(2, 1);
57 53 connection_LAYOUT->setColumnStretch(2, 1);
58 54
59 55 this->setLayout(connection_LAYOUT);
60 56
61 connect(this->sourceLogicalAddress_SPINBOX, SIGNAL(valueChanged(int)), this, SLOT(sourceHasChanged(int)));
62
63 57 connect(starDundeeStatusQueryRetryButton, SIGNAL(clicked()), this, SLOT(reTestSPWLink()));
64 58 connect(starDundeeStatusQueryAbortButton, SIGNAL(clicked()), starDundeeStatusQueryDialog, SLOT(reject()));
65 59
66 60 connect(this->timer, SIGNAL(timeout()), this, SLOT(receivePollingLoop()));
67 timer->start(100); // starts the periodical timer, perdio = 100ms
61 timer->start(100); // starts the periodical timer, period = 100ms
68 62 }
69 63
70 64 StarDundee::~StarDundee()
@@ -82,14 +76,14 void StarDundee::Open()
82 76
83 77 if (!USBSpaceWire_Open(&hDevice, usbDeviceNumber_SPINBOX->value())) // Open the USB device
84 78 {
85 emit sendMessage("stardundee *** Open *** ERROR: USBSpaceWire_Open(&hDevice, 0))");
86 return;
79 emit sendMessage("stardundee *** Open *** ERROR: USBSpaceWire_Open(&hDevice, 0))");
80 return;
87 81 }
88 82 emit sendMessage("stardundee *** Open *** USBSpaceWire_Open successful, device number: "
89 83 + QString::number(usbDeviceNumber_SPINBOX->value()));
90 84
91 85 USBSpaceWire_EnableNetworkMode(hDevice, 0); // deactivate the network mode
92 CFGSpaceWire_EnableRMAP(1); // Enable the use of RMAP
86 CFGSpaceWire_EnableRMAP(1); // Enable the use of RMAP for the StarDundee brick configuration
93 87 CFGSpaceWire_SetRMAPDestinationKey(0x20); // Set the destination key expected by STAR-Dundee devices
94 88
95 89 // Set the path and return path to the device
@@ -129,15 +123,27 void StarDundee::Open()
129 123 else emit sendMessage("Set the link status control for link " + QString::number(linkNumber_SPINBOX->value()));
130 124 }
131 125
132 setRoutingTableEntry(rmapTargetLogicalAddress, (1<<linkNumber_SPINBOX->value()));
133 setRoutingTableEntry(sourceLogicalAddress_SPINBOX->value(), (1<<3));
134 //setRoutingTableEntry(33, (1<<3));
126 if (CFGSpaceWire_SetAsInterface(hDevice, 1, 0) != CFG_TRANSFER_SUCCESS)
127 {
128 emit sendMessage("Could not set the device to be an interface");
129 }
130 else
131 {
132 emit sendMessage("Device set to be an interface");
133 }
135 134
136 emit sendMessage("The driver's current send buffer size is " + QString::number(USBSpaceWire_GetDriverSendBufferSize(hDevice)) + " bytes");
135 //setRoutingTableEntry(rmapTargetLogicalAddress, (1<<linkNumber_SPINBOX->value()));
136 //setRoutingTableEntry(rmapSourceLogicalAddress, (1<<3));
137 //GetRoutingTableEntry(rmapTargetLogicalAddress);
138 //GetRoutingTableEntry(rmapSourceLogicalAddress);
137 139
138 140 USBSpaceWire_RegisterReceiveOnAllPorts(hDevice); // Register to receive on all ports
139 141 USBSpaceWire_ClearEndpoints(hDevice); // clear the USB endpoints
140 142
143 emit sendMessage("The driver's current send buffer size is " + QString::number(USBSpaceWire_GetDriverSendBufferSize(hDevice)) + " bytes");
144 emit sendMessage("The driver's current read buffer size is " + QString::number(USBSpaceWire_GetDriverReadBufferSize(hDevice)) + " bytes");
145 emit sendMessage("USBSpaceWire_IsReadThrottling is " + QString::number(USBSpaceWire_IsReadThrottling(hDevice)));
146
141 147 // initialize SPW packet semaphores
142 148 while (rmapPacketSEMAPHORE->available()!=0) rmapPacketSEMAPHORE->acquire();
143 149 while (ccsdsPacketSEMAPHORE->available()!=0) ccsdsPacketSEMAPHORE->acquire();
@@ -148,7 +154,7 void StarDundee::Open()
148 154 }
149 155 else
150 156 {
151
157 starDundeeStatusQueryDialog->exec();
152 158 }
153 159 }
154 160
@@ -162,21 +168,35 void StarDundee::Close()
162 168 emit isOpen(false);
163 169 }
164 170
165 unsigned int StarDundee::GetRoutingTableEntry()
171 unsigned char StarDundee::setRoutingTableEntry(int tableEntry, U32 dwOutputPorts)
172 {
173 U32 routingTableEntry;
174 // SET THE ROUTING TABLE ENTRY FOR LOGICAL ADDRESSING, TARGET entryNumber
175 if (CFGSpaceWire_ClearRoutingTableEntry(hDevice, tableEntry) != CFG_TRANSFER_SUCCESS)
176 {
177 emit sendMessage("Could not clear routing table entry " + QString::number(tableEntry));
178 }
179 // Build the routing table entry
180 CFGSpaceWire_RTBuildRoutingTableEntry(&routingTableEntry,
181 dwOutputPorts, // route out of port dwOutputPorts
182 0, // header deletion disabled
183 0); // priority normal
184 // Set the routing table entry for logical address tableEntry
185 if (CFGSpaceWire_SetRoutingTableEntry(hDevice, tableEntry, routingTableEntry) != CFG_TRANSFER_SUCCESS)
186 {
187 emit sendMessage("Could not set routing table entry [" + QString::number(tableEntry) + "]");
188 }
189 else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] set" );
190 return 1;
191 }
192
193 unsigned int StarDundee::GetRoutingTableEntry(int tableEntry)
166 194 {
167 195 U32 routingTableEntry, outputPorts;
168 196 char enabled, delHead, priority;
169 197 int portNum;
170 int tableEntry;
171 198
172 tableEntry = rmapTargetLogicalAddress;
173
174 // Set the path and return path to the device
175 CFGSpaceWire_StackClear();
176 CFGSpaceWire_AddrStackPush(0);
177 CFGSpaceWire_AddrStackPush(254);
178 CFGSpaceWire_RetAddrStackPush(254);
179
199 emit sendMessage("GetRoutingTableEntry [" + QString::number(tableEntry) + "]");
180 200 // Read the routing table entry
181 201 if (CFGSpaceWire_GetRoutingTableEntry(hDevice, tableEntry, &routingTableEntry) != CFG_TRANSFER_SUCCESS)
182 202 {
@@ -343,8 +363,8 unsigned int StarDundee::WriteBLOCK(char
343 363 {
344 364 RMAP *RMAPCommand;
345 365 char * packet;
366 char* aux;
346 367 unsigned char offset, headerSize, CRCSize;
347 char* aux;
348 368 unsigned int totalSize;
349 369 int errorCode;
350 370 QString console_message;
@@ -366,16 +386,17 unsigned int StarDundee::WriteBLOCK(char
366 386
367 387 //*************************
368 388 // BUILD THE PACKET TO SEND
369 totalSize = headerSize + nbBytes + CRCSize;
389 totalSize = headerSize + nbBytes + CRCSize + PATH_ADDRESSING_OFFSET;
370 390 packet = (char*) malloc( totalSize );
371 391 aux = (char*) ((void*) &RMAPCommand->RMAPHeader);
372 for(unsigned int i = 0; i<headerSize; i++) packet[i] = aux[i];
392 packet[0] = this->linkNumber_SPINBOX->value();
393 for(unsigned int i = 0; i<headerSize; i++) packet[i+PATH_ADDRESSING_OFFSET] = aux[i];
373 394 offset = headerSize;
374 395 for(unsigned int i = 0; i<nbBytes; i++)
375 396 {
376 packet[i+offset] = data[i];
397 packet[i+offset+PATH_ADDRESSING_OFFSET] = data[i];
377 398 }
378 packet[nbBytes+offset] = RMAPCommand->dataCRC;
399 packet[nbBytes+offset+PATH_ADDRESSING_OFFSET] = RMAPCommand->dataCRC;
379 400
380 401 //****************
381 402 // SEND THE PACKET
@@ -480,7 +501,10 unsigned int StarDundee::ReadBLOCK(unsig
480 501 {
481 502 int errorCode;
482 503 RMAP *RMAPCommand;
483 unsigned int dataLength;
504 char *packet;
505 char *aux;
506 unsigned int dataLength = 0;
507 unsigned int totalSize = 0;
484 508
485 509 //**********************
486 510 // Check the link status
@@ -511,12 +535,39 unsigned int StarDundee::ReadBLOCK(unsig
511 535 nbBytes,
512 536 NULL);
513 537 }
538
539 //*************************
540 // BUILD THE PACKET TO SEND
541 totalSize = sizeof(RMAPCommand->RMAPHeader) + PATH_ADDRESSING_OFFSET;
542 packet = (char*) malloc( totalSize );
543 aux = (char*) ((void*) &RMAPCommand->RMAPHeader);
544 packet[0] = this->linkNumber_SPINBOX->value();
545 for (unsigned int i = 0; i<sizeof(RMAPCommand->RMAPHeader); i++)
546 packet[i+PATH_ADDRESSING_OFFSET] = aux[i];
547
548 //****************
549 // SEND THE PACKET
514 550 result = USBSpaceWire_SendPacket(hDevice,
515 (unsigned char*) ((void*) &RMAPCommand->RMAPHeader),
516 sizeof(RMAPCommand->RMAPHeader),
551 packet,
552 totalSize,
517 553 BWAIT_1, &pIdentifier);
518 554 if (result != TRANSFER_SUCCESS) emit sendMessage("ERR *** ReadStarDundee *** ReadBLOCK *** sending the READ command ");
519 else emit sendMessage("OK *** ReadStarDundee *** ReadBLOCK *** sending the READ command");
555 else
556 {
557 emit sendMessage("OK *** ReadStarDundee *** ReadBLOCK *** sending the READ command");
558 emit appendToLog("packet sent, B0 = " + QString::number(packet[0], 16)
559 + " *** B1 = " + QString::number(packet[1], 16)
560 + " *** B2 = " + QString::number(packet[2], 16)
561 + " *** B3 = " + QString::number(packet[3], 16)
562 + " *** B4 = " + QString::number(packet[4], 16)
563 + " *** B5 = " + QString::number(packet[5], 16)
564 );
565 }
566
567 //**************
568 // Free the send
569 USBSpaceWire_FreeSend(hDevice, pIdentifier);
570 free(packet);
520 571
521 572 //*********************************
522 573 // RECEIVE THE INCOMING RMAP PACKET
@@ -561,20 +612,21 unsigned int StarDundee::WriteSPW(char *
561 612 return 1;
562 613 }
563 614
564 totalSize = count + 4;
615 totalSize = count + 4 + PATH_ADDRESSING_OFFSET; // The StarDundee brick is in PATH addressing
565 616 SPWData = (char*) malloc(totalSize);
566 617 // SPW HEADER
567 SPWData[0] = targetLogicalAddress;
568 SPWData[1] = protocoleIdentifier;
569 SPWData[2] = reserved;
570 SPWData[3] = userApplication;
618 SPWData[0] = this->linkNumber_SPINBOX->value(); // 1 by default, value can be 1 or 2
619 SPWData[0+PATH_ADDRESSING_OFFSET] = targetLogicalAddress;
620 SPWData[1+PATH_ADDRESSING_OFFSET] = protocoleIdentifier;
621 SPWData[2+PATH_ADDRESSING_OFFSET] = reserved;
622 SPWData[3+PATH_ADDRESSING_OFFSET] = userApplication;
571 623 // CCSDS PACKET
572 624 for (unsigned int i = 0; i<count; i++)
573 625 {
574 SPWData[i+4] = Value[i];
626 SPWData[i+4+PATH_ADDRESSING_OFFSET] = Value[i];
575 627 }
576 628
577 //************
629 //****************
578 630 // SEND THE PACKET
579 631 result = USBSpaceWire_SendPacket(hDevice,
580 632 SPWData,
@@ -588,7 +640,21 unsigned int StarDundee::WriteSPW(char *
588 640 free(SPWData);
589 641 return 0;
590 642 }
591 else emit sendMessage("OK *** WriteSPW when sending packet of size " + QString::number(totalSize));
643 else emit sendMessage("OK *** WriteSPW when sending packet of size " + QString::number(totalSize-1));
644 emit appendToLog("packet sent, B0 = " + QString::number(SPWData[0])
645 + " *** B1 = " + QString::number(SPWData[1])
646 + " *** B2 = " + QString::number(SPWData[2])
647 + " *** B3 = " + QString::number(SPWData[3])
648 + " *** B4 = " + QString::number(SPWData[4])
649 + " *** B5 = " + QString::number(SPWData[5])
650 + " *** B6 = " + QString::number(SPWData[6])
651 + " *** B7 = " + QString::number(SPWData[7])
652 + " *** B8 = " + QString::number(SPWData[8])
653 + " *** B9 = " + QString::number(SPWData[9])
654 + " *** B10 = " + QString::number(SPWData[10])
655 + " *** B11 = " + QString::number(SPWData[11])
656 + " *** B12 = " + QString::number(SPWData[12])
657 );
592 658
593 659 //**************
594 660 // Free the send
@@ -651,6 +717,31 unsigned int StarDundee::getLinkStatus(u
651 717 else return 0;
652 718 }
653 719
720 void StarDundee::receivePollingLoop()
721 {
722 timer->blockSignals(true);
723 if (USBSpaceWire_WaitOnReadPacketAvailable(hDevice, 0)) receiveSPWPacketLoop(0);
724 timer->blockSignals(false);
725 }
726
727 int StarDundee::receiveSPWPacketLoop(unsigned char requestID)
728 {
729 int result = 0;
730 emit appendToLog("Number of packets dropped by the driver: " +
731 QString::number(USBSpaceWire_GetDriverDroppedPackets(hDevice)));
732
733 while (USBSpaceWire_WaitOnReadPacketAvailable(hDevice, 0))
734 {
735 //sendMessage("trying to get a packet");
736 result = receiveSPWPacket(requestID);
737 }
738 if (!ccsdsPacketStore.isEmpty())
739 {
740 emit packetStoreNotEmpty();
741 }
742 return result;
743 }
744
654 745 int StarDundee::receiveSPWPacket(unsigned char requestID) // SLOT
655 746 {
656 747 unsigned int packetLength;
@@ -670,7 +761,7 int StarDundee::receiveSPWPacket(unsigne
670 761 // TRY TO RECEIVE DATA
671 762 nbBytes = qMax(RMAP_MAX_PACKET_LENGTH, CCSDS_MAX_PACKET_LENGTH); // maximum size of the packet to receive
672 763 nPacketNum = 1;
673 result = USBSpaceWire_ReadPackets(hDevice, spwPacket, nbBytes, nPacketNum, BWAIT_1, &properties, &pIdentifier);
764 result = USBSpaceWire_ReadPackets(hDevice, spwPacket, nbBytes, nPacketNum, BWAIT_1, &properties, &pIdentifierRead);
674 765 if (result != TRANSFER_SUCCESS)
675 766 {
676 767 emit sendMessage("Error: Could not receive the packet");
@@ -679,7 +770,20 int StarDundee::receiveSPWPacket(unsigne
679 770 else
680 771 {
681 772 packetLength = properties.len;
682 USBSpaceWire_FreeRead(hDevice, pIdentifier); // Free the receive
773 if (properties.eop == SPACEWIRE_USB_NO_EOP)
774 {
775 emit appendToLog("No end of packet marker received");
776 }
777 else if (properties.eop == SPACEWIRE_USB_EOP)
778 {
779 emit appendToLog("Normal end of packet marker received");
780 }
781 else if (properties.eop == SPACEWIRE_USB_EEP)
782 {
783 emit appendToLog("Error end of packet marker received");
784 }
785
786 USBSpaceWire_FreeRead(hDevice, pIdentifierRead); // Free the read buffer
683 787 }
684 788
685 789 switch(spwPacket[1]) // byte 1 is the protocole identifier in the SPW packet
@@ -690,45 +794,62 int StarDundee::receiveSPWPacket(unsigne
690 794 rmapPacketSize = packetLength;
691 795 rmapPacketSEMAPHORE->release();
692 796 emit appendToLog("RMAP packet of size " + QString::number(packetLength) + " received");
797 emit appendToLog("packet received, B0 = " + QString::number(spwPacket[0], 16)
798 + " *** B1 = " + QString::number(spwPacket[1], 16)
799 + " *** B2 = " + QString::number(spwPacket[2], 16)
800 + " *** B3 = " + QString::number(spwPacket[3], 16)
801 + " *** B4 = " + QString::number(spwPacket[4], 16)
802 + " *** B5 = " + QString::number(spwPacket[5], 16)
803 );
693 804 return packetLength;
694 805
695 806 case 2: // 0x02 is the protocole identifier for CCSDS packets
696 if (ccsdsPacketSEMAPHORE->available()!=0) return -4; // ERROR === previous CCSDS packet not processed yet
807 if (ccsdsPacketSEMAPHORE->available()!=0)
808 {
809 emit sendMessage("in function [receiveSPWPacket] === ERROR === previous CCSDS packet not processed yet");
810 return -4; // ERROR === previous CCSDS packet not processed yet
811 }
697 812 for(unsigned int i=0; i<packetLength; i++) ccsdsPacket[i] = spwPacket[i];
698 813 ccsdsPacketSize = packetLength;
699 ccsdsPacketSEMAPHORE->release();
814 //ccsdsPacketSEMAPHORE->release();
815 //emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
700 816 emit appendToLog("CCSDS packet of size " + QString::number(packetLength) + " received");
701 emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
817 emit appendToLog("packet received, byte0 " + QString::number(spwPacket[0], 16)
818 + " *** byte1 " + QString::number(spwPacket[1], 16)
819 + " *** byte2 " + QString::number(spwPacket[2], 16)
820 + " *** byte3 " + QString::number(spwPacket[3], 16));
821 storeCCSDSPacket(ccsdsPacket, packetLength);
702 822 return packetLength;
823 default:
824 emit appendToLog("packet received, byte0 " + QString::number(spwPacket[0], 16)
825 + " *** byte1 " + QString::number(spwPacket[1], 16)
826 + " *** byte2 " + QString::number(spwPacket[2], 16)
827 + " *** byte3 " + QString::number(spwPacket[3], 16));
703 828 }
704 829 return 0;
705 830 }
706 831
707 void StarDundee::receivePollingLoop()
832 unsigned int StarDundee::storeCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size)
708 833 {
709 timer->blockSignals(true);
710 if (USBSpaceWire_WaitOnReadPacketAvailable(hDevice, 0)) receiveSPWPacket(0);
711 timer->blockSignals(false);
834 unsigned int i;
835 ccsdsPacketToProcess_t ccsdsPacketToStore;
836
837 ccsdsPacketToStore.size = size;
838 for(i=0; i<size; i++)
839 {
840 ccsdsPacketToStore.data[i] = ccsdsPacket[i];
841 }
842 ccsdsPacketStore << ccsdsPacketToStore;
843 //emit(ccsdsPacketAvailable(ccsdsPacket, packetLength));
844 //emit ccsdsPacketIsAvailable(size);
845 return 1;
712 846 }
713 847
714 unsigned char StarDundee::setRoutingTableEntry(int tableEntry, U32 dwOutputPorts)
848 void StarDundee::reTestSPWLink() // SLOT
715 849 {
716 U32 routingTableEntry;
717 // SET THE ROUTING TABLE ENTRY FOR LOGICAL ADDRESSING, TARGET entryNumber
718 if (CFGSpaceWire_ClearRoutingTableEntry(hDevice, tableEntry) != CFG_TRANSFER_SUCCESS)
850 if (getLinkStatus(linkNumber_SPINBOX->value()))
719 851 {
720 emit sendMessage("Could not clear routing table entry " + QString::number(tableEntry));
852 emit isOpen(true);
853 starDundeeStatusQueryDialog->accept();
721 854 }
722 // Build the routing table entry
723 CFGSpaceWire_RTBuildRoutingTableEntry(&routingTableEntry,
724 dwOutputPorts, // route out of port dwOutputPorts
725 0, // header deletion disabled
726 0); // priority normal
727 // Set the routing table entry for logical address tableEntry
728 if (CFGSpaceWire_SetRoutingTableEntry(hDevice, tableEntry, routingTableEntry) != CFG_TRANSFER_SUCCESS)
729 {
730 emit sendMessage("Could not set routing table entry [" + QString::number(tableEntry) + "]");
731 }
732 else emit sendMessage("Routing table entry [" + QString::number(tableEntry) + "] set" );
733
734 855 }
Show file before | Show file after | Hide comments
@@ -13,9 +13,11
13 13 #include "rmapoperations.h"
14 14 #include "spw_usb_api.h"
15 15 #include "spw_config_library.h"
16 #include "ccsds.h"
16 17
17 18 #define BWAIT_0 0
18 19 #define BWAIT_1 1
20 #define PATH_ADDRESSING_OFFSET 1
19 21
20 22 class StarDundee : public QWidget
21 23 {
@@ -27,23 +29,28 public:
27 29 unsigned int Read(unsigned int *Value,unsigned int count,unsigned int address=0);
28 30 unsigned int WriteSPW(char *Value, unsigned int count, char targetLogicalAddress, char userApplication);
29 31
32 unsigned int storeCCSDSPacket(unsigned char *ccsdsPacket, unsigned int size);
33 QList<ccsdsPacketToProcess_t> ccsdsPacketStore;
34
30 35 signals:
31 36 void sendMessage(QString message);
32 37 void isOpen(bool);
33 38 void RMAP_write_reply_setText(QString);
34 39 void appendToLog(QString);
35 40 void ccsdsPacketAvailable(unsigned char*, unsigned int);
41 void packetStoreNotEmpty();
36 42
37 43 public slots:
38 44 void Open();
39 45 void Close();
40 int receiveSPWPacket(unsigned char requestID);
46 void reTestSPWLink();
47 int receiveSPWPacketLoop(unsigned char requestID=0);
48 int receiveSPWPacket(unsigned char requestID=0);
41 49 void commandCodeHasChanged(RMAP_command_codes code) {this->commandCode = code;}
42 50 void targetHasChanged(int target) {rmapTargetLogicalAddress = (unsigned char) target;}
51 void sourceHasChanged(int source) {rmapSourceLogicalAddress = (unsigned char) source;}
43 52 void ccsdsPacketIsProcessed() {ccsdsPacketSEMAPHORE->tryAcquire();}
44 void reTestSPWLink() {getLinkStatus(linkNumber_SPINBOX->value());}
45 53 //
46 void sourceHasChanged(int target) {rmapSourceLogicalAddress = (unsigned char) target;}
47 54 void receivePollingLoop();
48 55
49 56 private:
@@ -54,7 +61,7 private:
54 61 unsigned char setRoutingTableEntry(int tableEntry, U32 dwOutputPorts);
55 62
56 63 unsigned int getLinkStatus(unsigned char link);
57 unsigned int GetRoutingTableEntry();
64 unsigned int GetRoutingTableEntry(int tableEntry);
58 65
59 66 unsigned char rmapTargetLogicalAddress ;
60 67 unsigned char rmapSourceLogicalAddress ;
@@ -63,12 +70,10 private:
63 70
64 71 QLabel *usbDeviceNumber_LABEL;
65 72 QLabel *linkNumber_LABEL;
66 QLabel *sourceLogicalAddress_LABEL;
67 73 QLabel *starDundeeStatusQueryDialogLabel;
68 74
69 75 QSpinBox *usbDeviceNumber_SPINBOX;
70 76 QSpinBox *linkNumber_SPINBOX;
71 QSpinBox *sourceLogicalAddress_SPINBOX;
72 77
73 78 QGridLayout *connection_LAYOUT;
74 79 QGridLayout *starDundeeStatusQueryDialogLayout;
@@ -80,8 +85,9 private:
80 85
81 86 QTimer *timer;
82 87
83 unsigned char pBuffer[10]; // Pointer to the start of the user buffer from which to transmit data
84 USB_SPACEWIRE_ID pIdentifier; // A pointer to a variable which will be set to contain a unique identifier for the send
88 unsigned char pBuffer[10]; // Pointer to the start of the user buffer from which to transmit data
89 USB_SPACEWIRE_ID pIdentifierRead; // A pointer to a variable which will be set to contain a unique identifier for the read
90 USB_SPACEWIRE_ID pIdentifier;
85 91
86 92 star_device_handle hDevice; // Handle to the SpaceWire device
87 93 USB_SPACEWIRE_STATUS result; // The result of the send operation
General Comments 0
You need to be logged in to leave comments. Login now