HG_REPOSITORIES/LPP/INSTRUMENTATION/USERS/JEANDET/LFR_FSW Commit - r15:d75852f5b698

FSW modified to have correct answers to TC_LFR_DUMP_PAR

paul@pc-solar1.lab-lpp.local -

r15:d75852f5b698 default

parent child

Context file:

r15:d75852f5b698

Collapse all files

FSW-rtems/FSW-rtems.layout +16 -16

             <?xml version="1.0" encoding="UTF-8" standalone="yes" ?>
             <CodeBlocks_layout_file>
             	<ActiveTarget name="Debug" />
-            	<File name="../header/ccsds_types.h" open="1" top="0" tabpos="2">
+            	<File name="../header/ccsds_types.h" open="0" top="0" tabpos="3">
-            		<Cursor position="553" topLine="24" />
+            		<Cursor position="417" topLine="3" />
             	</File>
-            	<File name="../header/fsw_init.h" open="0" top="0" tabpos="3">
+            	<File name="../header/fsw_init.h" open="0" top="0" tabpos="6">
-            		<Cursor position="1521" topLine="15" />
+            		<Cursor position="1629" topLine="27" />
             	</File>
             	<File name="../header/fsw_misc.h" open="0" top="0" tabpos="0">
             		<Cursor position="114" topLine="0" />
             	</File>
             	<File name="../header/fsw_params.h" open="0" top="0" tabpos="2">
-            		<Cursor position="1358" topLine="31" />
+            		<Cursor position="481" topLine="0" />
             	</File>
             	<File name="../header/fsw_processing.h" open="0" top="0" tabpos="0">
             		<Cursor position="628" topLine="7" />
             	</File>
             	<File name="../header/grlib_regs.h" open="0" top="0" tabpos="4">
-            		<Cursor position="1153" topLine="11" />
+            		<Cursor position="1153" topLine="16" />
             	</File>
             	<File name="../header/tc_handler.h" open="0" top="0" tabpos="4">
-            		<Cursor position="624" topLine="2" />
+            		<Cursor position="1380" topLine="35" />
             	</File>
             	<File name="../header/wf_handler.h" open="0" top="0" tabpos="0">
-            		<Cursor position="318" topLine="0" />
+            		<Cursor position="341" topLine="0" />
             	</File>
-            	<File name="../src/fsw_globals.c" open="0" top="0" tabpos="3">
+            	<File name="../src/fsw_globals.c" open="0" top="0" tabpos="5">
-            		<Cursor position="378" topLine="1" />
+            		<Cursor position="99" topLine="0" />
             	</File>
             	<File name="../src/fsw_init.c" open="1" top="0" tabpos="1">
-            		<Cursor position="10747" topLine="81" />
+            		<Cursor position="12524" topLine="55" />
             	</File>
             	<File name="../src/fsw_misc.c" open="0" top="0" tabpos="2">
-            		<Cursor position="475" topLine="0" />
+            		<Cursor position="2621" topLine="0" />
             	</File>
             	<File name="../src/fsw_processing.c" open="0" top="0" tabpos="0">
-            		<Cursor position="1696" topLine="59" />
+            		<Cursor position="1792" topLine="43" />
             	</File>
-            	<File name="../src/tc_handler.c" open="1" top="1" tabpos="3">
+            	<File name="../src/tc_handler.c" open="1" top="1" tabpos="2">
-            		<Cursor position="11453" topLine="39" />
+            		<Cursor position="13883" topLine="80" />
             	</File>
             	<File name="../src/wf_handler.c" open="0" top="0" tabpos="4">
-            		<Cursor position="1660" topLine="24" />
+            		<Cursor position="4576" topLine="83" />
             	</File>
             </CodeBlocks_layout_file>

FSW-rtems/bin/Debug/fsw binary modified 0 0

NO CONTENT: modified file, binary diff hidden

header/fsw_init.h +8 -1

             #ifndef FSW_RTEMS_H_INCLUDED
             #define FSW_RTEMS_H_INCLUDED
             #include <errno.h>
             #include <fcntl.h>
             #include <stdio.h>
             #include <stdlib.h>
             #include <grspw.h>
             #include <apbuart.h>
             #include <fsw_params.h>
             #include <fsw_misc.h>
             #include <fsw_processing.h>
             #include <tc_handler.h>
             #include <wf_handler.h>
             #include <grlib_regs.h>
             extern int sched_yield();
             extern int errno;
             extern rtems_id   Task_id[ ];       /* array of task ids */
             extern rtems_name Task_name[ ];     /* array of task names */
             extern rtems_name misc_name[ ];    /* arry of miscellaneous names for rtems objects */
             extern int fdSPW;   // grspw file descriptor
             extern int fdUART;  // uart file descriptor
+            void timecode_irq_handler(void *pDev, void *regs, int minor, unsigned int tc);
             // MODE PARAMETERS
             extern struct param_norm_str param_norm;
             extern struct param_burst_str param_burst;
             extern struct param_sbm1_str param_sbm1;
             extern struct param_sbm2_str param_sbm2;
             extern unsigned char param_common[];
             // RTEMS TASKS
             rtems_task Init( rtems_task_argument argument);	/* forward declaration needed */
             rtems_task recv_task(rtems_task_argument argument);
             rtems_task spiq_task(rtems_task_argument argument);
             rtems_task stat_task(rtems_task_argument argument);
             rtems_task wfrm_task(rtems_task_argument argument);
             int create_all_tasks();
             int start_all_tasks();
             int create_message_queue();
             // OTHER functions
             void init_default_mode_parameters();
             int configure_spw_link();
-            int send_console_outputs_on_serial_port();
+            void configure_spacewire_set_NP(unsigned char val, unsigned int regAddr); // No Port force
+            void configure_spacewire_set_RE(unsigned char val, unsigned int regAddr); // RMAP Enable
             extern int rtems_cpu_usage_report();
             extern int rtems_cpu_usage_reset();
             void print_statistics(spw_stats *);
             rtems_status_code write_spw(spw_ioctl_pkt_send* spw_ioctl_send);
+            void (*grspw_timecode_callback) (void *pDev, void *regs, int minor, unsigned int tc);
             #endif // FSW_RTEMS_CONFIG_H_INCLUDED

header/tc_handler.h +1 0

             #ifndef TC_HANDLER_H_INCLUDED
             #define TC_HANDLER_H_INCLUDED
             #include <rtems.h>
             #include <bsp.h>        // for the LEON_Unmask_interrupt function
             #include <stdio.h>
             #include <unistd.h>     // for the read call
             #include <sys/ioctl.h>  // for the ioctl call
             #include <ccsds_types.h>
             #include <grspw.h>
             #include <fsw_init.h>
             extern int fdSPW;
             extern rtems_name misc_name[ ];
             extern rtems_name misc_id[ ];
             extern rtems_id Task_id[ ];         // array of task ids
             // MODE PARAMETERS
             extern struct param_norm_str param_norm;
             extern struct param_sbm1_str param_sbm1;
             extern struct param_sbm2_str param_sbm2;
             extern time_management_regs_t *time_management_regs;
             extern unsigned char param_common[];
             unsigned char currentTC_LEN_RCV[2]; //  SHALL be equal to the current TC packet estimated packet length field
             unsigned char currentTC_COMPUTED_CRC[2];
             unsigned int currentTC_LEN_RCV_AsUnsignedInt;
             unsigned int currentTM_length;
             unsigned char currentTC_processedFlag;
             //****
             // ISR
             rtems_isr commutation_isr1( rtems_vector_number vector );
             rtems_isr commutation_isr2( rtems_vector_number vector );
             //**********************
             // GENERAL USE FUNCTIONS
             unsigned int lookUpTableForCRC[256];
             void initLookUpTableForCRC();
             void GetCRCAsTwoBytes(unsigned char* data, unsigned char* crcAsTwoBytes, unsigned int sizeOfData);
             //*********************
             // ACCEPTANCE FUNCTIONS
             unsigned char acceptTM(ccsdsTelecommandPacket_t * TMPacket, unsigned int tc_len_recv);
             unsigned char TM_build_header( enum TM_TYPE tm_type, unsigned int packetLength,
                                           unsigned int coarseTime, unsigned int fineTime, TMHeader_t *TMHeader);
             unsigned char TM_build_data(ccsdsTelecommandPacket_t *TC, char* data, unsigned int SID, unsigned char *computed_CRC);
             int TC_checker(ccsdsTelecommandPacket_t *TC, unsigned int TC_LEN_RCV);
             //***********
             // RTEMS TASK
             rtems_task recv_task( rtems_task_argument unused );
             rtems_task actn_task( rtems_task_argument unused );
             rtems_task dumb_task( rtems_task_argument unused );
             int create_message_queue();
             //***********
             // TC ACTIONS
             int action_default(ccsdsTelecommandPacket_t *TC);
+            int action_default_alt(ccsdsTelecommandPacket_t *TC);
             int send_tm_lfr_tc_exe_success(ccsdsTelecommandPacket_t *TC);
             //
             int action_load_norm(ccsdsTelecommandPacket_t *TC);
             int action_enter(ccsdsTelecommandPacket_t *TC);
             int action_updt_time(ccsdsTelecommandPacket_t *TC);
             #endif // TC_HANDLER_H_INCLUDED

src/fsw_config.c +3 -1

             #include <drvmgr/ambapp_bus.h>
             // GRSPW0 resources
             struct drvmgr_key grlib_grspw_0n1_res[] = {
                 {"txBdCnt", KEY_TYPE_INT, {(unsigned int)10}},
                 {"rxBdCnt", KEY_TYPE_INT, {(unsigned int)10}},
                 {"txDataSize", KEY_TYPE_INT, {(unsigned int)4096}},
                 {"txHdrSize", KEY_TYPE_INT, {(unsigned int)20+6}}, // 6 is for the auxiliary header, when needed
                 {"rxPktSize", KEY_TYPE_INT, {(unsigned int)248+4}},
                 KEY_EMPTY
             };
             #if 0
                 /* APBUART0 */
                 struct drvmgr_key grlib_drv_res_apbuart0[] =
                 {
                     {"mode", KEY_TYPE_INT, {(unsigned int)1}},
                     {"syscon", KEY_TYPE_INT, {(unsigned int)1}},
                     KEY_EMPTY
                 };
                 /* APBUART1 */
                 struct drvmgr_key grlib_drv_res_apbuart1[] =
                 {
                     {"mode", KEY_TYPE_INT, {(unsigned int)1}},
                     {"syscon", KEY_TYPE_INT, {(unsigned int)0}},
                     KEY_EMPTY
                 };
                 /* LEON3 System with driver configuration for 2 APBUARTs, the
                 * the rest of the AMBA device drivers use their defaults.
                 */
                 /* Override default debug UART assignment.
                 * 0 = Default APBUART. APBUART[0], but on MP system CPU0=APBUART0,
                 *     CPU1=APBUART1...
                 * 1 = APBUART[0]
                 * 2 = APBUART[1]
                 * 3 = APBUART[2]
                 * ...
                 */
                 //int debug_uart_index = 2; /* second UART -- APBUART[1] */
             #endif
             // If RTEMS_DRVMGR_STARTUP is defined we override the "weak defaults" that is defined by the LEON3 BSP.
             struct drvmgr_bus_res grlib_drv_resources = {
                 .next = NULL,
                 .resource = {
                     {DRIVER_AMBAPP_GAISLER_GRSPW_ID, 0, &grlib_grspw_0n1_res[0]},
             //        {DRIVER_AMBAPP_GAISLER_APBUART_ID, 0, &grlib_drv_res_apbuart0[0]},
             //        {DRIVER_AMBAPP_GAISLER_APBUART_ID, 1, &grlib_drv_res_apbuart1[0]},
                     RES_EMPTY /* Mark end of device resource array */
                 }
             };

src/fsw_globals.c +1 0

             #include <fsw_processing.h>
             #include <rtems.h>
             // RTEMS GLOBAL VARIABLES
             rtems_name misc_name[5];
             rtems_name misc_id[5];
             rtems_id   Task_id[10];         /* array of task ids */
             rtems_name Task_name[10];       /* array of task names */
             int fdSPW;
             int fdUART;
             // APB CONFIGURATION REGISTERS
             time_management_regs_t *time_management_regs = (time_management_regs_t*) REGS_ADDR_TIME_MANAGEMENT;
             // WAVEFORMS GLOBAL VARIABLES
             volatile int wf_snap_f0[ NB_SAMPLES_PER_SNAPSHOT * NB_BYTES_SWF_BLK ]; // 24576 bytes
             volatile int wf_snap_f1[ NB_SAMPLES_PER_SNAPSHOT * NB_BYTES_SWF_BLK ]; // 24576 bytes
             volatile int wf_snap_f2[ NB_SAMPLES_PER_SNAPSHOT * NB_BYTES_SWF_BLK ]; // 24576 bytes
             volatile int wf_cont_f3[ NB_SAMPLES_PER_SNAPSHOT * NB_BYTES_SWF_BLK ]; // 24576 bytes
             // SPECTRAL MATRICES GLOBAL VARIABLES
             volatile int spec_mat_f0_a[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_b[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_c[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_d[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_e[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_f[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_g[ TOTAL_SIZE_SPEC_MAT ];
             volatile int spec_mat_f0_h[ TOTAL_SIZE_SPEC_MAT ];
             //
             float averaged_spec_mat_f0[ TOTAL_SIZE_SPEC_MAT ];
             float compressed_spec_mat_f0[ TOTAL_SIZE_COMPRESSED_MATRIX_f0 ];
             // MODE PARAMETERS
             struct param_norm_str param_norm;
             struct param_burst_str param_burst;
             struct param_sbm1_str param_sbm1;
             struct param_sbm2_str param_sbm2;
             unsigned char param_common[2];
             // BASIC PARAMETERS GLOBAL VARIABLES
             unsigned char LFR_BP1_F0[ NB_BINS_COMPRESSED_MATRIX_f0 * 9 ];
             BP1_t data_BP1[ NB_BINS_COMPRESSED_MATRIX_f0 ];

src/fsw_init.c +51 -10

             //*************************
             // GPL reminder to be added
             //*************************
             #include <rtems.h>
             /* configuration information */
             #define CONFIGURE_INIT
             #include <bsp.h> /* for device driver prototypes */
             /* configuration information */
             #define CONFIGURE_APPLICATION_NEEDS_CONSOLE_DRIVER
             #define CONFIGURE_APPLICATION_NEEDS_CLOCK_DRIVER
             #define CONFIGURE_MAXIMUM_TASKS             10
             #define CONFIGURE_RTEMS_INIT_TASKS_TABLE
             #define CONFIGURE_EXTRA_TASK_STACKS         (3 * RTEMS_MINIMUM_STACK_SIZE)
             #define CONFIGURE_LIBIO_MAXIMUM_FILE_DESCRIPTORS 32
             #define CONFIGURE_INIT_TASK_PRIORITY	100
             #define CONFIGURE_MAXIMUM_DRIVERS 16
             #define CONFIGURE_MAXIMUM_PERIODS 1
             #define CONFIGURE_MAXIMUM_MESSAGE_QUEUES 1
             #include <rtems/confdefs.h>
             /* If --drvmgr was enabled during the configuration of the RTEMS kernel */
             #ifdef RTEMS_DRVMGR_STARTUP
                 #ifdef LEON3
                 /* Add Timer and UART Driver */
                     #ifdef CONFIGURE_APPLICATION_NEEDS_CLOCK_DRIVER
                         #define CONFIGURE_DRIVER_AMBAPP_GAISLER_GPTIMER
                     #endif
                     #ifdef CONFIGURE_APPLICATION_NEEDS_CONSOLE_DRIVER
                         #define CONFIGURE_DRIVER_AMBAPP_GAISLER_APBUART
                     #endif
                 #endif
                 #define CONFIGURE_DRIVER_AMBAPP_GAISLER_GRSPW   /* GRSPW Driver */
                 #include <drvmgr/drvmgr_confdefs.h>
             #endif
             #include <fsw_init.h>
             #include <fsw_config.c>
             char *link_status(int status);
             char *lstates[6] = {"Error-reset",
                                 "Error-wait",
                                 "Ready",
                                 "Started",
                                 "Connecting",
                                 "Run"
             };
             rtems_task Init( rtems_task_argument ignored )
             {
                 rtems_status_code status;
                 rtems_isr_entry old_isr_handler;
                 //send_console_outputs_on_serial_port();
                 initLookUpTableForCRC(); // in tc_handler.h
                 init_default_mode_parameters();
                 create_message_queue();
                 create_all_tasks();
                 start_all_tasks();
+                grspw_timecode_callback = &timecode_irq_handler;
                 configure_spw_link();
                 configure_timer((gptimer_regs_t*) REGS_ADDR_GPTIMER, TIMER_SM_SIMULATOR, CLKDIV_SM_SIMULATOR,
                                 IRQ_SPARC_SM, spectral_matrices_isr );
                 configure_timer((gptimer_regs_t*) REGS_ADDR_GPTIMER, TIMER_WF_SIMULATOR, CLKDIV_WF_SIMULATOR,
                                 IRQ_SPARC_WF, waveforms_isr );
                 // irq handling of the time management unit
                 status = rtems_interrupt_catch( commutation_isr1,
                                                IRQ_SPARC_TIME1,
                                                &old_isr_handler) ; // see sparcv8.pdf p.76 for interrupt levels
                 if (status==RTEMS_SUCCESSFUL)
                     PRINTF("commutation_isr1 *** rtems_interrupt_catch successfullly configured\n")
                 status = rtems_interrupt_catch( commutation_isr2,
                                                IRQ_SPARC_TIME2,
                                                &old_isr_handler) ; // see sparcv8.pdf p.76 for interrupt levels
                 if (status==RTEMS_SUCCESSFUL)
                     PRINTF("commutation_isr2 *** rtems_interrupt_catch successfullly configured\n")
                 LEON_Unmask_interrupt( IRQ_TIME1 );
                 LEON_Unmask_interrupt( IRQ_TIME2 );
                 status = rtems_task_delete(RTEMS_SELF);
             }
             rtems_task spiq_task(rtems_task_argument unused)
             {
                 rtems_event_set event_out;
                 struct grspw_regs_str *grspw_regs;
                 grspw_regs = (struct grspw_regs_str *) REGS_ADDR_GRSPW;
                 while(1){
                     PRINTF("In SPIQ *** Waiting for SPW_LINKERR_EVENT\n")
                     rtems_event_receive(SPW_LINKERR_EVENT, RTEMS_WAIT, RTEMS_NO_TIMEOUT, &event_out); // wait for an SPW_LINKERR_EVENT
                     if (rtems_task_suspend(Task_id[1])!=RTEMS_SUCCESSFUL)   // suspend RECV task
                         PRINTF("In SPIQ *** Error suspending RECV Task\n")
                     configure_spw_link();
                     if (rtems_task_restart(Task_id[1], 1)!=RTEMS_SUCCESSFUL) // restart RECV task
                         PRINTF("In SPIQ *** Error resume RECV Task\n")
                 }
             }
             void init_default_mode_parameters()
             {
                 // COMMON PARAMETERS
                 param_common[0] = 0x00;
                 param_common[1] = 0x10;             // default value 0 0 0 1 0 0 0 0
                 // NORMAL MODE
                 param_norm.sy_lfr_n_swf_l = 2048;   // nb sample
                 param_norm.sy_lfr_n_swf_p = 300;    // sec
                 param_norm.sy_lfr_n_asm_p = 3600;   // sec
                 param_norm.sy_lfr_n_bp_p0 = 4;      // sec
                 param_norm.sy_lfr_n_bp_p1 = 20;     // sec
                 // BURST MODE
                 param_burst.sy_lfr_b_bp_p0 = 1;     // sec
                 param_burst.sy_lfr_b_bp_p1 = 5;     // sec
                 // SBM1 MODE
                 param_sbm1.sy_lfr_s1_bp_p0 = 1;     // sec
                 param_sbm1.sy_lfr_s1_bp_p1 = 1;     // sec
                 // SBM2 MODE
                 param_sbm2.sy_lfr_s2_bp_p0 = 1;     // sec
                 param_sbm2.sy_lfr_s2_bp_p0 = 5;     // sec
             }
             int create_all_tasks()
             {
                 rtems_status_code status;
                 Task_name[1] = rtems_build_name( 'R', 'E', 'C', 'V' );
                 Task_name[2] = rtems_build_name( 'A', 'C', 'T', 'N' );
                 Task_name[3] = rtems_build_name( 'S', 'P', 'I', 'Q' );
                 Task_name[4] = rtems_build_name( 'S', 'M', 'I', 'Q' );
                 Task_name[5] = rtems_build_name( 'S', 'T', 'A', 'T' );
                 Task_name[6] = rtems_build_name( 'A', 'V', 'F', '0' );
                 Task_name[7] = rtems_build_name( 'B', 'P', 'F', '0' );
                 Task_name[8] = rtems_build_name( 'W', 'F', 'R', 'M' );
                 Task_name[9] = rtems_build_name( 'D', 'U', 'M', 'B' );
                 // RECV
                 status = rtems_task_create(
                     Task_name[1], 200, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES, &Task_id[1]
                 );
                 // ACTN
                 status = rtems_task_create(
                     Task_name[2], 50, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES, &Task_id[2]
                 );
                 // SPIQ
                 status = rtems_task_create(
                     Task_name[3], 50, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES, &Task_id[3]
                 );
                 // SMIQ
                 status = rtems_task_create(
                     Task_name[4], 10, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES | RTEMS_NO_PREEMPT,
                     RTEMS_DEFAULT_ATTRIBUTES, &Task_id[4]
                 );
                 // STAT
                 status = rtems_task_create(
                     Task_name[5], 150, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES, &Task_id[5]
                 );
                 // AVF0
                 status = rtems_task_create(
                     Task_name[6], 50, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES  | RTEMS_NO_PREEMPT,
                     RTEMS_DEFAULT_ATTRIBUTES | RTEMS_FLOATING_POINT, &Task_id[6]
                 );
                 // BPF0
                 status = rtems_task_create(
                     Task_name[7], 50, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES | RTEMS_FLOATING_POINT, &Task_id[7]
                 );
                 // WFRM
                 status = rtems_task_create(
                     Task_name[8], 100, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES | RTEMS_FLOATING_POINT, &Task_id[8]
                 );
                 // DUMB
                 status = rtems_task_create(
                     Task_name[9], 200, RTEMS_MINIMUM_STACK_SIZE * 2,
                     RTEMS_DEFAULT_MODES,
                     RTEMS_DEFAULT_ATTRIBUTES, &Task_id[9]
                 );
                 return 0;
             }
             int start_all_tasks()
             {
                 rtems_status_code status;
                 status = rtems_task_start( Task_id[3], spiq_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_SPIQ\n")
                 status = rtems_task_start( Task_id[1], recv_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_RECV\n")
                 status = rtems_task_start( Task_id[2], actn_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_ACTN\n")
                 status = rtems_task_start( Task_id[4], smiq_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_BPPR\n")
                 status = rtems_task_start( Task_id[5], stat_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_STAT\n")
                 status = rtems_task_start( Task_id[6], avf0_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_AVF0\n")
                 status = rtems_task_start( Task_id[7], bpf0_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_BPF0\n")
                 status = rtems_task_start( Task_id[8], wfrm_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_WFRM\n")
                 status = rtems_task_start( Task_id[9], dumb_task, 1 );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In INIT *** Error starting TASK_DUMB\n")
                 return 0;
             }
             int configure_spw_link()
             {
                 rtems_status_code status;
                 close(fdSPW); // close the device if it is already open
                 fdSPW = open(GRSPW_DEVICE_NAME, O_RDWR); // open the device. the open call reset the hardware
                 if (fdSPW<0) PRINTF("In configure_spw_link *** Error opening"GRSPW_DEVICE_NAME"\n")
                 while(ioctl(fdSPW, SPACEWIRE_IOCTRL_START, 0) != RTEMS_SUCCESSFUL){
                     PRINTF("In configure_spw_link *** "GRSPW_DEVICE_NAME" not started, retry\n")
                     close(fdSPW); // close the device
                     fdSPW = open(GRSPW_DEVICE_NAME, O_RDWR); // open the device. the open call reset the hardware
                     if (fdSPW<0) PRINTF("In configure_spw_link *** Error opening"GRSPW_DEVICE_NAME"\n")
                     rtems_task_wake_after(100);
                 }
                 PRINTF("In configure_spw_link *** "GRSPW_DEVICE_NAME" opened and started successfully\n")
                 // sets a few parameters of the link
-                status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_RMAPEN, 1);      // sets the RMAP enable bit
+                //status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_RMAPEN, 1);      // sets the RMAP enable bit
-                if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_RMAPEN\n")
+                //if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_RMAPEN\n")
-                //
+                configure_spacewire_set_NP(1, REGS_ADDR_GRSPW); // No Port force
+                configure_spacewire_set_RE(1, REGS_ADDR_GRSPW); // the dedicated call seems to  break the no port force configuration
                 status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_RXBLOCK, 1);              // sets the blocking mode for reception
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_RXBLOCK\n")
                 //
                 status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_EVENT_ID, Task_id[3]);    // sets the task ID to which an event is sent when a
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_EVENT_ID\n") // link-error interrupt occurs
                 //
                 status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_DISABLE_ERR, 1);          // automatic link-disabling due to link-error interrupts
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_DISABLE_ERR\n")
                 //
                 status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_LINK_ERR_IRQ, 1);         // sets the link-error interrupt bit
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_LINK_ERR_IRQ\n")
+                //
                 status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_TXBLOCK_ON_FULL, 1);         // sets the link-error interrupt bit
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_TXBLOCK_ON_FULL\n")
+                //
                 status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_DESTKEY, CCSDS_DESTINATION_ID);  // sets the destination key
                 PRINTF1("destination address set to: %d\n", CCSDS_DESTINATION_ID)
-                if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_LINK_ERR_IRQ\n")
+                if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_DESTKEY\n")
+                //
-                status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_NODEADDR, CCSDS_NODE_ADDRESS);  // sets the destination key
+                status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_NODEADDR, CCSDS_NODE_ADDRESS);  // sets the node address
                 PRINTF1("node address set to: %d\n", CCSDS_NODE_ADDRESS)
-                if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_LINK_ERR_IRQ\n")
+                if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_NODEADDR\n")
+                //
+                status = ioctl(fdSPW, SPACEWIRE_IOCTRL_SET_TCODE_CTRL, 0x0909);
+                if (status!=RTEMS_SUCCESSFUL) PRINTF("In RECV *** Error SPACEWIRE_IOCTRL_SET_TCODE_CTRL,\n")
                 PRINTF("In configure_spw_link *** "GRSPW_DEVICE_NAME" configured successfully\n")
                 return RTEMS_SUCCESSFUL;
             }
+            void configure_spacewire_set_NP(unsigned char val, unsigned int regAddr) // No Port force
+            {
+                unsigned int *spwptr;
+                spwptr = (unsigned int*) regAddr;
+                if (val == 1)
+                {
+                    *spwptr = *spwptr | 0x00100000; // [NP] set the No port force bit
+                }
+                if (val== 0)
+                {
+                    *spwptr = *spwptr & 0xffdfffff;
+                }
+            }
+            void configure_spacewire_set_RE(unsigned char val, unsigned int regAddr) // RMAP Enable
+            {
+                unsigned int *spwptr;
+                spwptr = (unsigned int*) regAddr;
+                if (val == 1)
+                {
+                    *spwptr = *spwptr | 0x00010000; // [NP] set the No port force bit
+                }
+                if (val== 0)
+                {
+                    *spwptr = *spwptr & 0xfffdffff;
+                }
+            }
             char *link_status(int status){
                     return lstates[status];
             }
             rtems_status_code write_spw(spw_ioctl_pkt_send* spw_ioctl_send)
             {
                 rtems_status_code status;
                 status = ioctl( fdSPW, SPACEWIRE_IOCTRL_SEND, spw_ioctl_send );
                 if (status!=RTEMS_SUCCESSFUL) printf("In write_spw *** Error SPACEWIRE_IOCTRL_SEND\n");
                 return status;
             }
+            void timecode_irq_handler(void *pDev, void *regs, int minor, unsigned int tc)
+            {
+                if (rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_0 ) != RTEMS_SUCCESSFUL)
+                    printf("In timecode_irq_handler *** Error sending event to DUMB\n");
+            }

src/tc_handler.c +21 -10

             #include <tc_handler.h>
             #include <fsw_params.h>
             char *errorCCSDSMsg[8] = { "ILLEGAL_APID 0",
                                         "WRONG_LEN_PACKET 1",
                                         "INCOR_CHECKSUM 2",
                                         "ILL_TYPE 3",
                                         "ILL_SUBTYPE 4",
                                         "WRONG_APP_DATA 5",
                                         "WRONG_CMD_CODE 6",
                                         "CCSDS_TM_VALID 7"
             };
             //**********************
             // GENERAL USE FUNCTIONS
             unsigned int Crc_opt( unsigned char D, unsigned int Chk)
             {
                 return(((Chk << 8) & 0xff00)^lookUpTableForCRC [(((Chk >> 8)^D) & 0x00ff)]);
             }
             void initLookUpTableForCRC()
             {
                 unsigned int i, tmp;
                 for (i=0; i<256; i++)
                 {
                     tmp = 0;
                     if((i & 1) != 0) tmp = tmp ^ 0x1021;
                     if((i & 2) != 0) tmp = tmp ^ 0x2042;
                     if((i & 4) != 0) tmp = tmp ^ 0x4084;
                     if((i & 8) != 0) tmp = tmp ^ 0x8108;
                     if((i & 16) != 0) tmp = tmp ^ 0x1231;
                     if((i & 32) != 0) tmp = tmp ^ 0x2462;
                     if((i & 64) != 0) tmp = tmp ^ 0x48c4;
                     if((i & 128) != 0) tmp = tmp ^ 0x9188;
                     lookUpTableForCRC[i] = tmp;
                 }
             }
             void GetCRCAsTwoBytes(unsigned char* data, unsigned char* crcAsTwoBytes, unsigned int sizeOfData)
             {
                 unsigned int Chk;
                 int j;
                 Chk = 0xffff; // reset the syndrom to all ones
                 for (j=0; j<sizeOfData; j++) {
                     Chk = Crc_opt(data[j], Chk);
                 }
                 crcAsTwoBytes[0] = (unsigned char) (Chk >> 8);
                 crcAsTwoBytes[1] = (unsigned char) (Chk & 0x00ff);
             }
             //*********************
             // ACCEPTANCE FUNCTIONS
             int TC_checker(ccsdsTelecommandPacket_t *TC, unsigned int tc_len_recv)
             {
                 rtems_status_code status;
                 spw_ioctl_pkt_send spw_ioctl_send;
                 TMHeader_t TM_header;
                 unsigned int code = 0;
                 unsigned char computed_CRC[2];
                 char data[ TM_LEN_EXE_CORR + CCSDS_TC_TM_PACKET_OFFSET - TM_HEADER_LEN ];
                 GetCRCAsTwoBytes( (unsigned char*) TC->packetID, computed_CRC, tc_len_recv + 5 );
                 code = acceptTM( TC, tc_len_recv ) ;
                 if ( (code == 0) | (code == 1) | (code == 2)
                     | (code == 3) | (code == 4) | (code == 5) )
                 { // generate TM_LFR_TC_EXE_CORRUPTED
                     // BUILD HEADER
                     TM_build_header( TM_LFR_TC_EXE_ERR, TM_LEN_EXE_CORR, 0, 0, &TM_header);
                     // BUILD DATA
                     TM_build_data( TC, data, SID_EXE_CORR, computed_CRC);
                     // PREPARE TM SENDING
                     spw_ioctl_send.hlen = TM_HEADER_LEN + 4; // + 4 is for the protocole extra header
                     spw_ioctl_send.hdr = (char*) &TM_header;
                     spw_ioctl_send.dlen = 16;
                     spw_ioctl_send.data = data;
                     // SEND PACKET
                     write_spw(&spw_ioctl_send);
                 }
                 else { // send valid TC to the action launcher
                     status =  rtems_message_queue_send( misc_id[0], TC, tc_len_recv + CCSDS_TC_TM_PACKET_OFFSET + 3);
                     return -1;
                 }
                 return -1;
             }
             unsigned char acceptTM(ccsdsTelecommandPacket_t * TMPacket, unsigned int TC_LEN_RCV)
             {
                 unsigned char pid = 0;
                 unsigned char category = 0;
                 unsigned int length = 0;
                 unsigned char packetType = 0;
                 unsigned char packetSubtype = 0;
                 unsigned char * CCSDSContent;
                 // APID check *** APID on 2 bytes
                 pid = ((TMPacket->packetID[0] & 0x07)<<4) + ( (TMPacket->packetID[1]>>4) & 0x0f );   // PID = 11 *** 7 bits xxxxx210 7654xxxx
                 category = (TMPacket->packetID[1] & 0x0f);         // PACKET_CATEGORY = 12 *** 4 bits xxxxxxxx xxxx3210
                 if (pid!=CCSDS_PROCESS_ID) return ILLEGAL_APID;
                 if (category!=CCSDS_PACKET_CATEGORY) return ILLEGAL_APID;
                 // packet length check
                 length = TMPacket->packetLength[0] * 256 + TMPacket->packetLength[1];
                 if (length != TC_LEN_RCV ) return WRONG_LEN_PACKET; // LEN RCV != SIZE FIELD
                 if (length >= CCSDS_TC_PKT_MAX_SIZE) return WRONG_LEN_PACKET; // check that the packet does not exceed the MAX size
                 packetType = TMPacket->dataFieldHeader[1];
                 packetSubtype = TMPacket->dataFieldHeader[2];
                 // service type, subtype and packet length check
                 if (packetType == 181){
                     switch(packetSubtype){ //subtype, autorized values are 3, 20, 21, 24, 27, 28, 30, 40, 50, 60, 61
                         case 3:
                             if (length!=(12-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 20:
                             if (length!=(14-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 21:
                             if (length!=(20-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 24:
                             if (length!=(14-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 27:
                             if (length!=(14-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 28:
                             if (length!=(14-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 30:
                             if (length!=(12-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 40:
                             if (length!=(20-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 50:
                             if (length!=(50-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 60:
                             if (length!=(12-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         case 61:
                             if (length!=(12-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                             break;
                         default:
                             return ILL_SUBTYPE;
                             break;
                         }
                 }
                 else if (packetType == 9){
                     if (packetSubtype!=129) return ILL_SUBTYPE;
                     if (length!=(18-CCSDS_TC_TM_PACKET_OFFSET)) return WRONG_LEN_PACKET;
                 }
                 else return ILL_TYPE;
                 // source ID check // Source ID not documented in the ICD
                 // packet error control, CRC check
                 CCSDSContent = (unsigned char*) TMPacket->packetID;
                 GetCRCAsTwoBytes(CCSDSContent, currentTC_COMPUTED_CRC, length + CCSDS_TC_TM_PACKET_OFFSET - 2); // 2 CRC bytes removed from the calculation of the CRC
                 if (currentTC_COMPUTED_CRC[0] != CCSDSContent[length + CCSDS_TC_TM_PACKET_OFFSET -2]) return INCOR_CHECKSUM;
                 if (currentTC_COMPUTED_CRC[1] != CCSDSContent[length + CCSDS_TC_TM_PACKET_OFFSET -1]) return INCOR_CHECKSUM;
                 return CCSDS_TM_VALID;
             }
             unsigned char TM_build_header( enum TM_TYPE tm_type, unsigned int packetLength,
                                           unsigned int coarseTime, unsigned int fineTime, TMHeader_t *TMHeader)
             {
                 TMHeader->targetLogicalAddress = CCSDS_DESTINATION_ID;
                 TMHeader->protocolIdentifier = 0x02;
                 TMHeader->reserved = 0x00;
                 TMHeader->userApplication = 0x00;
                 TMHeader->packetID[0] = 0x0c;
                 TMHeader->packetSequenceControl[0] = 0xc0;
                 TMHeader->packetSequenceControl[1] = 0x00;
                 TMHeader->packetLength[0] = (unsigned char) (packetLength>>8);
                 TMHeader->packetLength[1] = (unsigned char) packetLength;
                 TMHeader->dataFieldHeader[0] = 0x10;
                 TMHeader->dataFieldHeader[3] = CCSDS_DESTINATION_ID;
                 switch (tm_type){
                     case(TM_LFR_TC_EXE_OK):
                         TMHeader->packetID[1] = 0xc1;
                         TMHeader->dataFieldHeader[1] = 1; // type
                         TMHeader->dataFieldHeader[2] = 7; // subtype
                         break;
                     case(TM_LFR_TC_EXE_ERR):
                         TMHeader->packetID[1] = 0xc1;
                         TMHeader->dataFieldHeader[1] = 1; // type
                         TMHeader->dataFieldHeader[2] = 8; // subtype
                         break;
                     case(TM_LFR_HK):
                         TMHeader->packetID[1] = 0xc4;
                         TMHeader->dataFieldHeader[1] = 3;  // type
                         TMHeader->dataFieldHeader[2] = 25; // subtype
                         break;
                     case(TM_LFR_SCI):
                         TMHeader->packetID[1] = 0xcc;
                         TMHeader->dataFieldHeader[1] = 21;  // type
                         TMHeader->dataFieldHeader[2] = 3; // subtype
                         break;
                     case(TM_LFR_SCI_SBM):
                         TMHeader->packetID[1] = 0xfc;
                         TMHeader->dataFieldHeader[1] = 21;  // type
                         TMHeader->dataFieldHeader[2] = 3; // subtype
                         break;
                     case(TM_LFR_PAR_DUMP):
                         TMHeader->packetID[1] = 0xc9;
                         TMHeader->dataFieldHeader[1] = 181;  // type
                         TMHeader->dataFieldHeader[2] = 31; // subtype
                         break;
                     default:
                         return 0;
                 }
                 TMHeader->dataFieldHeader[4] = (unsigned char) (time_management_regs->coarse_time>>24);
                 TMHeader->dataFieldHeader[5] = (unsigned char) (time_management_regs->coarse_time>>16);
                 TMHeader->dataFieldHeader[6] = (unsigned char) (time_management_regs->coarse_time>>8);
                 TMHeader->dataFieldHeader[7] = (unsigned char) (time_management_regs->coarse_time);
                 TMHeader->dataFieldHeader[8] = (unsigned char) (time_management_regs->fine_time>>8);
                 TMHeader->dataFieldHeader[9] = (unsigned char) (time_management_regs->fine_time);
                 return 1;
             }
             unsigned char TM_build_data(ccsdsTelecommandPacket_t *TC, char* data, unsigned int SID, unsigned char *computed_CRC)
             {
                 unsigned int packetLength;
                 packetLength = TC->packetLength[0] * 256 + TC->packetLength[1];
                 switch (SID){
                     case (SID_NOT_EXE):
                         break;
                     case (SID_NOT_IMP):
                         data[0] = 0x9c;
                         data[1] = 0x42;
                         data[2] = TC->packetID[0];
                         data[3] = TC->packetID[1];
                         data[4] = TC->packetSequenceControl[0];
                         data[5] = TC->packetSequenceControl[1];
                         data[6] = TC->dataFieldHeader[1]; // type
                         data[7] = TC->dataFieldHeader[2]; // subtype
                         break;
                     case (SID_EXE_ERR):
                         break;
                     case (SID_EXE_CORR):
                         data[0] = 0x9c;
                         data[1] = 0x45;
                         data[2] = TC->packetID[0];
                         data[3] = TC->packetID[1];
                         data[4] = TC->packetSequenceControl[0];
                         data[5] = TC->packetSequenceControl[1];
                         data[6] = TC->dataFieldHeader[1]; // type
                         data[7] = TC->dataFieldHeader[2]; // subtype
                         data[8] = currentTC_LEN_RCV[0];
                         data[9] = currentTC_LEN_RCV[1];
                         data[10] = TC->packetLength[0];
                         data[11] = TC->packetLength[1];
                         data[12] = TC->dataAndCRC[packetLength];
                         data[13] = TC->dataAndCRC[packetLength+1];
                         data[14] = computed_CRC[0];
                         data[15] = computed_CRC[1];
                         break;
                     default:
                         return 0;
                 }
                 return 1;
             }
             //***********
             // RTEMS TASK
             rtems_task recv_task( rtems_task_argument unused )
             {
                 int len = 0;
                 unsigned int i = 0;
                 unsigned int data_length = 0;
                 ccsdsTelecommandPacket_t currentTC;
                 char data[100];
                 for(i=0; i<100; i++) data[i] = 0;
                 PRINTF("In RECV *** \n")
                 while(1)
                 {
                     len = read(fdSPW, (char*) &currentTC, CCSDS_TC_PKT_MAX_SIZE); // the call to read is blocking
                     if (len == -1){ // error during the read call
                         PRINTF("In RECV *** last read call returned -1\n")
                         if (rtems_event_send( Task_id[3], SPW_LINKERR_EVENT ) != RTEMS_SUCCESSFUL)
                             PRINTF("IN RECV *** Error: rtems_event_send SPW_LINKERR_EVENT\n")
                         if (rtems_task_suspend(RTEMS_SELF) != RTEMS_SUCCESSFUL)
                             PRINTF("In RECV *** Error: rtems_task_suspend(RTEMS_SELF)\n")
                     }
                     else {
                         PRINTF1("Got pck of length %d\n", len+1)
                         currentTC_LEN_RCV[0] = 0x00;
                         currentTC_LEN_RCV[1] = (unsigned char) len - CCSDS_TC_TM_PACKET_OFFSET - 3; //  build the corresponding packet size field
                         currentTC_LEN_RCV_AsUnsignedInt = (unsigned int) len - CCSDS_TC_TM_PACKET_OFFSET - 3; // => -3 is for Prot ID, Reserved and User App bytes
                         // CHECK THE TC AND BUILD THE APPROPRIATE TM
                         data_length = TC_checker(&currentTC, currentTC_LEN_RCV_AsUnsignedInt);
                         if (data_length!=-1)
                         {
                         }
                     }
                 }
             }
             rtems_task actn_task( rtems_task_argument unused )
             {
                 int result = 0;
                 rtems_status_code status;           // RTEMS status code
                 ccsdsTelecommandPacket_t TC;        // TC sent to the ACTN task
                 size_t size;                        // size of the incoming TC packet
                 unsigned char subtype = 0;          // subtype of the current TC packet
                 PRINTF("In ACTN *** \n")
                 while(1)
                 {
                     status = rtems_message_queue_receive(misc_id[0], (char*) &TC, &size,
                                                          RTEMS_WAIT, RTEMS_NO_TIMEOUT);
                     if (status!=RTEMS_SUCCESSFUL) PRINTF1("in task ACTN *** error receiving a message, code %d \n", status)
                     else
                     {
                         subtype = TC.dataFieldHeader[2];
                         switch(subtype)
                         {
                             case TC_SUBTYPE_RESET:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_LOAD_COMM:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_LOAD_NORM:
                                 result = action_load_norm( &TC );
                                 send_tm_lfr_tc_exe_success( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_LOAD_BURST:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_LOAD_SBM1:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_LOAD_SBM2:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_DUMP:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_ENTER:
                                 result = action_enter( &TC );
                                 send_tm_lfr_tc_exe_success( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_UPDT_INFO:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_EN_CAL:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_DIS_CAL:
                                 result = action_default( &TC );
                                 break;
                                 //
                             case TC_SUBTYPE_UPDT_TIME:
                                 result = action_updt_time( &TC );
                                 send_tm_lfr_tc_exe_success( &TC );
                                 break;
                                 //
                             default:
                                 break;
                         }
                     }
                 }
             }
             int create_message_queue()
             {
                 rtems_status_code status;
                 misc_name[0] = rtems_build_name( 'Q', 'U', 'E', 'U' );
                 status = rtems_message_queue_create( misc_name[0], ACTION_MSG_QUEUE_COUNT, CCSDS_TC_PKT_MAX_SIZE,
                                                              RTEMS_FIFO | RTEMS_LOCAL, &misc_id[0] );
                 if (status!=RTEMS_SUCCESSFUL) PRINTF("in create_message_queue *** error creating message queue\n")
                 return 0;
             }
             //***********
             // TC ACTIONS
             int action_default(ccsdsTelecommandPacket_t *TC)
             {
-                char data[100];                     // buffer for the generic TM packet
+                TMHeader_t TM_header;
-                TMHeader_t TM_header;               // TM header
+                char data[8];
-                spw_ioctl_pkt_send spw_ioctl_send;  // structure to send the TM packet if any
+                spw_ioctl_pkt_send spw_ioctl_send;
-                // BUILD HEADER
-                TM_build_header( TM_LFR_TC_EXE_ERR, TM_LEN_NOT_IMP, 0, 0, &TM_header);
+                TM_build_header( TM_LFR_TC_EXE_ERR, TM_LEN_NOT_IMP,
-                // BUILD DATA
+                                    time_management_regs->coarse_time, time_management_regs->fine_time, &TM_header);
-                TM_build_data( TC, data, SID_NOT_IMP, NULL);
-                // filling the strture for the spcawire transmission
+                data[0] = 0x9c;
+                data[1] = 0x42;
+                data[2] = TC->packetID[0];
+                data[3] = TC->packetID[1];
+                data[4] = TC->packetSequenceControl[0];
+                data[5] = TC->packetSequenceControl[1];
+                data[6] = TC->dataFieldHeader[1]; // type
+                data[7] = TC->dataFieldHeader[2]; // subtype
+                // filling the structure for the spacewire transmission
                 spw_ioctl_send.hlen = TM_HEADER_LEN + 4; // + 4 is for the protocole extra header
                 spw_ioctl_send.hdr = (char*) &TM_header;
                 spw_ioctl_send.dlen = 8;
                 spw_ioctl_send.data = data;
                 // SEND DATA
                 write_spw(&spw_ioctl_send);
                 return 0;
             }
             int action_enter(ccsdsTelecommandPacket_t *TC)
             {
                 unsigned char lfr_mode = TC->dataAndCRC[1];
                 printf("enter mode %d\n", lfr_mode);
                 switch(lfr_mode)
                 {
                     case(LFR_MODE_STANDBY):
                         LEON_Mask_interrupt( IRQ_WF );
                         LEON_Mask_interrupt( IRQ_SM );
                         break;
                     case(LFR_MODE_NORMAL):
                         LEON_Unmask_interrupt( IRQ_WF );
                         LEON_Unmask_interrupt( IRQ_SM );
                         break;
                     case(LFR_MODE_BURST):
                         break;
                     case(LFR_MODE_SBM1):
                         break;
                     case(LFR_MODE_SBM2):
                         break;
                 }
                 return 0;
             }
             int action_load_norm(ccsdsTelecommandPacket_t *TC)
             {
                 param_norm.sy_lfr_n_swf_l = TC->dataAndCRC[0] * 256 + TC->dataAndCRC[1];
                 param_norm.sy_lfr_n_swf_p = TC->dataAndCRC[2] * 256 + TC->dataAndCRC[3];
                 param_norm.sy_lfr_n_asm_p = TC->dataAndCRC[4] * 256 + TC->dataAndCRC[5];
                 param_norm.sy_lfr_n_bp_p0 = TC->dataAndCRC[6];
                 param_norm.sy_lfr_n_bp_p1 = TC->dataAndCRC[7];
                 /*printf("sy_lfr_n_ => swf_l %d, swf_p %d, asm_p %d, bsp_p0 %d, bsp_p1 %d\n",
                        param_norm.sy_lfr_n_swf_l, param_norm.sy_lfr_n_swf_p,
                        param_norm.sy_lfr_n_asm_p, param_norm.sy_lfr_n_bp_p0, param_norm.sy_lfr_n_bp_p1);*/
                 return 0;
             }
             int action_updt_time(ccsdsTelecommandPacket_t *TC)
             {
                 time_management_regs->coarse_time_load = (TC->dataAndCRC[0] << 24)
                                                             + (TC->dataAndCRC[1] << 16)
                                                             + (TC->dataAndCRC[2] << 8)
                                                             + TC->dataAndCRC[3];
                 //time_management_regs->ctrl = time_management_regs->ctrl | 1;
                 return 0;
             }
             int send_tm_lfr_tc_exe_success(ccsdsTelecommandPacket_t *TC)
             {
                 TMHeader_t TM_header;
                 char data[4];
                 spw_ioctl_pkt_send spw_ioctl_send;
                 TM_build_header( TM_LFR_TC_EXE_OK, TM_LEN_EXE,
                                           time_management_regs->coarse_time, time_management_regs->fine_time, &TM_header);
                 data[0] = TC->packetID[0];
                 data[1] = TC->packetID[1];
                 data[2] = TC->packetSequenceControl[0];
                 data[3] = TC->packetSequenceControl[1];
                 // filling the structure for the spacewire transmission
                 spw_ioctl_send.hlen = TM_HEADER_LEN + 3; // + 4 is for the protocole extra header
                 spw_ioctl_send.hdr = (char*) &TM_header;
                 spw_ioctl_send.dlen = 3;
                 spw_ioctl_send.data = data;
                 // SEND DATA
                 write_spw(&spw_ioctl_send);
                 return 0;
             }
             //***************************
             // Interrupt Service Routines
             rtems_isr commutation_isr1( rtems_vector_number vector )
             {
                 if (rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_0 ) != RTEMS_SUCCESSFUL)
-                    printf("In spectral_matrices_isr *** Error sending event to DUMB\n");
+                    printf("In commutation_isr1 *** Error sending event to DUMB\n");
             }
             rtems_isr commutation_isr2( rtems_vector_number vector )
             {
                 if (rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_0 ) != RTEMS_SUCCESSFUL)
-                    printf("In spectral_matrices_isr *** Error sending event to DUMB\n");
+                    printf("In commutation_isr2 *** Error sending event to DUMB\n");
             }
             rtems_task dumb_task( rtems_task_argument unused )
             {
                 unsigned int coarse_time;
                 unsigned int fine_time;
                 rtems_event_set event_out;
                 PRINTF("In DUMB *** \n")
                 while(1){
                     rtems_event_receive(RTEMS_EVENT_0, RTEMS_WAIT, RTEMS_NO_TIMEOUT, &event_out); // wait for an RTEMS_EVENT0
                     coarse_time = time_management_regs->coarse_time;
                     fine_time = time_management_regs->fine_time;
                     printf("commutation_isr*, coarse time = %x, fine time = %x\n", coarse_time, fine_time);
                 }
             }

src/wf_handler.c +1 -1

             #include <wf_handler.h>
             rtems_isr waveforms_isr( rtems_vector_number vector )
             {
                 if (rtems_event_send( Task_id[TASKID_WFRM], RTEMS_EVENT_0 ) != RTEMS_SUCCESSFUL)
-                    printf("In spectral_matrices_isr *** Error sending event to WFRM\n");
+                    printf("In waveforms_isr *** Error sending event to WFRM\n");
             }
             rtems_task wfrm_task(rtems_task_argument argument)
             {
                 unsigned int length;
                 unsigned int i = 0;
                 spw_ioctl_pkt_send spw_ioctl_send;
                 rtems_event_set event_out;
                 gptimer_regs_t *gptimer_regs;
                 gptimer_regs = (gptimer_regs_t *) REGS_ADDR_GPTIMER;
                 ExtendedTMHeader_t header;
                 header.targetLogicalAddress = CCSDS_DESTINATION_ID;
                 header.protocolIdentifier = CCSDS_PROTOCOLE_ID;
                 header.reserved = 0x00;
                 header.userApplication = CCSDS_USER_APP;
                 header.packetID[0] = 0x0c;
                 header.packetID[1] = 0xcc;
                 header.packetSequenceControl[0] = 0x00;
                 header.packetSequenceControl[1] = 0x00;
                 header.packetLength[0] = 0x00;
                 header.packetLength[1] = 0x00;
                 header.dataFieldHeader[0] = 0x10;
                 header.dataFieldHeader[1] = 0x15; // service type
                 header.dataFieldHeader[2] = 0x03; // service subtype
                 header.dataFieldHeader[3] = CCSDS_DESTINATION_ID;
                 header.auxiliaryHeader[0] = 0x00;
                 header.auxiliaryHeader[1] = 0x1f;
                 header.auxiliaryHeader[2] = 0x07; // PKT_CNT
                 header.auxiliaryHeader[3] = 0x00; // PKT_NR
                 header.auxiliaryHeader[4] = 0x00; // BLK_NR MSB
                 header.auxiliaryHeader[5] = 0x00; // BLK_NR LSB
                 // BUILD THE PACKET HEADER
                 spw_ioctl_send.hlen = TM_HEADER_LEN + 4 + 6; // + 4 is for the protocole extra header, + 6 is for the auxiliary header
                 spw_ioctl_send.hdr = (char*) &header;
                 PRINTF("In WFRM *** \n")
                 while(1){
                     rtems_event_receive(RTEMS_EVENT_0, RTEMS_WAIT, RTEMS_NO_TIMEOUT, &event_out); // wait for an RTEMS_EVENT0
                     header.dataFieldHeader[4] = (unsigned char) (time_management_regs->coarse_time>>24);
                     header.dataFieldHeader[5] = (unsigned char) (time_management_regs->coarse_time>>16);
                     header.dataFieldHeader[6] = (unsigned char) (time_management_regs->coarse_time>>8);
                     header.dataFieldHeader[7] = (unsigned char) (time_management_regs->coarse_time);
                     header.dataFieldHeader[8] = (unsigned char) (time_management_regs->fine_time>>8);
                     header.dataFieldHeader[9] = (unsigned char) (time_management_regs->fine_time);
                     for (i=0; i<7; i++) // send F0
                     {
                         // BUILD THE DATA
                         if (i==6) {
                             spw_ioctl_send.dlen = 8 * NB_BYTES_SWF_BLK;
                             length = TM_LEN_SCI_NORM_SWF_340;
                             }
                         else {
                             spw_ioctl_send.dlen = 340 * NB_BYTES_SWF_BLK;
                             length = TM_LEN_SCI_NORM_SWF_8;
                         }
                         spw_ioctl_send.data = (char*) &wf_snap_f0[i * 340 * NB_BYTES_SWF_BLK];
                         // BUILD THE HEADER
                         header.packetLength[0] = (unsigned char) (length>>8);
                         header.packetLength[1] = (unsigned char) (length);
                         header.auxiliaryHeader[0] = SID_NORM_SWF_F0; // SID
                         // SEND PACKET
                         write_spw(&spw_ioctl_send);
                     }
                     for (i=0; i<7; i++) // send F1
                     {
                         // BUILD THE DATA
                         if (i==6) {
                             spw_ioctl_send.dlen = 8 * NB_BYTES_SWF_BLK;
                             length = TM_LEN_SCI_NORM_SWF_340;
                             }
                         else {
                             spw_ioctl_send.dlen = 340 * NB_BYTES_SWF_BLK;
                             length = TM_LEN_SCI_NORM_SWF_8;
                         }
                         spw_ioctl_send.data = (char*) &wf_snap_f1[i * 340 * NB_BYTES_SWF_BLK];
                         // BUILD THE HEADER
                         header.packetLength[0] = (unsigned char) (length>>8);
                         header.packetLength[1] = (unsigned char) (length);
                         header.auxiliaryHeader[0] = SID_NORM_SWF_F1; // SID
                         // SEND PACKET
                         write_spw(&spw_ioctl_send);
                     }
                     for (i=0; i<7; i++) // send F0
                     {
                         // BUILD THE DATA
                         if (i==6) {
                             spw_ioctl_send.dlen = 8 * NB_BYTES_SWF_BLK;
                             length = TM_LEN_SCI_NORM_SWF_340;
                             }
                         else {
                             spw_ioctl_send.dlen = 340 * NB_BYTES_SWF_BLK;
                             length = TM_LEN_SCI_NORM_SWF_8;
                         }
                         spw_ioctl_send.data = (char*) &wf_snap_f2[i * 340 * NB_BYTES_SWF_BLK];
                         // BUILD THE HEADER
                         header.packetLength[0] = (unsigned char) (length>>8);
                         header.packetLength[1] = (unsigned char) (length);
                         header.auxiliaryHeader[0] = SID_NORM_SWF_F2; // SID
                         // SEND PACKET
                         write_spw(&spw_ioctl_send);
                     }
                     // irq processed, reset the related register of the timer unit
                     gptimer_regs->timer[2].ctrl = gptimer_regs->timer[2].ctrl | 0x00000010;
                 }
             }

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