HG_REPOSITORIES/LPP/INSTRUMENTATION/SOLO_LFR/DEV_PLE Commit - r362:0f33a04cb747

3.2.0.12...

paul -

r362:0f33a04cb747 R3++

parent child

Context file:

r362:0f33a04cb747

Collapse all files

src/CMakeLists.txt +1 -1

             cmake_minimum_required (VERSION 2.6)
             project (fsw)
             include(sparc-rtems)
             include(cppcheck)
             include_directories("../header"
             	 "../header/lfr_common_headers"
             	 "../header/processing"
                      "../LFR_basic-parameters"
                      "../src")
             set(SOURCES    wf_handler.c
                  tc_handler.c
                  fsw_misc.c
                  fsw_init.c
                  fsw_globals.c
                  fsw_spacewire.c
                  tc_load_dump_parameters.c
                  tm_lfr_tc_exe.c
                  tc_acceptance.c
                  processing/fsw_processing.c
                  processing/avf0_prc0.c
                  processing/avf1_prc1.c
                  processing/avf2_prc2.c
                  lfr_cpu_usage_report.c
                  ${LFR_BP_SRC}
                  ../header/wf_handler.h
                  ../header/tc_handler.h
                  ../header/grlib_regs.h
                  ../header/fsw_misc.h
                  ../header/fsw_init.h
                  ../header/fsw_spacewire.h
                  ../header/tc_load_dump_parameters.h
                  ../header/tm_lfr_tc_exe.h
                  ../header/tc_acceptance.h
                  ../header/processing/fsw_processing.h
                  ../header/processing/avf0_prc0.h
                  ../header/processing/avf1_prc1.h
                  ../header/processing/avf2_prc2.h
                  ../header/fsw_params_wf_handler.h
                  ../header/lfr_cpu_usage_report.h
                  ../header/lfr_common_headers/ccsds_types.h
                  ../header/lfr_common_headers/fsw_params.h
                  ../header/lfr_common_headers/fsw_params_nb_bytes.h
                  ../header/lfr_common_headers/fsw_params_processing.h
                  ../header/lfr_common_headers/tm_byte_positions.h
                  ../LFR_basic-parameters/basic_parameters.h
                  ../LFR_basic-parameters/basic_parameters_params.h
                  ../header/GscMemoryLPP.hpp
             )
             option(FSW_verbose "Enable verbose LFR" OFF)
             option(FSW_boot_messages "Enable LFR boot messages" OFF)
             option(FSW_debug_messages "Enable LFR debug messages" OFF)
             option(FSW_cpu_usage_report "Enable LFR cpu usage report" OFF)
             option(FSW_stack_report "Enable LFR stack report" OFF)
             option(FSW_vhdl_dev "?" OFF)
             option(FSW_lpp_dpu_destid "Set to debug at LPP" ON)
             option(FSW_debug_watchdog "Enable debug watchdog" OFF)
             option(FSW_debug_tch "?" OFF)
             set(SW_VERSION_N1 "3" CACHE STRING  "Choose N1 FSW Version." FORCE)
             set(SW_VERSION_N2 "2" CACHE STRING  "Choose N2 FSW Version." FORCE)
             set(SW_VERSION_N3 "0" CACHE STRING  "Choose N3 FSW Version." FORCE)
-            set(SW_VERSION_N4 "11" CACHE STRING  "Choose N4 FSW Version." FORCE)
+            set(SW_VERSION_N4 "12" CACHE STRING  "Choose N4 FSW Version." FORCE)
             if(FSW_verbose)
             	add_definitions(-DPRINT_MESSAGES_ON_CONSOLE)
             endif()
             if(FSW_boot_messages)
             	add_definitions(-DBOOT_MESSAGES)
             endif()
             if(FSW_debug_messages)
             	add_definitions(-DDEBUG_MESSAGES)
             endif()
             if(FSW_cpu_usage_report)
             	add_definitions(-DPRINT_TASK_STATISTICS)
             endif()
             if(FSW_stack_report)
             	add_definitions(-DPRINT_STACK_REPORT)
             endif()
             if(FSW_vhdl_dev)
             	add_definitions(-DVHDL_DEV)
             endif()
             if(FSW_lpp_dpu_destid)
             	add_definitions(-DLPP_DPU_DESTID)
             endif()
             if(FSW_debug_watchdog)
             	add_definitions(-DDEBUG_WATCHDOG)
             endif()
             if(FSW_debug_tch)
             	add_definitions(-DDEBUG_TCH)
             endif()
             add_definitions(-DMSB_FIRST_TCH)
             add_definitions(-DSWVERSION=-1-0)
             add_definitions(-DSW_VERSION_N1=${SW_VERSION_N1})
             add_definitions(-DSW_VERSION_N2=${SW_VERSION_N2})
             add_definitions(-DSW_VERSION_N3=${SW_VERSION_N3})
             add_definitions(-DSW_VERSION_N4=${SW_VERSION_N4})
             add_executable(fsw ${SOURCES})
             add_test_cppcheck(fsw STYLE UNUSED_FUNCTIONS POSSIBLE_ERROR MISSING_INCLUDE)

src/fsw_misc.c +3 -3

             /** General usage functions and RTEMS tasks.
              *
              * @file
              * @author P. LEROY
              *
              */
             #include "fsw_misc.h"
             int16_t hk_lfr_sc_v_f3_as_int16 = 0;
             int16_t hk_lfr_sc_e1_f3_as_int16 = 0;
             int16_t hk_lfr_sc_e2_f3_as_int16 = 0;
             void timer_configure(unsigned char timer, unsigned int clock_divider,
                                 unsigned char interrupt_level, rtems_isr (*timer_isr)() )
             {
                 /** This function configures a GPTIMER timer instantiated in the VHDL design.
                  *
                  * @param gptimer_regs points to the APB registers of the GPTIMER IP core.
                  * @param timer is the number of the timer in the IP core (several timers can be instantiated).
                  * @param clock_divider is the divider of the 1 MHz clock that will be configured.
                  * @param interrupt_level is the interrupt level that the timer drives.
                  * @param timer_isr is the interrupt subroutine that will be attached to the IRQ driven by the timer.
                  *
                  * Interrupt levels are described in the SPARC documentation sparcv8.pdf p.76
                  *
                  */
                 rtems_status_code status;
                 rtems_isr_entry old_isr_handler;
                 old_isr_handler = NULL;
                 gptimer_regs->timer[timer].ctrl = INIT_CHAR;  // reset the control register
                 status = rtems_interrupt_catch( timer_isr, interrupt_level, &old_isr_handler) ; // see sparcv8.pdf p.76 for interrupt levels
                 if (status!=RTEMS_SUCCESSFUL)
                 {
                     PRINTF("in configure_timer *** ERR rtems_interrupt_catch\n")
                 }
                 timer_set_clock_divider( timer, clock_divider);
             }
             void timer_start(unsigned char timer)
             {
                 /** This function starts a GPTIMER timer.
                  *
                  * @param gptimer_regs points to the APB registers of the GPTIMER IP core.
                  * @param timer is the number of the timer in the IP core (several timers can be instantiated).
                  *
                  */
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl | GPTIMER_CLEAR_IRQ;
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl | GPTIMER_LD;
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl | GPTIMER_EN;
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl | GPTIMER_RS;
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl | GPTIMER_IE;
             }
             void timer_stop(unsigned char timer)
             {
                 /** This function stops a GPTIMER timer.
                  *
                  * @param gptimer_regs points to the APB registers of the GPTIMER IP core.
                  * @param timer is the number of the timer in the IP core (several timers can be instantiated).
                  *
                  */
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl & GPTIMER_EN_MASK;
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl & GPTIMER_IE_MASK;
                 gptimer_regs->timer[timer].ctrl = gptimer_regs->timer[timer].ctrl | GPTIMER_CLEAR_IRQ;
             }
             void timer_set_clock_divider(unsigned char timer, unsigned int clock_divider)
             {
                 /** This function sets the clock divider of a GPTIMER timer.
                  *
                  * @param gptimer_regs points to the APB registers of the GPTIMER IP core.
                  * @param timer is the number of the timer in the IP core (several timers can be instantiated).
                  * @param clock_divider is the divider of the 1 MHz clock that will be configured.
                  *
                  */
                 gptimer_regs->timer[timer].reload = clock_divider; // base clock frequency is 1 MHz
             }
             // WATCHDOG
             rtems_isr watchdog_isr( rtems_vector_number vector )
             {
                 rtems_status_code status_code;
                 status_code = rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_12 );
                 PRINTF("watchdog_isr *** this is the end, exit(0)\n");
                 exit(0);
             }
             void watchdog_configure(void)
             {
                 /** This function configure the watchdog.
                  *
                  * @param gptimer_regs points to the APB registers of the GPTIMER IP core.
                  * @param timer is the number of the timer in the IP core (several timers can be instantiated).
                  *
                  * The watchdog is a timer provided by the GPTIMER IP core of the GRLIB.
                  *
                  */
                 LEON_Mask_interrupt( IRQ_GPTIMER_WATCHDOG );    // mask gptimer/watchdog interrupt during configuration
                 timer_configure( TIMER_WATCHDOG, CLKDIV_WATCHDOG, IRQ_SPARC_GPTIMER_WATCHDOG, watchdog_isr );
                 LEON_Clear_interrupt( IRQ_GPTIMER_WATCHDOG );   // clear gptimer/watchdog interrupt
             }
             void watchdog_stop(void)
             {
                 LEON_Mask_interrupt( IRQ_GPTIMER_WATCHDOG );                  // mask gptimer/watchdog interrupt line
                 timer_stop( TIMER_WATCHDOG );
                 LEON_Clear_interrupt( IRQ_GPTIMER_WATCHDOG );                 // clear gptimer/watchdog interrupt
             }
             void watchdog_reload(void)
             {
                 /** This function reloads the watchdog timer counter with the timer reload value.
                  *
                  * @param void
                  *
                  * @return void
                  *
                  */
                 gptimer_regs->timer[TIMER_WATCHDOG].ctrl = gptimer_regs->timer[TIMER_WATCHDOG].ctrl | GPTIMER_LD;
             }
             void watchdog_start(void)
             {
                 /** This function starts the watchdog timer.
                  *
                  * @param gptimer_regs points to the APB registers of the GPTIMER IP core.
                  * @param timer is the number of the timer in the IP core (several timers can be instantiated).
                  *
                  */
                 LEON_Clear_interrupt( IRQ_GPTIMER_WATCHDOG );
                 gptimer_regs->timer[TIMER_WATCHDOG].ctrl = gptimer_regs->timer[TIMER_WATCHDOG].ctrl | GPTIMER_CLEAR_IRQ;
                 gptimer_regs->timer[TIMER_WATCHDOG].ctrl = gptimer_regs->timer[TIMER_WATCHDOG].ctrl | GPTIMER_LD;
                 gptimer_regs->timer[TIMER_WATCHDOG].ctrl = gptimer_regs->timer[TIMER_WATCHDOG].ctrl | GPTIMER_EN;
                 gptimer_regs->timer[TIMER_WATCHDOG].ctrl = gptimer_regs->timer[TIMER_WATCHDOG].ctrl | GPTIMER_IE;
                 LEON_Unmask_interrupt( IRQ_GPTIMER_WATCHDOG );
             }
             int enable_apbuart_transmitter( void )  // set the bit 1, TE Transmitter Enable to 1 in the APBUART control register
             {
                 struct apbuart_regs_str *apbuart_regs = (struct apbuart_regs_str *) REGS_ADDR_APBUART;
                 apbuart_regs->ctrl = APBUART_CTRL_REG_MASK_TE;
                 return 0;
             }
             void set_apbuart_scaler_reload_register(unsigned int regs, unsigned int value)
             {
                 /** This function sets the scaler reload register of the apbuart module
                  *
                  * @param regs is the address of the apbuart registers in memory
                  * @param value is the value that will be stored in the scaler register
                  *
                  * The value shall be set by the software to get data on the serial interface.
                  *
                  */
                 struct apbuart_regs_str *apbuart_regs = (struct apbuart_regs_str *) regs;
                 apbuart_regs->scaler = value;
                 BOOT_PRINTF1("OK  *** apbuart port scaler reload register set to 0x%x\n", value)
             }
             //************
             // RTEMS TASKS
             rtems_task load_task(rtems_task_argument argument)
             {
                 BOOT_PRINTF("in LOAD *** \n")
                 rtems_status_code status;
                 unsigned int i;
                 unsigned int j;
                 rtems_name name_watchdog_rate_monotonic;  // name of the watchdog rate monotonic
                 rtems_id watchdog_period_id;              // id of the watchdog rate monotonic period
                 watchdog_period_id = RTEMS_ID_NONE;
                 name_watchdog_rate_monotonic = rtems_build_name( 'L', 'O', 'A', 'D' );
                 status = rtems_rate_monotonic_create( name_watchdog_rate_monotonic, &watchdog_period_id );
                 if( status != RTEMS_SUCCESSFUL ) {
                     PRINTF1( "in LOAD *** rtems_rate_monotonic_create failed with status of %d\n", status )
                 }
                 i = 0;
                 j = 0;
                 watchdog_configure();
                 watchdog_start();
                 set_sy_lfr_watchdog_enabled( true );
                 while(1){
                     status = rtems_rate_monotonic_period( watchdog_period_id, WATCHDOG_PERIOD );
                     watchdog_reload();
                     i = i + 1;
                     if ( i == WATCHDOG_LOOP_PRINTF )
                     {
                         i = 0;
                         j = j + 1;
                         PRINTF1("%d\n", j)
                     }
             #ifdef DEBUG_WATCHDOG
                     if (j == WATCHDOG_LOOP_DEBUG )
                     {
                         status = rtems_task_delete(RTEMS_SELF);
                     }
             #endif
                 }
             }
             rtems_task hous_task(rtems_task_argument argument)
             {
                 rtems_status_code status;
                 rtems_status_code spare_status;
                 rtems_id queue_id;
                 rtems_rate_monotonic_period_status period_status;
                 bool isSynchronized;
                 queue_id = RTEMS_ID_NONE;
                 memset(&period_status, 0, sizeof(rtems_rate_monotonic_period_status));
                 isSynchronized = false;
                 status =  get_message_queue_id_send( &queue_id );
                 if (status != RTEMS_SUCCESSFUL)
                 {
                     PRINTF1("in HOUS *** ERR get_message_queue_id_send %d\n", status)
                 }
                 BOOT_PRINTF("in HOUS ***\n");
                 if (rtems_rate_monotonic_ident( name_hk_rate_monotonic, &HK_id) != RTEMS_SUCCESSFUL) {
                     status = rtems_rate_monotonic_create( name_hk_rate_monotonic, &HK_id );
                     if( status != RTEMS_SUCCESSFUL ) {
                         PRINTF1( "rtems_rate_monotonic_create failed with status of %d\n", status );
                     }
                 }
                 status = rtems_rate_monotonic_cancel(HK_id);
                 if( status != RTEMS_SUCCESSFUL ) {
                     PRINTF1( "ERR *** in HOUS *** rtems_rate_monotonic_cancel(HK_id) ***code: %d\n", status );
                 }
                 else {
                     DEBUG_PRINTF("OK  *** in HOUS *** rtems_rate_monotonic_cancel(HK_id)\n");
                 }
                 // startup phase
                 status = rtems_rate_monotonic_period( HK_id, SY_LFR_TIME_SYN_TIMEOUT_in_ticks );
                 status = rtems_rate_monotonic_get_status( HK_id, &period_status );
                 DEBUG_PRINTF1("startup HK, HK_id status = %d\n", period_status.state)
                 while( (period_status.state != RATE_MONOTONIC_EXPIRED)
                        && (isSynchronized == false) )   // after SY_LFR_TIME_SYN_TIMEOUT ms, starts HK anyway
                 {
                     if ((time_management_regs->coarse_time & VAL_LFR_SYNCHRONIZED) == INT32_ALL_0) // check time synchronization
                     {
                         isSynchronized = true;
                     }
                     else
                     {
                         status = rtems_rate_monotonic_get_status( HK_id, &period_status );
                         status = rtems_task_wake_after( HK_SYNC_WAIT );        // wait HK_SYNCH_WAIT 100 ms = 10 * 10 ms
                     }
                 }
                 status = rtems_rate_monotonic_cancel(HK_id);
                 DEBUG_PRINTF1("startup HK, HK_id status = %d\n", period_status.state)
                 set_hk_lfr_reset_cause( POWER_ON );
                 while(1){ // launch the rate monotonic task
                     status = rtems_rate_monotonic_period( HK_id, HK_PERIOD );
                     if ( status != RTEMS_SUCCESSFUL ) {
                         PRINTF1( "in HOUS *** ERR period: %d\n", status);
                         spare_status = rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_6 );
                     }
                     else {
                         housekeeping_packet.packetSequenceControl[BYTE_0] = (unsigned char) (sequenceCounterHK >> SHIFT_1_BYTE);
                         housekeeping_packet.packetSequenceControl[BYTE_1] = (unsigned char) (sequenceCounterHK     );
                         increment_seq_counter( &sequenceCounterHK );
                         housekeeping_packet.time[BYTE_0] = (unsigned char) (time_management_regs->coarse_time >> SHIFT_3_BYTES);
                         housekeeping_packet.time[BYTE_1] = (unsigned char) (time_management_regs->coarse_time >> SHIFT_2_BYTES);
                         housekeeping_packet.time[BYTE_2] = (unsigned char) (time_management_regs->coarse_time >> SHIFT_1_BYTE);
                         housekeeping_packet.time[BYTE_3] = (unsigned char) (time_management_regs->coarse_time);
                         housekeeping_packet.time[BYTE_4] = (unsigned char) (time_management_regs->fine_time >> SHIFT_1_BYTE);
                         housekeeping_packet.time[BYTE_5] = (unsigned char) (time_management_regs->fine_time);
                         spacewire_update_hk_lfr_link_state( &housekeeping_packet.lfr_status_word[0] );
                         spacewire_read_statistics();
                         update_hk_with_grspw_stats();
                         set_hk_lfr_time_not_synchro();
                         housekeeping_packet.hk_lfr_q_sd_fifo_size_max = hk_lfr_q_sd_fifo_size_max;
                         housekeeping_packet.hk_lfr_q_rv_fifo_size_max = hk_lfr_q_rv_fifo_size_max;
                         housekeeping_packet.hk_lfr_q_p0_fifo_size_max = hk_lfr_q_p0_fifo_size_max;
                         housekeeping_packet.hk_lfr_q_p1_fifo_size_max = hk_lfr_q_p1_fifo_size_max;
                         housekeeping_packet.hk_lfr_q_p2_fifo_size_max = hk_lfr_q_p2_fifo_size_max;
                         housekeeping_packet.sy_lfr_common_parameters_spare  = parameter_dump_packet.sy_lfr_common_parameters_spare;
                         housekeeping_packet.sy_lfr_common_parameters        = parameter_dump_packet.sy_lfr_common_parameters;
                         get_temperatures( housekeeping_packet.hk_lfr_temp_scm );
                         get_v_e1_e2_f3(   housekeeping_packet.hk_lfr_sc_v_f3  );
                         get_cpu_load( (unsigned char *) &housekeeping_packet.hk_lfr_cpu_load );
                         hk_lfr_le_me_he_update();
                         // SEND PACKET
                         status =  rtems_message_queue_send( queue_id, &housekeeping_packet,
                                                             PACKET_LENGTH_HK + CCSDS_TC_TM_PACKET_OFFSET + CCSDS_PROTOCOLE_EXTRA_BYTES);
                         if (status != RTEMS_SUCCESSFUL) {
                             PRINTF1("in HOUS *** ERR send: %d\n", status)
                         }
                     }
                 }
                 PRINTF("in HOUS *** deleting task\n")
                 status = rtems_task_delete( RTEMS_SELF ); // should not return
                 return;
             }
             int filter( int x, filter_ctx* ctx )
             {
                 static const int b[NB_COEFFS][NB_COEFFS]={ {B00, B01, B02}, {B10, B11, B12}, {B20, B21, B22} };
                 static const int a[NB_COEFFS][NB_COEFFS]={ {A00, A01, A02}, {A10, A11, A12}, {A20, A21, A22} };
                 static const int b_gain[NB_COEFFS]={GAIN_B0, GAIN_B1, GAIN_B2};
                 static const int a_gain[NB_COEFFS]={GAIN_A0, GAIN_A1, GAIN_A2};
                 int_fast32_t W;
                 int i;
                 W = INIT_INT;
                 i = INIT_INT;
                 //Direct-Form-II
                 for ( i = 0; i < NB_COEFFS; i++ )
                 {
                     x = x << a_gain[i];
                     W = (x - ( a[i][COEFF1] * ctx->W[i][COEFF0] )
                            - ( a[i][COEFF2] * ctx->W[i][COEFF1] ) ) >> a_gain[i];
                     x = ( b[i][COEFF0] * W )
                             + ( b[i][COEFF1] * ctx->W[i][COEFF0] )
                             + ( b[i][COEFF2] * ctx->W[i][COEFF1] );
                     x = x >> b_gain[i];
                     ctx->W[i][1] = ctx->W[i][0];
                     ctx->W[i][0] = W;
                 }
                 return x;
             }
             rtems_task avgv_task(rtems_task_argument argument)
             {
             #define MOVING_AVERAGE 16
                 rtems_status_code status;
                 static int32_t v[MOVING_AVERAGE] = {0};
                 static int32_t e1[MOVING_AVERAGE] = {0};
                 static int32_t e2[MOVING_AVERAGE] = {0};
                 static int old_v = 0;
                 static int old_e1 = 0;
                 static int old_e2 = 0;
                 int32_t current_v;
                 int32_t current_e1;
                 int32_t current_e2;
                 int32_t average_v;
                 int32_t average_e1;
                 int32_t average_e2;
                 int32_t newValue_v;
                 int32_t newValue_e1;
                 int32_t newValue_e2;
                 unsigned char k;
                 unsigned char indexOfOldValue;
                 static filter_ctx ctx_v = { { {0,0,0}, {0,0,0}, {0,0,0} } };
                 static filter_ctx ctx_e1 = { { {0,0,0}, {0,0,0}, {0,0,0} } };
                 static filter_ctx ctx_e2 = { { {0,0,0}, {0,0,0}, {0,0,0} } };
                 BOOT_PRINTF("in AVGV ***\n");
                 if (rtems_rate_monotonic_ident( name_avgv_rate_monotonic, &AVGV_id) != RTEMS_SUCCESSFUL) {
                     status = rtems_rate_monotonic_create( name_avgv_rate_monotonic, &AVGV_id );
                     if( status != RTEMS_SUCCESSFUL ) {
                         PRINTF1( "rtems_rate_monotonic_create failed with status of %d\n", status );
                     }
                 }
                 status = rtems_rate_monotonic_cancel(AVGV_id);
                 if( status != RTEMS_SUCCESSFUL ) {
                     PRINTF1( "ERR *** in AVGV *** rtems_rate_monotonic_cancel(AVGV_id) ***code: %d\n", status );
                 }
                 else {
                     DEBUG_PRINTF("OK  *** in AVGV *** rtems_rate_monotonic_cancel(AVGV_id)\n");
                 }
                 // initialize values
                 indexOfOldValue = MOVING_AVERAGE - 1;
                 current_v = 0;
                 current_e1 = 0;
                 current_e2 = 0;
                 average_v   = 0;
                 average_e1  = 0;
                 average_e2  = 0;
                 newValue_v  = 0;
                 newValue_e1 = 0;
                 newValue_e2 = 0;
                 k = INIT_CHAR;
                 while(1)
                 { // launch the rate monotonic task
                     status = rtems_rate_monotonic_period( AVGV_id, AVGV_PERIOD );
                     if ( status != RTEMS_SUCCESSFUL )
                     {
                         PRINTF1( "in AVGV *** ERR period: %d\n", status);
                     }
                     else
                     {
                         current_v = waveform_picker_regs->v;
                         current_e1 = waveform_picker_regs->e1;
                         current_e2 = waveform_picker_regs->e2;
                         if ( (current_v != old_v)
                              || (current_e1 != old_e1)
                              || (current_e2 != old_e2))
                         {
                             average_v = filter( current_v, &ctx_v );
                             average_e1 = filter( current_e1, &ctx_e1 );
                             average_e2 = filter( current_e2, &ctx_e2 );
                             //update int16 values
-                            hk_lfr_sc_v_f3_as_int16 =  (int16_t) (average_v / MOVING_AVERAGE );
+                            hk_lfr_sc_v_f3_as_int16 =  (int16_t) average_v;
-                            hk_lfr_sc_e1_f3_as_int16 = (int16_t) (average_e1 / MOVING_AVERAGE );
+                            hk_lfr_sc_e1_f3_as_int16 = (int16_t) average_e1;
-                            hk_lfr_sc_e2_f3_as_int16 = (int16_t) (average_e2 / MOVING_AVERAGE );
+                            hk_lfr_sc_e2_f3_as_int16 = (int16_t) average_e2;
                         }
                         old_v = current_v;
                         old_e1 = current_e1;
                         old_e2 = current_e2;
                     }
                 }
                 PRINTF("in AVGV *** deleting task\n");
                 status = rtems_task_delete( RTEMS_SELF ); // should not return
                 return;
             }
             rtems_task dumb_task( rtems_task_argument unused )
             {
                 /** This RTEMS taks is used to print messages without affecting the general behaviour of the software.
                  *
                  * @param unused is the starting argument of the RTEMS task
                  *
                  * The DUMB taks waits for RTEMS events and print messages depending on the incoming events.
                  *
                  */
                 unsigned int i;
                 unsigned int intEventOut;
                 unsigned int coarse_time = 0;
                 unsigned int fine_time = 0;
                 rtems_event_set event_out;
                 event_out = EVENT_SETS_NONE_PENDING;
                 BOOT_PRINTF("in DUMB *** \n")
                 while(1){
                     rtems_event_receive(RTEMS_EVENT_0 | RTEMS_EVENT_1 | RTEMS_EVENT_2 | RTEMS_EVENT_3
                                         | RTEMS_EVENT_4 | RTEMS_EVENT_5 | RTEMS_EVENT_6 | RTEMS_EVENT_7
                                         | RTEMS_EVENT_8 | RTEMS_EVENT_9 | RTEMS_EVENT_12 | RTEMS_EVENT_13
                                         | RTEMS_EVENT_14,
                                         RTEMS_WAIT | RTEMS_EVENT_ANY, RTEMS_NO_TIMEOUT, &event_out); // wait for an RTEMS_EVENT
                     intEventOut =  (unsigned int) event_out;
                     for ( i=0; i<NB_RTEMS_EVENTS; i++)
                     {
                         if ( ((intEventOut >> i) & 1) != 0)
                         {
                             coarse_time = time_management_regs->coarse_time;
                             fine_time = time_management_regs->fine_time;
                             if (i==EVENT_12)
                             {
                                 PRINTF1("%s\n", DUMB_MESSAGE_12)
                             }
                             if (i==EVENT_13)
                             {
                                 PRINTF1("%s\n", DUMB_MESSAGE_13)
                             }
                             if (i==EVENT_14)
                             {
                                 PRINTF1("%s\n", DUMB_MESSAGE_1)
                             }
                         }
                     }
                 }
             }
             //*****************************
             // init housekeeping parameters
             void init_housekeeping_parameters( void )
             {
                 /** This function initialize the housekeeping_packet global variable with default values.
                  *
                  */
                 unsigned int i = 0;
                 unsigned char *parameters;
                 unsigned char sizeOfHK;
                 sizeOfHK = sizeof( Packet_TM_LFR_HK_t );
                 parameters = (unsigned char*) &housekeeping_packet;
                 for(i = 0; i< sizeOfHK; i++)
                 {
                     parameters[i] = INIT_CHAR;
                 }
                 housekeeping_packet.targetLogicalAddress = CCSDS_DESTINATION_ID;
                 housekeeping_packet.protocolIdentifier = CCSDS_PROTOCOLE_ID;
                 housekeeping_packet.reserved = DEFAULT_RESERVED;
                 housekeeping_packet.userApplication = CCSDS_USER_APP;
                 housekeeping_packet.packetID[0] = (unsigned char) (APID_TM_HK >> SHIFT_1_BYTE);
                 housekeeping_packet.packetID[1] = (unsigned char) (APID_TM_HK);
                 housekeeping_packet.packetSequenceControl[0] = TM_PACKET_SEQ_CTRL_STANDALONE;
                 housekeeping_packet.packetSequenceControl[1] = TM_PACKET_SEQ_CNT_DEFAULT;
                 housekeeping_packet.packetLength[0] = (unsigned char) (PACKET_LENGTH_HK >> SHIFT_1_BYTE);
                 housekeeping_packet.packetLength[1] = (unsigned char) (PACKET_LENGTH_HK     );
                 housekeeping_packet.spare1_pusVersion_spare2 = DEFAULT_SPARE1_PUSVERSION_SPARE2;
                 housekeeping_packet.serviceType = TM_TYPE_HK;
                 housekeeping_packet.serviceSubType = TM_SUBTYPE_HK;
                 housekeeping_packet.destinationID = TM_DESTINATION_ID_GROUND;
                 housekeeping_packet.sid = SID_HK;
                 // init status word
                 housekeeping_packet.lfr_status_word[0] = DEFAULT_STATUS_WORD_BYTE0;
                 housekeeping_packet.lfr_status_word[1] = DEFAULT_STATUS_WORD_BYTE1;
                 // init software version
                 housekeeping_packet.lfr_sw_version[0] = SW_VERSION_N1;
                 housekeeping_packet.lfr_sw_version[1] = SW_VERSION_N2;
                 housekeeping_packet.lfr_sw_version[BYTE_2] = SW_VERSION_N3;
                 housekeeping_packet.lfr_sw_version[BYTE_3] = SW_VERSION_N4;
                 // init fpga version
                 parameters = (unsigned char *) (REGS_ADDR_VHDL_VERSION);
                 housekeeping_packet.lfr_fpga_version[BYTE_0] = parameters[BYTE_1]; // n1
                 housekeeping_packet.lfr_fpga_version[BYTE_1] = parameters[BYTE_2]; // n2
                 housekeeping_packet.lfr_fpga_version[BYTE_2] = parameters[BYTE_3]; // n3
                 housekeeping_packet.hk_lfr_q_sd_fifo_size = MSG_QUEUE_COUNT_SEND;
                 housekeeping_packet.hk_lfr_q_rv_fifo_size = MSG_QUEUE_COUNT_RECV;
                 housekeeping_packet.hk_lfr_q_p0_fifo_size = MSG_QUEUE_COUNT_PRC0;
                 housekeeping_packet.hk_lfr_q_p1_fifo_size = MSG_QUEUE_COUNT_PRC1;
                 housekeeping_packet.hk_lfr_q_p2_fifo_size = MSG_QUEUE_COUNT_PRC2;
             }
             void increment_seq_counter( unsigned short *packetSequenceControl )
             {
                 /** This function increment the sequence counter passes in argument.
                  *
                  * The increment does not affect the grouping flag. In case of an overflow, the counter is reset to 0.
                  *
                  */
                 unsigned short segmentation_grouping_flag;
                 unsigned short sequence_cnt;
                 segmentation_grouping_flag  = TM_PACKET_SEQ_CTRL_STANDALONE << SHIFT_1_BYTE;   // keep bits 7 downto 6
                 sequence_cnt                = (*packetSequenceControl) & SEQ_CNT_MASK;    // [0011 1111 1111 1111]
                 if ( sequence_cnt < SEQ_CNT_MAX)
                 {
                     sequence_cnt = sequence_cnt + 1;
                 }
                 else
                 {
                     sequence_cnt = 0;
                 }
                 *packetSequenceControl = segmentation_grouping_flag | sequence_cnt ;
             }
             void getTime( unsigned char *time)
             {
                 /** This function write the current local time in the time buffer passed in argument.
                  *
                  */
                 time[0] = (unsigned char) (time_management_regs->coarse_time>>SHIFT_3_BYTES);
                 time[1] = (unsigned char) (time_management_regs->coarse_time>>SHIFT_2_BYTES);
                 time[2] = (unsigned char) (time_management_regs->coarse_time>>SHIFT_1_BYTE);
                 time[3] = (unsigned char) (time_management_regs->coarse_time);
                 time[4] = (unsigned char) (time_management_regs->fine_time>>SHIFT_1_BYTE);
                 time[5] = (unsigned char) (time_management_regs->fine_time);
             }
             unsigned long long int getTimeAsUnsignedLongLongInt( )
             {
                 /** This function write the current local time in the time buffer passed in argument.
                  *
                  */
                 unsigned long long int time;
                 time = ( (unsigned long long int) (time_management_regs->coarse_time & COARSE_TIME_MASK) << SHIFT_2_BYTES )
                         + time_management_regs->fine_time;
                 return time;
             }
             void send_dumb_hk( void )
             {
                 Packet_TM_LFR_HK_t dummy_hk_packet;
                 unsigned char *parameters;
                 unsigned int i;
                 rtems_id queue_id;
                 queue_id = RTEMS_ID_NONE;
                 dummy_hk_packet.targetLogicalAddress = CCSDS_DESTINATION_ID;
                 dummy_hk_packet.protocolIdentifier = CCSDS_PROTOCOLE_ID;
                 dummy_hk_packet.reserved = DEFAULT_RESERVED;
                 dummy_hk_packet.userApplication = CCSDS_USER_APP;
                 dummy_hk_packet.packetID[0] = (unsigned char) (APID_TM_HK >> SHIFT_1_BYTE);
                 dummy_hk_packet.packetID[1] = (unsigned char) (APID_TM_HK);
                 dummy_hk_packet.packetSequenceControl[0] = TM_PACKET_SEQ_CTRL_STANDALONE;
                 dummy_hk_packet.packetSequenceControl[1] = TM_PACKET_SEQ_CNT_DEFAULT;
                 dummy_hk_packet.packetLength[0] = (unsigned char) (PACKET_LENGTH_HK >> SHIFT_1_BYTE);
                 dummy_hk_packet.packetLength[1] = (unsigned char) (PACKET_LENGTH_HK     );
                 dummy_hk_packet.spare1_pusVersion_spare2 = DEFAULT_SPARE1_PUSVERSION_SPARE2;
                 dummy_hk_packet.serviceType = TM_TYPE_HK;
                 dummy_hk_packet.serviceSubType = TM_SUBTYPE_HK;
                 dummy_hk_packet.destinationID = TM_DESTINATION_ID_GROUND;
                 dummy_hk_packet.time[0] = (unsigned char) (time_management_regs->coarse_time >> SHIFT_3_BYTES);
                 dummy_hk_packet.time[1] = (unsigned char) (time_management_regs->coarse_time >> SHIFT_2_BYTES);
                 dummy_hk_packet.time[BYTE_2] = (unsigned char) (time_management_regs->coarse_time >> SHIFT_1_BYTE);
                 dummy_hk_packet.time[BYTE_3] = (unsigned char) (time_management_regs->coarse_time);
                 dummy_hk_packet.time[BYTE_4] = (unsigned char) (time_management_regs->fine_time >> SHIFT_1_BYTE);
                 dummy_hk_packet.time[BYTE_5] = (unsigned char) (time_management_regs->fine_time);
                 dummy_hk_packet.sid = SID_HK;
                 // init status word
                 dummy_hk_packet.lfr_status_word[0] = INT8_ALL_F;
                 dummy_hk_packet.lfr_status_word[1] = INT8_ALL_F;
                 // init software version
                 dummy_hk_packet.lfr_sw_version[0] = SW_VERSION_N1;
                 dummy_hk_packet.lfr_sw_version[1] = SW_VERSION_N2;
                 dummy_hk_packet.lfr_sw_version[BYTE_2] = SW_VERSION_N3;
                 dummy_hk_packet.lfr_sw_version[BYTE_3] = SW_VERSION_N4;
                 // init fpga version
                 parameters = (unsigned char *) (REGS_ADDR_WAVEFORM_PICKER + APB_OFFSET_VHDL_REV);
                 dummy_hk_packet.lfr_fpga_version[BYTE_0] = parameters[BYTE_1]; // n1
                 dummy_hk_packet.lfr_fpga_version[BYTE_1] = parameters[BYTE_2]; // n2
                 dummy_hk_packet.lfr_fpga_version[BYTE_2] = parameters[BYTE_3]; // n3
                 parameters = (unsigned char *) &dummy_hk_packet.hk_lfr_cpu_load;
                 for (i=0; i<(BYTE_POS_HK_REACTION_WHEELS_FREQUENCY - BYTE_POS_HK_LFR_CPU_LOAD); i++)
                 {
                     parameters[i] = INT8_ALL_F;
                 }
                 get_message_queue_id_send( &queue_id );
                 rtems_message_queue_send( queue_id, &dummy_hk_packet,
                                             PACKET_LENGTH_HK + CCSDS_TC_TM_PACKET_OFFSET + CCSDS_PROTOCOLE_EXTRA_BYTES);
             }
             void get_temperatures( unsigned char *temperatures )
             {
                 unsigned char* temp_scm_ptr;
                 unsigned char* temp_pcb_ptr;
                 unsigned char* temp_fpga_ptr;
                 // SEL1 SEL0
                 // 0    0       => PCB
                 // 0    1       => FPGA
                 // 1    0       => SCM
                 temp_scm_ptr  = (unsigned char *) &time_management_regs->temp_scm;
                 temp_pcb_ptr =  (unsigned char *) &time_management_regs->temp_pcb;
                 temp_fpga_ptr = (unsigned char *) &time_management_regs->temp_fpga;
                 temperatures[ BYTE_0 ] = temp_scm_ptr[ BYTE_2 ];
                 temperatures[ BYTE_1 ] = temp_scm_ptr[ BYTE_3 ];
                 temperatures[ BYTE_2 ] = temp_pcb_ptr[ BYTE_2 ];
                 temperatures[ BYTE_3 ] = temp_pcb_ptr[ BYTE_3 ];
                 temperatures[ BYTE_4 ] = temp_fpga_ptr[ BYTE_2 ];
                 temperatures[ BYTE_5 ] = temp_fpga_ptr[ BYTE_3 ];
             }
             void get_v_e1_e2_f3( unsigned char *spacecraft_potential )
             {
                 unsigned char* v_ptr;
                 unsigned char* e1_ptr;
                 unsigned char* e2_ptr;
                 v_ptr  = (unsigned char *) &hk_lfr_sc_v_f3_as_int16;
                 e1_ptr = (unsigned char *) &hk_lfr_sc_e1_f3_as_int16;
                 e2_ptr = (unsigned char *) &hk_lfr_sc_e2_f3_as_int16;
                 spacecraft_potential[BYTE_0] = v_ptr[0];
                 spacecraft_potential[BYTE_1] = v_ptr[1];
                 spacecraft_potential[BYTE_2] = e1_ptr[0];
                 spacecraft_potential[BYTE_3] = e1_ptr[1];
                 spacecraft_potential[BYTE_4] = e2_ptr[0];
                 spacecraft_potential[BYTE_5] = e2_ptr[1];
             }
             void get_cpu_load( unsigned char *resource_statistics )
             {
                 unsigned char cpu_load;
                 cpu_load = lfr_rtems_cpu_usage_report();
                 // HK_LFR_CPU_LOAD
                 resource_statistics[0] = cpu_load;
                 // HK_LFR_CPU_LOAD_MAX
                 if (cpu_load > resource_statistics[1])
                 {
                      resource_statistics[1] = cpu_load;
                 }
                 // CPU_LOAD_AVE
                 resource_statistics[BYTE_2] = 0;
             #ifndef PRINT_TASK_STATISTICS
                     rtems_cpu_usage_reset();
             #endif
             }
             void set_hk_lfr_sc_potential_flag( bool state )
             {
                 if (state == true)
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] | STATUS_WORD_SC_POTENTIAL_FLAG_BIT;   // [0100 0000]
                 }
                 else
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] & STATUS_WORD_SC_POTENTIAL_FLAG_MASK;   // [1011 1111]
                 }
             }
             void set_sy_lfr_pas_filter_enabled( bool state )
             {
                 if (state == true)
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] | STATUS_WORD_PAS_FILTER_ENABLED_BIT;   // [0010 0000]
                 }
                 else
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] & STATUS_WORD_PAS_FILTER_ENABLED_MASK;   // [1101 1111]
                 }
             }
             void set_sy_lfr_watchdog_enabled( bool state )
             {
                 if (state == true)
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] | STATUS_WORD_WATCHDOG_BIT;   // [0001 0000]
                 }
                 else
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] & STATUS_WORD_WATCHDOG_MASK;   // [1110 1111]
                 }
             }
             void set_hk_lfr_calib_enable( bool state )
             {
                 if (state == true)
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] | STATUS_WORD_CALIB_BIT;   // [0000 1000]
                 }
                 else
                 {
                     housekeeping_packet.lfr_status_word[1] =
                             housekeeping_packet.lfr_status_word[1] & STATUS_WORD_CALIB_MASK;   // [1111 0111]
                 }
             }
             void set_hk_lfr_reset_cause( enum lfr_reset_cause_t lfr_reset_cause )
             {
                 housekeeping_packet.lfr_status_word[1] =
                         housekeeping_packet.lfr_status_word[1] & STATUS_WORD_RESET_CAUSE_MASK; // [1111 1000]
                 housekeeping_packet.lfr_status_word[1] = housekeeping_packet.lfr_status_word[1]
                         | (lfr_reset_cause & STATUS_WORD_RESET_CAUSE_BITS );   // [0000 0111]
             }
             void increment_hk_counter( unsigned char newValue, unsigned char oldValue, unsigned int *counter )
             {
                 int delta;
                 delta = 0;
                 if (newValue >= oldValue)
                 {
                     delta = newValue - oldValue;
                 }
                 else
                 {
                     delta = (CONST_256 - oldValue) + newValue;
                 }
                 *counter = *counter + delta;
             }
             void hk_lfr_le_update( void )
             {
                 static hk_lfr_le_t old_hk_lfr_le = {0};
                 hk_lfr_le_t new_hk_lfr_le;
                 unsigned int counter;
                 counter = (((unsigned int) housekeeping_packet.hk_lfr_le_cnt[0]) * CONST_256) + housekeeping_packet.hk_lfr_le_cnt[1];
                 // DPU
                 new_hk_lfr_le.dpu_spw_parity    = housekeeping_packet.hk_lfr_dpu_spw_parity;
                 new_hk_lfr_le.dpu_spw_disconnect= housekeeping_packet.hk_lfr_dpu_spw_disconnect;
                 new_hk_lfr_le.dpu_spw_escape    = housekeeping_packet.hk_lfr_dpu_spw_escape;
                 new_hk_lfr_le.dpu_spw_credit    = housekeeping_packet.hk_lfr_dpu_spw_credit;
                 new_hk_lfr_le.dpu_spw_write_sync= housekeeping_packet.hk_lfr_dpu_spw_write_sync;
                 // TIMECODE
                 new_hk_lfr_le.timecode_erroneous= housekeeping_packet.hk_lfr_timecode_erroneous;
                 new_hk_lfr_le.timecode_missing  = housekeeping_packet.hk_lfr_timecode_missing;
                 new_hk_lfr_le.timecode_invalid  = housekeeping_packet.hk_lfr_timecode_invalid;
                 // TIME
                 new_hk_lfr_le.time_timecode_it  = housekeeping_packet.hk_lfr_time_timecode_it;
                 new_hk_lfr_le.time_not_synchro  = housekeeping_packet.hk_lfr_time_not_synchro;
                 new_hk_lfr_le.time_timecode_ctr = housekeeping_packet.hk_lfr_time_timecode_ctr;
                 //AHB
                 new_hk_lfr_le.ahb_correctable   = housekeeping_packet.hk_lfr_ahb_correctable;
                 // housekeeping_packet.hk_lfr_dpu_spw_rx_ahb => not handled by the grspw driver
                 // housekeeping_packet.hk_lfr_dpu_spw_tx_ahb => not handled by the grspw driver
                 // update the le counter
                 // DPU
                 increment_hk_counter( new_hk_lfr_le.dpu_spw_parity,    old_hk_lfr_le.dpu_spw_parity,       &counter );
                 increment_hk_counter( new_hk_lfr_le.dpu_spw_disconnect,old_hk_lfr_le.dpu_spw_disconnect,   &counter );
                 increment_hk_counter( new_hk_lfr_le.dpu_spw_escape,    old_hk_lfr_le.dpu_spw_escape,       &counter );
                 increment_hk_counter( new_hk_lfr_le.dpu_spw_credit,    old_hk_lfr_le.dpu_spw_credit,       &counter );
                 increment_hk_counter( new_hk_lfr_le.dpu_spw_write_sync,old_hk_lfr_le.dpu_spw_write_sync,   &counter );
                 // TIMECODE
                 increment_hk_counter( new_hk_lfr_le.timecode_erroneous,old_hk_lfr_le.timecode_erroneous,   &counter );
                 increment_hk_counter( new_hk_lfr_le.timecode_missing,  old_hk_lfr_le.timecode_missing,     &counter );
                 increment_hk_counter( new_hk_lfr_le.timecode_invalid,  old_hk_lfr_le.timecode_invalid,     &counter );
                 // TIME
                 increment_hk_counter( new_hk_lfr_le.time_timecode_it,  old_hk_lfr_le.time_timecode_it,     &counter );
                 increment_hk_counter( new_hk_lfr_le.time_not_synchro,  old_hk_lfr_le.time_not_synchro,     &counter );
                 increment_hk_counter( new_hk_lfr_le.time_timecode_ctr, old_hk_lfr_le.time_timecode_ctr,    &counter );
                 // AHB
                 increment_hk_counter( new_hk_lfr_le.ahb_correctable,   old_hk_lfr_le.ahb_correctable,      &counter );
                 // DPU
                 old_hk_lfr_le.dpu_spw_parity    = new_hk_lfr_le.dpu_spw_parity;
                 old_hk_lfr_le.dpu_spw_disconnect= new_hk_lfr_le.dpu_spw_disconnect;
                 old_hk_lfr_le.dpu_spw_escape    = new_hk_lfr_le.dpu_spw_escape;
                 old_hk_lfr_le.dpu_spw_credit    = new_hk_lfr_le.dpu_spw_credit;
                 old_hk_lfr_le.dpu_spw_write_sync= new_hk_lfr_le.dpu_spw_write_sync;
                 // TIMECODE
                 old_hk_lfr_le.timecode_erroneous= new_hk_lfr_le.timecode_erroneous;
                 old_hk_lfr_le.timecode_missing  = new_hk_lfr_le.timecode_missing;
                 old_hk_lfr_le.timecode_invalid  = new_hk_lfr_le.timecode_invalid;
                 // TIME
                 old_hk_lfr_le.time_timecode_it  = new_hk_lfr_le.time_timecode_it;
                 old_hk_lfr_le.time_not_synchro  = new_hk_lfr_le.time_not_synchro;
                 old_hk_lfr_le.time_timecode_ctr = new_hk_lfr_le.time_timecode_ctr;
                 //AHB
                 old_hk_lfr_le.ahb_correctable   = new_hk_lfr_le.ahb_correctable;
                 // housekeeping_packet.hk_lfr_dpu_spw_rx_ahb => not handled by the grspw driver
                 // housekeeping_packet.hk_lfr_dpu_spw_tx_ahb => not handled by the grspw driver
                 // update housekeeping packet counters, convert unsigned int numbers in 2 bytes numbers
                 // LE
                 housekeeping_packet.hk_lfr_le_cnt[0] = (unsigned char) ((counter & BYTE0_MASK) >> SHIFT_1_BYTE);
                 housekeeping_packet.hk_lfr_le_cnt[1] = (unsigned char)  (counter & BYTE1_MASK);
             }
             void hk_lfr_me_update( void )
             {
                 static hk_lfr_me_t old_hk_lfr_me = {0};
                 hk_lfr_me_t new_hk_lfr_me;
                 unsigned int counter;
                 counter = (((unsigned int) housekeeping_packet.hk_lfr_me_cnt[0]) * CONST_256) + housekeeping_packet.hk_lfr_me_cnt[1];
                 // get the current values
                 new_hk_lfr_me.dpu_spw_early_eop     = housekeeping_packet.hk_lfr_dpu_spw_early_eop;
                 new_hk_lfr_me.dpu_spw_invalid_addr  = housekeeping_packet.hk_lfr_dpu_spw_invalid_addr;
                 new_hk_lfr_me.dpu_spw_eep           = housekeeping_packet.hk_lfr_dpu_spw_eep;
                 new_hk_lfr_me.dpu_spw_rx_too_big    = housekeeping_packet.hk_lfr_dpu_spw_rx_too_big;
                 // update the me counter
                 increment_hk_counter( new_hk_lfr_me.dpu_spw_early_eop,      old_hk_lfr_me.dpu_spw_early_eop,    &counter );
                 increment_hk_counter( new_hk_lfr_me.dpu_spw_invalid_addr,   old_hk_lfr_me.dpu_spw_invalid_addr, &counter );
                 increment_hk_counter( new_hk_lfr_me.dpu_spw_eep,            old_hk_lfr_me.dpu_spw_eep,          &counter );
                 increment_hk_counter( new_hk_lfr_me.dpu_spw_rx_too_big,     old_hk_lfr_me.dpu_spw_rx_too_big,   &counter );
                 // store the counters for the next time
                 old_hk_lfr_me.dpu_spw_early_eop     = new_hk_lfr_me.dpu_spw_early_eop;
                 old_hk_lfr_me.dpu_spw_invalid_addr  = new_hk_lfr_me.dpu_spw_invalid_addr;
                 old_hk_lfr_me.dpu_spw_eep           = new_hk_lfr_me.dpu_spw_eep;
                 old_hk_lfr_me.dpu_spw_rx_too_big    = new_hk_lfr_me.dpu_spw_rx_too_big;
                 // update housekeeping packet counters, convert unsigned int numbers in 2 bytes numbers
                 // ME
                 housekeeping_packet.hk_lfr_me_cnt[0] = (unsigned char) ((counter & BYTE0_MASK) >> SHIFT_1_BYTE);
                 housekeeping_packet.hk_lfr_me_cnt[1] = (unsigned char)  (counter & BYTE1_MASK);
             }
             void hk_lfr_le_me_he_update()
             {
                 unsigned int hk_lfr_he_cnt;
                 hk_lfr_he_cnt = (((unsigned int) housekeeping_packet.hk_lfr_he_cnt[0]) * 256) + housekeeping_packet.hk_lfr_he_cnt[1];
                 //update the low severity error counter
                 hk_lfr_le_update( );
                 //update the medium severity error counter
                 hk_lfr_me_update();
                 //update the high severity error counter
                 hk_lfr_he_cnt = 0;
                 // update housekeeping packet counters, convert unsigned int numbers in 2 bytes numbers
                 // HE
                 housekeeping_packet.hk_lfr_he_cnt[0] = (unsigned char) ((hk_lfr_he_cnt & BYTE0_MASK) >> SHIFT_1_BYTE);
                 housekeeping_packet.hk_lfr_he_cnt[1] = (unsigned char)  (hk_lfr_he_cnt & BYTE1_MASK);
             }
             void set_hk_lfr_time_not_synchro()
             {
                 static unsigned char synchroLost = 1;
                 int synchronizationBit;
                 // get the synchronization bit
                 synchronizationBit =
                         (time_management_regs->coarse_time & VAL_LFR_SYNCHRONIZED) >> BIT_SYNCHRONIZATION;    // 1000 0000 0000 0000
                 switch (synchronizationBit)
                 {
                 case 0:
                     if (synchroLost == 1)
                     {
                         synchroLost = 0;
                     }
                     break;
                 case 1:
                     if (synchroLost == 0 )
                     {
                         synchroLost = 1;
                         increase_unsigned_char_counter(&housekeeping_packet.hk_lfr_time_not_synchro);
                         update_hk_lfr_last_er_fields( RID_LE_LFR_TIME, CODE_NOT_SYNCHRO );
                     }
                     break;
                 default:
                     PRINTF1("in hk_lfr_time_not_synchro *** unexpected value for synchronizationBit = %d\n", synchronizationBit);
                     break;
                 }
             }
             void set_hk_lfr_ahb_correctable()   // CRITICITY L
             {
                 /** This function builds the error counter hk_lfr_ahb_correctable using the statistics provided
                  * by the Cache Control Register (ASI 2, offset 0) and in the Register Protection Control Register (ASR16) on the
                  * detected errors in the cache, in the integer unit and in the floating point unit.
                  *
                  * @param void
                  *
                  * @return void
                  *
                  * All errors are summed to set the value of the hk_lfr_ahb_correctable counter.
                  *
                 */
                 unsigned int ahb_correctable;
                 unsigned int instructionErrorCounter;
                 unsigned int dataErrorCounter;
                 unsigned int fprfErrorCounter;
                 unsigned int iurfErrorCounter;
                 instructionErrorCounter = 0;
                 dataErrorCounter = 0;
                 fprfErrorCounter = 0;
                 iurfErrorCounter = 0;
                 CCR_getInstructionAndDataErrorCounters( &instructionErrorCounter, &dataErrorCounter);
                 ASR16_get_FPRF_IURF_ErrorCounters( &fprfErrorCounter, &iurfErrorCounter);
                 ahb_correctable = instructionErrorCounter
                         + dataErrorCounter
                         + fprfErrorCounter
                         + iurfErrorCounter
                         + housekeeping_packet.hk_lfr_ahb_correctable;
                 housekeeping_packet.hk_lfr_ahb_correctable = (unsigned char) (ahb_correctable & INT8_ALL_F);  // [1111 1111]
             }

src/wf_handler.c +1 -1

             /** Functions and tasks related to waveform packet generation.
              *
              * @file
              * @author P. LEROY
              *
              * A group of functions to handle waveforms, in snapshot or continuous format.\n
              *
              */
             #include "wf_handler.h"
             //***************
             // waveform rings
             // F0
             ring_node waveform_ring_f0[NB_RING_NODES_F0]= {0};
             ring_node *current_ring_node_f0             = NULL;
             ring_node *ring_node_to_send_swf_f0         = NULL;
             // F1
             ring_node waveform_ring_f1[NB_RING_NODES_F1] = {0};
             ring_node *current_ring_node_f1             = NULL;
             ring_node *ring_node_to_send_swf_f1         = NULL;
             ring_node *ring_node_to_send_cwf_f1         = NULL;
             // F2
             ring_node waveform_ring_f2[NB_RING_NODES_F2] = {0};
             ring_node *current_ring_node_f2             = NULL;
             ring_node *ring_node_to_send_swf_f2         = NULL;
             ring_node *ring_node_to_send_cwf_f2         = NULL;
             // F3
             ring_node waveform_ring_f3[NB_RING_NODES_F3] = {0};
             ring_node *current_ring_node_f3             = NULL;
             ring_node *ring_node_to_send_cwf_f3         = NULL;
             char wf_cont_f3_light[ (NB_SAMPLES_PER_SNAPSHOT) * NB_BYTES_CWF3_LIGHT_BLK ] = {0};
             bool extractSWF1 = false;
             bool extractSWF2 = false;
             bool swf0_ready_flag_f1 = false;
             bool swf0_ready_flag_f2 = false;
             bool swf1_ready = false;
             bool swf2_ready = false;
             int swf1_extracted[ (NB_SAMPLES_PER_SNAPSHOT * NB_WORDS_SWF_BLK) ] = {0};
             int swf2_extracted[ (NB_SAMPLES_PER_SNAPSHOT * NB_WORDS_SWF_BLK) ] = {0};
             ring_node ring_node_swf1_extracted = {0};
             ring_node ring_node_swf2_extracted = {0};
             typedef enum resynchro_state_t
             {
                 MEASURE,
                 CORRECTION
             } resynchro_state;
             //*********************
             // Interrupt SubRoutine
             ring_node * getRingNodeToSendCWF( unsigned char frequencyChannel)
             {
                 ring_node *node;
                 node = NULL;
                 switch ( frequencyChannel ) {
                 case CHANNELF1:
                     node = ring_node_to_send_cwf_f1;
                     break;
                 case CHANNELF2:
                     node = ring_node_to_send_cwf_f2;
                     break;
                 case CHANNELF3:
                     node = ring_node_to_send_cwf_f3;
                     break;
                 default:
                     break;
                 }
                 return node;
             }
             ring_node * getRingNodeToSendSWF( unsigned char frequencyChannel)
             {
                 ring_node *node;
                 node = NULL;
                 switch ( frequencyChannel ) {
                 case CHANNELF0:
                     node = ring_node_to_send_swf_f0;
                     break;
                 case CHANNELF1:
                     node = ring_node_to_send_swf_f1;
                     break;
                 case CHANNELF2:
                     node = ring_node_to_send_swf_f2;
                     break;
                 default:
                     break;
                 }
                 return node;
             }
             void reset_extractSWF( void )
             {
                 extractSWF1 = false;
                 extractSWF2 = false;
                 swf0_ready_flag_f1 = false;
                 swf0_ready_flag_f2 = false;
                 swf1_ready = false;
                 swf2_ready = false;
             }
             inline void waveforms_isr_f3( void )
             {
                 rtems_status_code spare_status;
                 if ( (lfrCurrentMode == LFR_MODE_NORMAL) || (lfrCurrentMode == LFR_MODE_BURST)  // in BURST the data are used to place v, e1 and e2 in the HK packet
                      || (lfrCurrentMode == LFR_MODE_SBM1) || (lfrCurrentMode == LFR_MODE_SBM2) )
                 { // in modes other than STANDBY and BURST, send the CWF_F3 data
                     //***
                     // F3
                     if ( (waveform_picker_regs->status & BITS_WFP_STATUS_F3) != INIT_CHAR ) {  // [1100 0000] check the f3 full bits
                         ring_node_to_send_cwf_f3    = current_ring_node_f3->previous;
                         current_ring_node_f3        = current_ring_node_f3->next;
                         if ((waveform_picker_regs->status & BIT_WFP_BUF_F3_0) == BIT_WFP_BUF_F3_0){             // [0100 0000] f3 buffer 0 is full
                             ring_node_to_send_cwf_f3->coarseTime    = waveform_picker_regs->f3_0_coarse_time;
                             ring_node_to_send_cwf_f3->fineTime      = waveform_picker_regs->f3_0_fine_time;
                             waveform_picker_regs->addr_data_f3_0    = current_ring_node_f3->buffer_address;
                             waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F3_0; // [1000 1000 0100 0000]
                         }
                         else if ((waveform_picker_regs->status & BIT_WFP_BUF_F3_1) == BIT_WFP_BUF_F3_1){    // [1000 0000] f3 buffer 1 is full
                             ring_node_to_send_cwf_f3->coarseTime    = waveform_picker_regs->f3_1_coarse_time;
                             ring_node_to_send_cwf_f3->fineTime      = waveform_picker_regs->f3_1_fine_time;
                             waveform_picker_regs->addr_data_f3_1    = current_ring_node_f3->buffer_address;
                             waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F3_1; // [1000 1000 1000 0000]
                         }
                         if (rtems_event_send( Task_id[TASKID_CWF3], RTEMS_EVENT_0 ) != RTEMS_SUCCESSFUL) {
                             spare_status = rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_0 );
                         }
                     }
                 }
             }
             inline void waveforms_isr_burst( void )
             {
                 unsigned char status;
                 rtems_status_code spare_status;
                 status = (waveform_picker_regs->status & BITS_WFP_STATUS_F2) >> SHIFT_WFP_STATUS_F2;   // [0011 0000] get the status bits for f2
                 switch(status)
                 {
                 case BIT_WFP_BUFFER_0:
                     ring_node_to_send_cwf_f2                = current_ring_node_f2->previous;
                     ring_node_to_send_cwf_f2->sid           = SID_BURST_CWF_F2;
                     ring_node_to_send_cwf_f2->coarseTime    = waveform_picker_regs->f2_0_coarse_time;
                     ring_node_to_send_cwf_f2->fineTime      = waveform_picker_regs->f2_0_fine_time;
                     current_ring_node_f2                    = current_ring_node_f2->next;
                     waveform_picker_regs->addr_data_f2_0    = current_ring_node_f2->buffer_address;
                     if (rtems_event_send( Task_id[TASKID_CWF2], RTEMS_EVENT_MODE_BURST ) != RTEMS_SUCCESSFUL) {
                         spare_status = rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_0 );
                     }
                     waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F2_0; // [0100 0100 0001 0000]
                     break;
                 case BIT_WFP_BUFFER_1:
                     ring_node_to_send_cwf_f2                = current_ring_node_f2->previous;
                     ring_node_to_send_cwf_f2->sid           = SID_BURST_CWF_F2;
                     ring_node_to_send_cwf_f2->coarseTime    = waveform_picker_regs->f2_1_coarse_time;
                     ring_node_to_send_cwf_f2->fineTime      = waveform_picker_regs->f2_1_fine_time;
                     current_ring_node_f2                    = current_ring_node_f2->next;
                     waveform_picker_regs->addr_data_f2_1    = current_ring_node_f2->buffer_address;
                     if (rtems_event_send( Task_id[TASKID_CWF2], RTEMS_EVENT_MODE_BURST ) != RTEMS_SUCCESSFUL) {
                         spare_status = rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_0 );
                     }
                     waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F2_1; // [0100 0100 0010 0000]
                     break;
                 default:
                     break;
                 }
             }
             inline void waveform_isr_normal_sbm1_sbm2( void )
             {
                 rtems_status_code status;
                 //***
                 // F0
                 if ( (waveform_picker_regs->status & BITS_WFP_STATUS_F0) != INIT_CHAR )  // [0000 0011] check the f0 full bits
                 {
                     swf0_ready_flag_f1 = true;
                     swf0_ready_flag_f2 = true;
                     ring_node_to_send_swf_f0    = current_ring_node_f0->previous;
                     current_ring_node_f0        = current_ring_node_f0->next;
                     if ( (waveform_picker_regs->status & BIT_WFP_BUFFER_0) == BIT_WFP_BUFFER_0)
                     {
                         ring_node_to_send_swf_f0->coarseTime    = waveform_picker_regs->f0_0_coarse_time;
                         ring_node_to_send_swf_f0->fineTime      = waveform_picker_regs->f0_0_fine_time;
                         waveform_picker_regs->addr_data_f0_0    = current_ring_node_f0->buffer_address;
                         waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F0_0; // [0001 0001 0000 0001]
                     }
                     else if ( (waveform_picker_regs->status & BIT_WFP_BUFFER_1) == BIT_WFP_BUFFER_1)
                     {
                         ring_node_to_send_swf_f0->coarseTime    = waveform_picker_regs->f0_1_coarse_time;
                         ring_node_to_send_swf_f0->fineTime      = waveform_picker_regs->f0_1_fine_time;
                         waveform_picker_regs->addr_data_f0_1    = current_ring_node_f0->buffer_address;
                         waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F0_1; // [0001 0001 0000 0010]
                     }
                     // send an event to the WFRM task for resynchro activities
                     status = rtems_event_send( Task_id[TASKID_WFRM], RTEMS_EVENT_SWF_RESYNCH );
                 }
                 //***
                 // F1
                 if ( (waveform_picker_regs->status & BITS_WFP_STATUS_F1) != INIT_CHAR ) {  // [0000 1100] check the f1 full bits
                     // (1) change the receiving buffer for the waveform picker
                     ring_node_to_send_cwf_f1    = current_ring_node_f1->previous;
                     current_ring_node_f1        = current_ring_node_f1->next;
                     if ( (waveform_picker_regs->status & BIT_WFP_BUF_F1_0) == BIT_WFP_BUF_F1_0)
                     {
                         ring_node_to_send_cwf_f1->coarseTime    = waveform_picker_regs->f1_0_coarse_time;
                         ring_node_to_send_cwf_f1->fineTime      = waveform_picker_regs->f1_0_fine_time;
                         waveform_picker_regs->addr_data_f1_0    = current_ring_node_f1->buffer_address;
                         waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F1_0; // [0010 0010 0000 0100] f1 bits = 0
                     }
                     else if ( (waveform_picker_regs->status & BIT_WFP_BUF_F1_1) == BIT_WFP_BUF_F1_1)
                     {
                         ring_node_to_send_cwf_f1->coarseTime    = waveform_picker_regs->f1_1_coarse_time;
                         ring_node_to_send_cwf_f1->fineTime      = waveform_picker_regs->f1_1_fine_time;
                         waveform_picker_regs->addr_data_f1_1    = current_ring_node_f1->buffer_address;
                         waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F1_1; // [0010 0010 0000 1000] f1 bits = 0
                     }
                     // (2) send an event for the the CWF1 task for transmission (and snapshot extraction if needed)
                     status = rtems_event_send( Task_id[TASKID_CWF1], RTEMS_EVENT_MODE_NORM_S1_S2 );
                 }
                 //***
                 // F2
                 if ( (waveform_picker_regs->status & BITS_WFP_STATUS_F2) != INIT_CHAR ) {  // [0011 0000] check the f2 full bit
                     // (1) change the receiving buffer for the waveform picker
                     ring_node_to_send_cwf_f2      = current_ring_node_f2->previous;
                     ring_node_to_send_cwf_f2->sid = SID_SBM2_CWF_F2;
                     current_ring_node_f2          = current_ring_node_f2->next;
                     if ( (waveform_picker_regs->status & BIT_WFP_BUF_F2_0) == BIT_WFP_BUF_F2_0)
                     {
                         ring_node_to_send_cwf_f2->coarseTime    = waveform_picker_regs->f2_0_coarse_time;
                         ring_node_to_send_cwf_f2->fineTime      = waveform_picker_regs->f2_0_fine_time;
                         waveform_picker_regs->addr_data_f2_0    = current_ring_node_f2->buffer_address;
                         waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F2_0; // [0100 0100 0001 0000]
                     }
                     else if ( (waveform_picker_regs->status & BIT_WFP_BUF_F2_1) == BIT_WFP_BUF_F2_1)
                     {
                         ring_node_to_send_cwf_f2->coarseTime    = waveform_picker_regs->f2_1_coarse_time;
                         ring_node_to_send_cwf_f2->fineTime      = waveform_picker_regs->f2_1_fine_time;
                         waveform_picker_regs->addr_data_f2_1    = current_ring_node_f2->buffer_address;
                         waveform_picker_regs->status            = waveform_picker_regs->status & RST_WFP_F2_1; // [0100 0100 0010 0000]
                     }
                     // (2) send an event for the waveforms transmission
                     status = rtems_event_send( Task_id[TASKID_CWF2], RTEMS_EVENT_MODE_NORM_S1_S2 );
                 }
             }
             rtems_isr waveforms_isr( rtems_vector_number vector )
             {
                 /** This is the interrupt sub routine called by the waveform picker core.
                  *
                  * This ISR launch different actions depending mainly on two pieces of information:
                  * 1. the values read in the registers of the waveform picker.
                  * 2. the current LFR mode.
                  *
                  */
                 // STATUS
                 // new error        error buffer full
                 // 15 14 13 12      11 10 9  8
                 // f3 f2 f1 f0      f3 f2 f1 f0
                 //
                 // ready buffer
                 // 7    6    5    4    3    2    1    0
                 // f3_1 f3_0 f2_1 f2_0 f1_1 f1_0 f0_1 f0_0
                 rtems_status_code spare_status;
                 waveforms_isr_f3();
                 //*************************************************
                 // copy the status bits in the housekeeping packets
                 housekeeping_packet.hk_lfr_vhdl_iir_cal =
                         (unsigned char) ((waveform_picker_regs->status & BYTE0_MASK) >> SHIFT_1_BYTE);
                 if ( (waveform_picker_regs->status & BYTE0_MASK) != INIT_CHAR)    // [1111 1111 0000 0000] check the error bits
                 {
                     spare_status = rtems_event_send( Task_id[TASKID_DUMB], RTEMS_EVENT_10 );
                 }
                 switch(lfrCurrentMode)
                 {
                 //********
                 // STANDBY
                 case LFR_MODE_STANDBY:
                     break;
                     //**************************
                     // LFR NORMAL, SBM1 and SBM2
                 case LFR_MODE_NORMAL:
                 case LFR_MODE_SBM1:
                 case LFR_MODE_SBM2:
                     waveform_isr_normal_sbm1_sbm2();
                     break;
                     //******
                     // BURST
                 case LFR_MODE_BURST:
                     waveforms_isr_burst();
                     break;
                     //********
                     // DEFAULT
                 default:
                     break;
                 }
             }
             //************
             // RTEMS TASKS
             rtems_task wfrm_task(rtems_task_argument argument) //used with the waveform picker VHDL IP
             {
                 /** This RTEMS task is dedicated to the transmission of snapshots of the NORMAL mode.
                  *
                  * @param unused is the starting argument of the RTEMS task
                  *
                  * The following data packets are sent by this task:
                  * - TM_LFR_SCIENCE_NORMAL_SWF_F0
                  * - TM_LFR_SCIENCE_NORMAL_SWF_F1
                  * - TM_LFR_SCIENCE_NORMAL_SWF_F2
                  *
                  */
                 rtems_event_set event_out;
                 rtems_id queue_id;
                 rtems_status_code status;
                 ring_node *ring_node_swf1_extracted_ptr;
                 ring_node *ring_node_swf2_extracted_ptr;
                 event_out = EVENT_SETS_NONE_PENDING;
                 queue_id = RTEMS_ID_NONE;
                 ring_node_swf1_extracted_ptr = (ring_node *) &ring_node_swf1_extracted;
                 ring_node_swf2_extracted_ptr = (ring_node *) &ring_node_swf2_extracted;
                 status =  get_message_queue_id_send( &queue_id );
                 if (status != RTEMS_SUCCESSFUL)
                 {
                     PRINTF1("in WFRM *** ERR get_message_queue_id_send %d\n", status);
                 }
                 BOOT_PRINTF("in WFRM ***\n");
                 while(1){
                     // wait for an RTEMS_EVENT
                     rtems_event_receive(RTEMS_EVENT_MODE_NORMAL | RTEMS_EVENT_SWF_RESYNCH,
                                         RTEMS_WAIT | RTEMS_EVENT_ANY, RTEMS_NO_TIMEOUT, &event_out);
                     if (event_out == RTEMS_EVENT_MODE_NORMAL)
                     {
                         DEBUG_PRINTF("WFRM received RTEMS_EVENT_MODE_SBM2\n");
                         ring_node_to_send_swf_f0->sid           = SID_NORM_SWF_F0;
                         ring_node_swf1_extracted_ptr->sid       = SID_NORM_SWF_F1;
                         ring_node_swf2_extracted_ptr->sid       = SID_NORM_SWF_F2;
                         status =  rtems_message_queue_send( queue_id, &ring_node_to_send_swf_f0,     sizeof( ring_node* ) );
                         status =  rtems_message_queue_send( queue_id, &ring_node_swf1_extracted_ptr, sizeof( ring_node* ) );
                         status =  rtems_message_queue_send( queue_id, &ring_node_swf2_extracted_ptr, sizeof( ring_node* ) );
                     }
                     if (event_out == RTEMS_EVENT_SWF_RESYNCH)
                     {
                         snapshot_resynchronization( (unsigned char *)  &ring_node_to_send_swf_f0->coarseTime );
                     }
                 }
             }
             rtems_task cwf3_task(rtems_task_argument argument) //used with the waveform picker VHDL IP
             {
                 /** This RTEMS task is dedicated to the transmission of continuous waveforms at f3.
                  *
                  * @param unused is the starting argument of the RTEMS task
                  *
                  * The following data packet is sent by this task:
                  * - TM_LFR_SCIENCE_NORMAL_CWF_F3
                  *
                  */
                 rtems_event_set event_out;
                 rtems_id queue_id;
                 rtems_status_code status;
                 ring_node ring_node_cwf3_light;
                 ring_node *ring_node_to_send_cwf;
                 event_out = EVENT_SETS_NONE_PENDING;
                 queue_id = RTEMS_ID_NONE;
                 status =  get_message_queue_id_send( &queue_id );
                 if (status != RTEMS_SUCCESSFUL)
                 {
                     PRINTF1("in CWF3 *** ERR get_message_queue_id_send %d\n", status)
                 }
                 ring_node_to_send_cwf_f3->sid = SID_NORM_CWF_LONG_F3;
                 // init the ring_node_cwf3_light structure
                 ring_node_cwf3_light.buffer_address = (int) wf_cont_f3_light;
                 ring_node_cwf3_light.coarseTime = INIT_CHAR;
                 ring_node_cwf3_light.fineTime = INIT_CHAR;
                 ring_node_cwf3_light.next = NULL;
                 ring_node_cwf3_light.previous = NULL;
                 ring_node_cwf3_light.sid = SID_NORM_CWF_F3;
                 ring_node_cwf3_light.status = INIT_CHAR;
                 BOOT_PRINTF("in CWF3 ***\n");
                 while(1){
                     // wait for an RTEMS_EVENT
                     rtems_event_receive( RTEMS_EVENT_0,
                                          RTEMS_WAIT | RTEMS_EVENT_ANY, RTEMS_NO_TIMEOUT, &event_out);
                     if ( (lfrCurrentMode == LFR_MODE_NORMAL)
                          || (lfrCurrentMode == LFR_MODE_SBM1) || (lfrCurrentMode==LFR_MODE_SBM2) )
                     {
                         ring_node_to_send_cwf = getRingNodeToSendCWF( CHANNELF3 );
                         if ( (parameter_dump_packet.sy_lfr_n_cwf_long_f3 & BIT_CWF_LONG_F3) == BIT_CWF_LONG_F3)
                         {
                             PRINTF("send CWF_LONG_F3\n");
                             ring_node_to_send_cwf_f3->sid = SID_NORM_CWF_LONG_F3;
                             status =  rtems_message_queue_send( queue_id, &ring_node_to_send_cwf, sizeof( ring_node* ) );
                         }
                         else
                         {
                             PRINTF("send CWF_F3 (light)\n");
                             send_waveform_CWF3_light( ring_node_to_send_cwf, &ring_node_cwf3_light, queue_id );
                         }
                     }
                     else
                     {
                         PRINTF1("in CWF3 *** lfrCurrentMode is %d, no data will be sent\n", lfrCurrentMode)
                     }
                 }
             }
             rtems_task cwf2_task(rtems_task_argument argument)  // ONLY USED IN BURST AND SBM2
             {
                 /** This RTEMS task is dedicated to the transmission of continuous waveforms at f2.
                  *
                  * @param unused is the starting argument of the RTEMS task
                  *
                  * The following data packet is sent by this function:
                  * - TM_LFR_SCIENCE_BURST_CWF_F2
                  * - TM_LFR_SCIENCE_SBM2_CWF_F2
                  *
                  */
                 rtems_event_set event_out;
                 rtems_id queue_id;
                 rtems_status_code status;
                 ring_node *ring_node_to_send;
                 unsigned long long int acquisitionTimeF0_asLong;
                 event_out = EVENT_SETS_NONE_PENDING;
                 queue_id = RTEMS_ID_NONE;
                 acquisitionTimeF0_asLong = INIT_CHAR;
                 status =  get_message_queue_id_send( &queue_id );
                 if (status != RTEMS_SUCCESSFUL)
                 {
                     PRINTF1("in CWF2 *** ERR get_message_queue_id_send %d\n", status)
                 }
                 BOOT_PRINTF("in CWF2 ***\n");
                 while(1){
                     // wait for an RTEMS_EVENT// send the snapshot when built
                     status = rtems_event_send( Task_id[TASKID_WFRM], RTEMS_EVENT_MODE_SBM2 );
                     rtems_event_receive( RTEMS_EVENT_MODE_NORM_S1_S2 | RTEMS_EVENT_MODE_BURST,
                                          RTEMS_WAIT | RTEMS_EVENT_ANY, RTEMS_NO_TIMEOUT, &event_out);
                     ring_node_to_send = getRingNodeToSendCWF( CHANNELF2 );
                     if (event_out == RTEMS_EVENT_MODE_BURST)
                     {   // data are sent whatever the transition time
                         status =  rtems_message_queue_send( queue_id, &ring_node_to_send, sizeof( ring_node* ) );
                     }
                     else if (event_out == RTEMS_EVENT_MODE_NORM_S1_S2)
                     {
                         if ( lfrCurrentMode == LFR_MODE_SBM2 )
                         {
                             // data are sent depending on the transition time
                             if ( time_management_regs->coarse_time >= lastValidEnterModeTime)
                             {
                                 status =  rtems_message_queue_send( queue_id, &ring_node_to_send, sizeof( ring_node* ) );
                             }
                         }
                         // launch snapshot extraction if needed
                         if (extractSWF2 == true)
                         {
                             ring_node_to_send_swf_f2 = ring_node_to_send_cwf_f2;
                             // extract the snapshot
                             build_snapshot_from_ring( ring_node_to_send_swf_f2, CHANNELF2, acquisitionTimeF0_asLong,
                                                       &ring_node_swf2_extracted, swf2_extracted );
                             extractSWF2 = false;
                             swf2_ready = true;  // once the snapshot at f2 is ready the CWF1 task will send an event to WFRM
                         }
                         if (swf0_ready_flag_f2 == true)
                         {
                             extractSWF2 = true;
                             // record the acquition time of the f0 snapshot to use to build the snapshot at f2
                             acquisitionTimeF0_asLong = get_acquisition_time( (unsigned char *) &ring_node_to_send_swf_f0->coarseTime );
                             swf0_ready_flag_f2 = false;
                         }
                     }
                 }
             }
             rtems_task cwf1_task(rtems_task_argument argument)  // ONLY USED IN SBM1
             {
                 /** This RTEMS task is dedicated to the transmission of continuous waveforms at f1.
                  *
                  * @param unused is the starting argument of the RTEMS task
                  *
                  * The following data packet is sent by this function:
                  * - TM_LFR_SCIENCE_SBM1_CWF_F1
                  *
                  */
                 rtems_event_set event_out;
                 rtems_id queue_id;
                 rtems_status_code status;
                 ring_node *ring_node_to_send_cwf;
                 event_out = EVENT_SETS_NONE_PENDING;
                 queue_id = RTEMS_ID_NONE;
                 status =  get_message_queue_id_send( &queue_id );
                 if (status != RTEMS_SUCCESSFUL)
                 {
                     PRINTF1("in CWF1 *** ERR get_message_queue_id_send %d\n", status)
                 }
                 BOOT_PRINTF("in CWF1 ***\n");
                 while(1){
                     // wait for an RTEMS_EVENT
                     rtems_event_receive( RTEMS_EVENT_MODE_NORM_S1_S2,
                                          RTEMS_WAIT | RTEMS_EVENT_ANY, RTEMS_NO_TIMEOUT, &event_out);
                     ring_node_to_send_cwf = getRingNodeToSendCWF( 1 );
                     ring_node_to_send_cwf_f1->sid = SID_SBM1_CWF_F1;
                     if (lfrCurrentMode == LFR_MODE_SBM1)
                     {
                         // data are sent depending on the transition time
                         if ( time_management_regs->coarse_time >= lastValidEnterModeTime )
                         {
                             status =  rtems_message_queue_send( queue_id, &ring_node_to_send_cwf, sizeof( ring_node* ) );
                         }
                     }
                     // launch snapshot extraction if needed
                     if (extractSWF1 == true)
                     {
                         ring_node_to_send_swf_f1 = ring_node_to_send_cwf;
                         // launch the snapshot extraction
                         status = rtems_event_send( Task_id[TASKID_SWBD], RTEMS_EVENT_MODE_NORM_S1_S2 );
                         extractSWF1 = false;
                     }
                     if (swf0_ready_flag_f1 == true)
                     {
                         extractSWF1 = true;
                         swf0_ready_flag_f1 = false;   // this step shall be executed only one time
                     }
                     if ((swf1_ready == true) && (swf2_ready == true))   // swf_f1 is ready after the extraction
                     {
                         status = rtems_event_send( Task_id[TASKID_WFRM], RTEMS_EVENT_MODE_NORMAL );
                         swf1_ready = false;
                         swf2_ready = false;
                     }
                 }
             }
             rtems_task swbd_task(rtems_task_argument argument)
             {
                 /** This RTEMS task is dedicated to the building of snapshots from different continuous waveforms buffers.
                  *
                  * @param unused is the starting argument of the RTEMS task
                  *
                  */
                 rtems_event_set event_out;
                 unsigned long long int acquisitionTimeF0_asLong;
                 event_out = EVENT_SETS_NONE_PENDING;
                 acquisitionTimeF0_asLong = INIT_CHAR;
                 BOOT_PRINTF("in SWBD ***\n")
                         while(1){
                     // wait for an RTEMS_EVENT
                     rtems_event_receive( RTEMS_EVENT_MODE_NORM_S1_S2,
                                          RTEMS_WAIT | RTEMS_EVENT_ANY, RTEMS_NO_TIMEOUT, &event_out);
                     if (event_out == RTEMS_EVENT_MODE_NORM_S1_S2)
                     {
                         acquisitionTimeF0_asLong = get_acquisition_time( (unsigned char *) &ring_node_to_send_swf_f0->coarseTime );
                         build_snapshot_from_ring( ring_node_to_send_swf_f1, CHANNELF1, acquisitionTimeF0_asLong,
                                                   &ring_node_swf1_extracted, swf1_extracted );
                         swf1_ready = true;    // the snapshot has been extracted and is ready to be sent
                     }
                     else
                     {
                         PRINTF1("in SWBD *** unexpected rtems event received %x\n", (int) event_out)
                     }
                 }
             }
             //******************
             // general functions
             void WFP_init_rings( void )
             {
                 // F0 RING
                 init_ring( waveform_ring_f0, NB_RING_NODES_F0, wf_buffer_f0, WFRM_BUFFER );
                 // F1 RING
                 init_ring( waveform_ring_f1, NB_RING_NODES_F1, wf_buffer_f1, WFRM_BUFFER );
                 // F2 RING
                 init_ring( waveform_ring_f2, NB_RING_NODES_F2, wf_buffer_f2, WFRM_BUFFER );
                 // F3 RING
                 init_ring( waveform_ring_f3, NB_RING_NODES_F3, wf_buffer_f3, WFRM_BUFFER );
                 ring_node_swf1_extracted.buffer_address = (int) swf1_extracted;
                 ring_node_swf2_extracted.buffer_address = (int) swf2_extracted;
                 DEBUG_PRINTF1("waveform_ring_f0 @%x\n", (unsigned int) waveform_ring_f0)
                         DEBUG_PRINTF1("waveform_ring_f1 @%x\n", (unsigned int) waveform_ring_f1)
                         DEBUG_PRINTF1("waveform_ring_f2 @%x\n", (unsigned int) waveform_ring_f2)
                         DEBUG_PRINTF1("waveform_ring_f3 @%x\n", (unsigned int) waveform_ring_f3)
                         DEBUG_PRINTF1("wf_buffer_f0 @%x\n", (unsigned int) wf_buffer_f0)
                         DEBUG_PRINTF1("wf_buffer_f1 @%x\n", (unsigned int) wf_buffer_f1)
                         DEBUG_PRINTF1("wf_buffer_f2 @%x\n", (unsigned int) wf_buffer_f2)
                         DEBUG_PRINTF1("wf_buffer_f3 @%x\n", (unsigned int) wf_buffer_f3)
             }
             void WFP_reset_current_ring_nodes( void )
             {
                 current_ring_node_f0      = waveform_ring_f0[0].next;
                 current_ring_node_f1      = waveform_ring_f1[0].next;
                 current_ring_node_f2      = waveform_ring_f2[0].next;
                 current_ring_node_f3      = waveform_ring_f3[0].next;
                 ring_node_to_send_swf_f0  = waveform_ring_f0;
                 ring_node_to_send_swf_f1  = waveform_ring_f1;
                 ring_node_to_send_swf_f2  = waveform_ring_f2;
                 ring_node_to_send_cwf_f1  = waveform_ring_f1;
                 ring_node_to_send_cwf_f2  = waveform_ring_f2;
                 ring_node_to_send_cwf_f3  = waveform_ring_f3;
             }
             int send_waveform_CWF3_light( ring_node *ring_node_to_send, ring_node *ring_node_cwf3_light, rtems_id queue_id )
             {
                 /** This function sends CWF_F3 CCSDS packets without the b1, b2 and b3 data.
                  *
                  * @param waveform points to the buffer containing the data that will be send.
                  * @param headerCWF points to a table of headers that have been prepared for the data transmission.
                  * @param queue_id is the id of the rtems queue to which spw_ioctl_pkt_send structures will be send. The structures
                  * contain information to setup the transmission of the data packets.
                  *
                  * By default, CWF_F3 packet are send without the b1, b2 and b3 data. This function rebuilds a data buffer
                  * from the incoming data and sends it in 7 packets, 6 containing 340 blocks and 1 one containing 8 blocks.
                  *
                  */
                 unsigned int i;
                 unsigned int j;
                 int ret;
                 rtems_status_code status;
                 char *sample;
                 int *dataPtr;
                 ret = LFR_DEFAULT;
                 dataPtr     = (int*) ring_node_to_send->buffer_address;
                 ring_node_cwf3_light->coarseTime = ring_node_to_send->coarseTime;
                 ring_node_cwf3_light->fineTime = ring_node_to_send->fineTime;
                 //**********************
                 // BUILD CWF3_light DATA
                 for ( i=0; i< NB_SAMPLES_PER_SNAPSHOT; i++)
                 {
                     sample = (char*) &dataPtr[ (i * NB_WORDS_SWF_BLK) ];
                     for (j=0; j < CWF_BLK_SIZE; j++)
                     {
                         wf_cont_f3_light[ (i * NB_BYTES_CWF3_LIGHT_BLK) + j] = sample[ j ];
                     }
                 }
                 // SEND PACKET
                 status =  rtems_message_queue_send( queue_id, &ring_node_cwf3_light, sizeof( ring_node* ) );
                 if (status != RTEMS_SUCCESSFUL) {
                     ret = LFR_DEFAULT;
                 }
                 return ret;
             }
             void compute_acquisition_time( unsigned int coarseTime, unsigned int fineTime,
                                            unsigned int sid, unsigned char pa_lfr_pkt_nr, unsigned char * acquisitionTime )
             {
                 unsigned long long int acquisitionTimeAsLong;
                 unsigned char localAcquisitionTime[BYTES_PER_TIME];
                 double deltaT;
                 deltaT = INIT_FLOAT;
                 localAcquisitionTime[BYTE_0] = (unsigned char) ( coarseTime >> SHIFT_3_BYTES );
                 localAcquisitionTime[BYTE_1] = (unsigned char) ( coarseTime >> SHIFT_2_BYTES );
                 localAcquisitionTime[BYTE_2] = (unsigned char) ( coarseTime >> SHIFT_1_BYTE  );
                 localAcquisitionTime[BYTE_3] = (unsigned char) ( coarseTime                  );
                 localAcquisitionTime[BYTE_4] = (unsigned char) ( fineTime   >> SHIFT_1_BYTE  );
                 localAcquisitionTime[BYTE_5] = (unsigned char) ( fineTime                    );
                 acquisitionTimeAsLong = ( (unsigned long long int) localAcquisitionTime[BYTE_0] << SHIFT_5_BYTES )
                         + ( (unsigned long long int) localAcquisitionTime[BYTE_1] << SHIFT_4_BYTES )
                         + ( (unsigned long long int) localAcquisitionTime[BYTE_2] << SHIFT_3_BYTES )
                         + ( (unsigned long long int) localAcquisitionTime[BYTE_3] << SHIFT_2_BYTES )
                         + ( (unsigned long long int) localAcquisitionTime[BYTE_4] << SHIFT_1_BYTE  )
                         + ( (unsigned long long int) localAcquisitionTime[BYTE_5]       );
                 switch( sid )
                 {
                 case SID_NORM_SWF_F0:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_304 * T0_IN_FINETIME ;
                     break;
                 case SID_NORM_SWF_F1:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_304 * T1_IN_FINETIME ;
                     break;
                 case SID_NORM_SWF_F2:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_304 * T2_IN_FINETIME ;
                     break;
                 case SID_SBM1_CWF_F1:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_CWF * T1_IN_FINETIME ;
                     break;
                 case SID_SBM2_CWF_F2:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_CWF * T2_IN_FINETIME ;
                     break;
                 case SID_BURST_CWF_F2:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_CWF * T2_IN_FINETIME ;
                     break;
                 case SID_NORM_CWF_F3:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_CWF_SHORT_F3 * T3_IN_FINETIME ;
                     break;
                 case SID_NORM_CWF_LONG_F3:
                     deltaT = ( (double ) (pa_lfr_pkt_nr) ) * BLK_NR_CWF * T3_IN_FINETIME ;
                     break;
                 default:
                     PRINTF1("in compute_acquisition_time *** ERR unexpected sid %d\n", sid)
                             deltaT = 0.;
                     break;
                 }
                 acquisitionTimeAsLong = acquisitionTimeAsLong + (unsigned long long int) deltaT;
                 //
                 acquisitionTime[BYTE_0] = (unsigned char) (acquisitionTimeAsLong >> SHIFT_5_BYTES);
                 acquisitionTime[BYTE_1] = (unsigned char) (acquisitionTimeAsLong >> SHIFT_4_BYTES);
                 acquisitionTime[BYTE_2] = (unsigned char) (acquisitionTimeAsLong >> SHIFT_3_BYTES);
                 acquisitionTime[BYTE_3] = (unsigned char) (acquisitionTimeAsLong >> SHIFT_2_BYTES);
                 acquisitionTime[BYTE_4] = (unsigned char) (acquisitionTimeAsLong >> SHIFT_1_BYTE );
                 acquisitionTime[BYTE_5] = (unsigned char) (acquisitionTimeAsLong                 );
             }
             void build_snapshot_from_ring( ring_node *ring_node_to_send,
                                            unsigned char frequencyChannel,
                                            unsigned long long int acquisitionTimeF0_asLong,
                                            ring_node *ring_node_swf_extracted,
                                            int *swf_extracted)
             {
                 unsigned int i;
                 unsigned int node;
                 unsigned long long int centerTime_asLong;
                 unsigned long long int acquisitionTime_asLong;
                 unsigned long long int bufferAcquisitionTime_asLong;
                 unsigned char *ptr1;
                 unsigned char *ptr2;
                 unsigned char *timeCharPtr;
                 unsigned char nb_ring_nodes;
                 unsigned long long int frequency_asLong;
                 unsigned long long int nbTicksPerSample_asLong;
                 unsigned long long int nbSamplesPart1_asLong;
                 unsigned long long int sampleOffset_asLong;
                 unsigned int deltaT_F0;
                 unsigned int deltaT_F1;
                 unsigned long long int deltaT_F2;
                 deltaT_F0 = DELTAT_F0;
                 deltaT_F1 = DELTAF_F1;
                 deltaT_F2 = DELTAF_F2;
                 sampleOffset_asLong = INIT_CHAR;
                 // (1) get the f0 acquisition time => the value is passed in argument
                 // (2) compute the central reference time
                 centerTime_asLong = acquisitionTimeF0_asLong + deltaT_F0;
                 acquisitionTime_asLong = centerTime_asLong;         //set to default value (Don_Initialisation_P2)
                 bufferAcquisitionTime_asLong = centerTime_asLong;   //set to default value (Don_Initialisation_P2)
                 nbTicksPerSample_asLong = TICKS_PER_T2;             //set to default value (Don_Initialisation_P2)
                 // (3) compute the acquisition time of the current snapshot
                 switch(frequencyChannel)
                 {
                 case CHANNELF1: // 1 is for F1 = 4096 Hz
                     acquisitionTime_asLong = centerTime_asLong - deltaT_F1;
                     nb_ring_nodes = NB_RING_NODES_F1;
                     frequency_asLong = FREQ_F1;
                     nbTicksPerSample_asLong = TICKS_PER_T1;  // 65536 / 4096;
                     break;
                 case CHANNELF2: // 2 is for F2 = 256 Hz
                     acquisitionTime_asLong = centerTime_asLong - deltaT_F2;
                     nb_ring_nodes = NB_RING_NODES_F2;
                     frequency_asLong = FREQ_F2;
                     nbTicksPerSample_asLong = TICKS_PER_T2;  // 65536 / 256;
                     break;
                 default:
                     acquisitionTime_asLong = centerTime_asLong;
                     nb_ring_nodes = 0;
                     frequency_asLong = FREQ_F2;
                     nbTicksPerSample_asLong = TICKS_PER_T2;
                     break;
                 }
                 //*****************************************************************************
                 // (4) search the ring_node with the acquisition time <= acquisitionTime_asLong
                 node = 0;
                 while ( node < nb_ring_nodes)
                 {
                     //PRINTF1("%d ... ", node);
                     bufferAcquisitionTime_asLong = get_acquisition_time( (unsigned char *) &ring_node_to_send->coarseTime );
                     if (bufferAcquisitionTime_asLong <= acquisitionTime_asLong)
                     {
                         //PRINTF1("buffer found with acquisition time = %llx\n", bufferAcquisitionTime_asLong);
                         node = nb_ring_nodes;
                     }
                     else
                     {
                         node = node + 1;
                         ring_node_to_send = ring_node_to_send->previous;
                     }
                 }
                 // (5) compute the number of samples to take in the current buffer
                 sampleOffset_asLong = ((acquisitionTime_asLong - bufferAcquisitionTime_asLong) * frequency_asLong ) >> SHIFT_2_BYTES;
                 nbSamplesPart1_asLong = NB_SAMPLES_PER_SNAPSHOT - sampleOffset_asLong;
                 //PRINTF2("sampleOffset_asLong = %lld, nbSamplesPart1_asLong = %lld\n", sampleOffset_asLong, nbSamplesPart1_asLong);
                 // (6) compute the final acquisition time
                 acquisitionTime_asLong = bufferAcquisitionTime_asLong +
                         (sampleOffset_asLong * nbTicksPerSample_asLong);
                 // (7) copy the acquisition time at the beginning of the extrated snapshot
                 ptr1 = (unsigned char*) &acquisitionTime_asLong;
                 // fine time
                 ptr2 = (unsigned char*) &ring_node_swf_extracted->fineTime;
                 ptr2[BYTE_2] = ptr1[ BYTE_4 + OFFSET_2_BYTES ];
                 ptr2[BYTE_3] = ptr1[ BYTE_5 + OFFSET_2_BYTES ];
                 // coarse time
                 ptr2 = (unsigned char*) &ring_node_swf_extracted->coarseTime;
                 ptr2[BYTE_0] = ptr1[ BYTE_0 + OFFSET_2_BYTES ];
                 ptr2[BYTE_1] = ptr1[ BYTE_1 + OFFSET_2_BYTES ];
                 ptr2[BYTE_2] = ptr1[ BYTE_2 + OFFSET_2_BYTES ];
                 ptr2[BYTE_3] = ptr1[ BYTE_3 + OFFSET_2_BYTES ];
                 // re set the synchronization bit
                 timeCharPtr = (unsigned char*) &ring_node_to_send->coarseTime;
                 ptr2[0] = ptr2[0] | (timeCharPtr[0] & SYNC_BIT); // [1000 0000]
                 if ( (nbSamplesPart1_asLong >= NB_SAMPLES_PER_SNAPSHOT) | (nbSamplesPart1_asLong < 0) )
                 {
                     nbSamplesPart1_asLong = 0;
                 }
                 // copy the part 1 of the snapshot in the extracted buffer
                 for ( i = 0; i < (nbSamplesPart1_asLong * NB_WORDS_SWF_BLK); i++ )
                 {
                     swf_extracted[i] =
                             ((int*) ring_node_to_send->buffer_address)[ i + (sampleOffset_asLong * NB_WORDS_SWF_BLK) ];
                 }
                 // copy the part 2 of the snapshot in the extracted buffer
                 ring_node_to_send = ring_node_to_send->next;
                 for ( i = (nbSamplesPart1_asLong * NB_WORDS_SWF_BLK); i < (NB_SAMPLES_PER_SNAPSHOT * NB_WORDS_SWF_BLK); i++ )
                 {
                     swf_extracted[i] =
                             ((int*) ring_node_to_send->buffer_address)[ (i-(nbSamplesPart1_asLong * NB_WORDS_SWF_BLK)) ];
                 }
             }
             double computeCorrection( unsigned char *timePtr )
             {
                 unsigned long long int acquisitionTime;
                 unsigned long long int centerTime;
                 unsigned long long int previousTick;
                 unsigned long long int nextTick;
                 unsigned long long int deltaPreviousTick;
                 unsigned long long int deltaNextTick;
                 double deltaPrevious_ms;
                 double deltaNext_ms;
                 double correctionInF2;
                 correctionInF2 = 0; //set to default value (Don_Initialisation_P2)
                 // get acquisition time in fine time ticks
                 acquisitionTime = get_acquisition_time( timePtr );
                 // compute center time
                 centerTime = acquisitionTime + DELTAT_F0;    // (2048. / 24576. / 2.) * 65536. = 2730.667;
                 previousTick = centerTime - (centerTime & INT16_ALL_F);
                 nextTick = previousTick + TICKS_PER_S;
                 deltaPreviousTick   = centerTime - previousTick;
                 deltaNextTick       = nextTick - centerTime;
                 deltaPrevious_ms    = (((double) deltaPreviousTick) / TICKS_PER_S) * MS_PER_S;
                 deltaNext_ms        = (((double) deltaNextTick)     / TICKS_PER_S) * MS_PER_S;
                 PRINTF2("    delta previous = %.3f ms, delta next = %.2f ms\n", deltaPrevious_ms, deltaNext_ms);
                 // which tick is the closest?
                 if (deltaPreviousTick > deltaNextTick)
                 {
                     // the snapshot center is just before the second => increase delta_snapshot
                     correctionInF2 = + (deltaNext_ms * FREQ_F2 / MS_PER_S );
                 }
                 else
                 {
                     // the snapshot center is just after the second => decrease delta_snapshot
                     correctionInF2 = - (deltaPrevious_ms * FREQ_F2 / MS_PER_S );
                 }
                 PRINTF1("    correctionInF2 = %.2f\n", correctionInF2);
                 return correctionInF2;
             }
             void applyCorrection( double correction )
             {
                 int correctionInt;
                 correctionInt = 0;
                 if (correction >= 0.)
                 {
                     if ( (ONE_TICK_CORR_INTERVAL_0_MIN < correction) && (correction < ONE_TICK_CORR_INTERVAL_0_MAX) )
                     {
                         correctionInt = ONE_TICK_CORR;
                     }
                     else
                     {
                         correctionInt = CORR_MULT * floor(correction);
                     }
                 }
                 else
                 {
                     if ( (ONE_TICK_CORR_INTERVAL_1_MIN < correction) && (correction < ONE_TICK_CORR_INTERVAL_1_MAX) )
                     {
                         correctionInt = -ONE_TICK_CORR;
                     }
                     else
                     {
                         correctionInt =  CORR_MULT * ceil(correction);
                     }
                 }
                 waveform_picker_regs->delta_snapshot = waveform_picker_regs->delta_snapshot + correctionInt;
             }
             void snapshot_resynchronization( unsigned char *timePtr )
             {
                 /** This function compute a correction to apply on delta_snapshot.
                  *
                  *
                  * @param timePtr is a pointer to the acquisition time of the snapshot being considered.
                  *
                  * @return void
                  *
                  */
                 static double correction    = INIT_FLOAT;
                 static resynchro_state state = MEASURE;
                 static unsigned int nbSnapshots = 0;
                 int correctionInt;
                 correctionInt = 0;
                 switch (state)
                 {
                 case MEASURE:
                     // ********
                     PRINTF1("MEASURE === %d\n", nbSnapshots);
                     state = CORRECTION;
                     correction = computeCorrection( timePtr );
                     PRINTF1("MEASURE === correction = %.2f\n", correction );
                     applyCorrection( correction );
                     PRINTF1("MEASURE === delta_snapshot = %d\n", waveform_picker_regs->delta_snapshot);
                     //****
                     break;
                 case CORRECTION:
                     //************
                     PRINTF1("CORRECTION === %d\n", nbSnapshots);
                     state = MEASURE;
                     computeCorrection( timePtr );
                     set_wfp_delta_snapshot();
                     PRINTF1("CORRECTION === delta_snapshot = %d\n", waveform_picker_regs->delta_snapshot);
                     //****
                     break;
                 default:
                     break;
                 }
                 nbSnapshots++;
             }
             //**************
             // wfp registers
             void reset_wfp_burst_enable( void )
             {
                 /** This function resets the waveform picker burst_enable register.
                  *
                  * The burst bits [f2 f1 f0] and the enable bits [f3 f2 f1 f0] are set to 0.
                  *
                  */
                 // [1000 000] burst f2, f1, f0     enable f3, f2, f1, f0
                 waveform_picker_regs->run_burst_enable = waveform_picker_regs->run_burst_enable & RST_BITS_RUN_BURST_EN;
             }
             void reset_wfp_status( void )
             {
                 /** This function resets the waveform picker status register.
                  *
                  * All status bits are set to 0 [new_err full_err full].
                  *
                  */
                 waveform_picker_regs->status = INT16_ALL_F;
             }
             void reset_wfp_buffer_addresses( void )
             {
                 // F0
                 waveform_picker_regs->addr_data_f0_0 = current_ring_node_f0->previous->buffer_address;  // 0x08
                 waveform_picker_regs->addr_data_f0_1 = current_ring_node_f0->buffer_address;            // 0x0c
                 // F1
                 waveform_picker_regs->addr_data_f1_0 = current_ring_node_f1->previous->buffer_address;  // 0x10
                 waveform_picker_regs->addr_data_f1_1 = current_ring_node_f1->buffer_address;            // 0x14
                 // F2
                 waveform_picker_regs->addr_data_f2_0 = current_ring_node_f2->previous->buffer_address;  // 0x18
                 waveform_picker_regs->addr_data_f2_1 = current_ring_node_f2->buffer_address;            // 0x1c
                 // F3
                 waveform_picker_regs->addr_data_f3_0 = current_ring_node_f3->previous->buffer_address;  // 0x20
                 waveform_picker_regs->addr_data_f3_1 = current_ring_node_f3->buffer_address;            // 0x24
             }
             void reset_waveform_picker_regs( void )
             {
                 /** This function resets the waveform picker module registers.
                 *
                 * The registers affected by this function are located at the following offset addresses:
                 * - 0x00 data_shaping
                 * - 0x04 run_burst_enable
                 * - 0x08 addr_data_f0
                 * - 0x0C addr_data_f1
                 * - 0x10 addr_data_f2
                 * - 0x14 addr_data_f3
                 * - 0x18 status
                 * - 0x1C delta_snapshot
                 * - 0x20 delta_f0
                 * - 0x24 delta_f0_2
                 * - 0x28 delta_f1 (obsolet parameter)
                 * - 0x2c delta_f2
                 * - 0x30 nb_data_by_buffer
                 * - 0x34 nb_snapshot_param
                 * - 0x38 start_date
                 * - 0x3c nb_word_in_buffer
                 *
                 */
                 set_wfp_data_shaping();                                     // 0x00 *** R1 R0 SP1 SP0 BW
                 reset_wfp_burst_enable();                                   // 0x04 *** [run *** burst f2, f1, f0 *** enable f3, f2, f1, f0 ]
                 reset_wfp_buffer_addresses();
                 reset_wfp_status();                                         // 0x18
                 set_wfp_delta_snapshot();   // 0x1c *** 300 s => 0x12bff
                 set_wfp_delta_f0_f0_2();    // 0x20, 0x24
                 //the parameter delta_f1 [0x28] is not used anymore
                 set_wfp_delta_f2();         // 0x2c
                 DEBUG_PRINTF1("delta_snapshot %x\n",    waveform_picker_regs->delta_snapshot);
                 DEBUG_PRINTF1("delta_f0 %x\n",          waveform_picker_regs->delta_f0);
                 DEBUG_PRINTF1("delta_f0_2 %x\n",        waveform_picker_regs->delta_f0_2);
                 DEBUG_PRINTF1("delta_f1 %x\n",          waveform_picker_regs->delta_f1);
                 DEBUG_PRINTF1("delta_f2 %x\n",          waveform_picker_regs->delta_f2);
                 // 2688 = 8 * 336
                 waveform_picker_regs->nb_data_by_buffer = DFLT_WFP_NB_DATA_BY_BUFFER;   // 0x30 *** 2688 - 1 => nb samples -1
                 waveform_picker_regs->snapshot_param    = DFLT_WFP_SNAPSHOT_PARAM;      // 0x34 *** 2688 => nb samples
                 waveform_picker_regs->start_date        = COARSE_TIME_MASK;
                 //
                 // coarse time and fine time registers are not initialized, they are volatile
                 //
                 waveform_picker_regs->buffer_length     = DFLT_WFP_BUFFER_LENGTH;   // buffer length in burst = 3 * 2688 / 16 = 504 = 0x1f8
             }
             void set_wfp_data_shaping( void )
             {
                 /** This function sets the data_shaping register of the waveform picker module.
                  *
                  * The value is read from one field of the parameter_dump_packet structure:\n
                  * bw_sp0_sp1_r0_r1
                  *
                  */
                 unsigned char data_shaping;
                 // get the parameters for the data shaping [BW SP0 SP1 R0 R1] in sy_lfr_common1 and configure the register
                 // waveform picker : [R1 R0 SP1 SP0 BW]
                 data_shaping = parameter_dump_packet.sy_lfr_common_parameters;
                 waveform_picker_regs->data_shaping =
                         ( (data_shaping & BIT_5) >> SHIFT_5_BITS )      // BW
                         + ( (data_shaping & BIT_4) >> SHIFT_3_BITS )    // SP0
                         + ( (data_shaping & BIT_3) >> 1 )               // SP1
                         + ( (data_shaping & BIT_2) << 1 )               // R0
                         + ( (data_shaping & BIT_1) << SHIFT_3_BITS )    // R1
                         + ( (data_shaping & BIT_0) << SHIFT_5_BITS );   // R2
             }
             void set_wfp_burst_enable_register( unsigned char mode )
             {
                 /** This function sets the waveform picker burst_enable register depending on the mode.
                  *
                  * @param mode is the LFR mode to launch.
                  *
                  * The burst bits shall be before the enable bits.
                  *
                  */
                 // [0000 0000] burst f2, f1, f0 enable f3 f2 f1 f0
                 // the burst bits shall be set first, before the enable bits
                 switch(mode) {
                 case LFR_MODE_NORMAL:
                 case LFR_MODE_SBM1:
                 case LFR_MODE_SBM2:
                     waveform_picker_regs->run_burst_enable = RUN_BURST_ENABLE_SBM2;  // [0110 0000] enable f2 and f1 burst
                     waveform_picker_regs->run_burst_enable = waveform_picker_regs->run_burst_enable | BITS_WFP_ENABLE_ALL; // [1111] enable f3 f2 f1 f0
                     break;
                 case LFR_MODE_BURST:
                     waveform_picker_regs->run_burst_enable = RUN_BURST_ENABLE_BURST;  // [0100 0000] f2 burst enabled
                     waveform_picker_regs->run_burst_enable = waveform_picker_regs->run_burst_enable | BITS_WFP_ENABLE_BURST; // [1100] enable f3 and f2
                     break;
                 default:
                     waveform_picker_regs->run_burst_enable = INIT_CHAR;  // [0000 0000] no burst enabled, no waveform enabled
                     break;
                 }
             }
             void set_wfp_delta_snapshot( void )
             {
                 /** This function sets the delta_snapshot register of the waveform picker module.
                  *
                  * The value is read from two (unsigned char) of the parameter_dump_packet structure:
                  * - sy_lfr_n_swf_p[0]
                  * - sy_lfr_n_swf_p[1]
                  *
                  */
                 unsigned int delta_snapshot;
                 unsigned int delta_snapshot_in_T2;
                 delta_snapshot = (parameter_dump_packet.sy_lfr_n_swf_p[0] * CONST_256)
                         + parameter_dump_packet.sy_lfr_n_swf_p[1];
                 delta_snapshot_in_T2 = delta_snapshot * FREQ_F2;
                 waveform_picker_regs->delta_snapshot = delta_snapshot_in_T2 - 1;    // max 4 bytes
             }
             void set_wfp_delta_f0_f0_2( void )
             {
                 unsigned int delta_snapshot;
                 unsigned int nb_samples_per_snapshot;
                 float delta_f0_in_float;
                 delta_snapshot = waveform_picker_regs->delta_snapshot;
                 nb_samples_per_snapshot = (parameter_dump_packet.sy_lfr_n_swf_l[0] * CONST_256) + parameter_dump_packet.sy_lfr_n_swf_l[1];
                 delta_f0_in_float = (nb_samples_per_snapshot / 2.) * ( (1. / FREQ_F2) - (1. / FREQ_F0) ) * FREQ_F2;
                 waveform_picker_regs->delta_f0      = delta_snapshot - floor( delta_f0_in_float );
-                waveform_picker_regs->delta_f0_2    = DFLT_WFP_DELTA_F0_2; // 48 = 11 0000, max 7 bits
+                waveform_picker_regs->delta_f0_2    = DFLT_WFP_DELTA_F0_2;
             }
             void set_wfp_delta_f1( void )
             {
                 /** Sets the value of the delta_f1 parameter
                  *
                  * @param void
                  *
                  * @return void
                  *
                  * delta_f1 is not used, the snapshots are extracted from CWF_F1 waveforms.
                  *
                  */
                 unsigned int delta_snapshot;
                 unsigned int nb_samples_per_snapshot;
                 float delta_f1_in_float;
                 delta_snapshot = waveform_picker_regs->delta_snapshot;
                 nb_samples_per_snapshot = (parameter_dump_packet.sy_lfr_n_swf_l[0] * CONST_256) + parameter_dump_packet.sy_lfr_n_swf_l[1];
                 delta_f1_in_float = (nb_samples_per_snapshot / 2.) * ( (1. / FREQ_F2) - (1. / FREQ_F1) ) * FREQ_F2;
                 waveform_picker_regs->delta_f1 = delta_snapshot - floor( delta_f1_in_float );
             }
             void set_wfp_delta_f2( void )   // parameter not used, only delta_f0 and delta_f0_2 are used
             {
                 /** Sets the value of the delta_f2 parameter
                  *
                  * @param void
                  *
                  * @return void
                  *
                  * delta_f2 is used only for the first snapshot generation, even when the snapshots are extracted from CWF_F2
                  * waveforms (see lpp_waveform_snapshot_controler.vhd for details).
                  *
                  */
                 unsigned int delta_snapshot;
                 unsigned int nb_samples_per_snapshot;
                 delta_snapshot = waveform_picker_regs->delta_snapshot;
                 nb_samples_per_snapshot = (parameter_dump_packet.sy_lfr_n_swf_l[0] * CONST_256) + parameter_dump_packet.sy_lfr_n_swf_l[1];
                 waveform_picker_regs->delta_f2 = delta_snapshot - (nb_samples_per_snapshot / 2) - 1;
             }
             //*****************
             // local parameters
             void increment_seq_counter_source_id( unsigned char *packet_sequence_control, unsigned int sid )
             {
                 /** This function increments the parameter "sequence_cnt" depending on the sid passed in argument.
                  *
                  * @param packet_sequence_control is a pointer toward the parameter sequence_cnt to update.
                  * @param sid is the source identifier of the packet being updated.
                  *
                  * REQ-LFR-SRS-5240 / SSS-CP-FS-590
                  * The sequence counters shall wrap around from 2^14 to zero.
                  * The sequence counter shall start at zero at startup.
                  *
                  * REQ-LFR-SRS-5239 / SSS-CP-FS-580
                  * All TM_LFR_SCIENCE_ packets are sent to ground, i.e. destination id = 0
                  *
                  */
                 unsigned short *sequence_cnt;
                 unsigned short segmentation_grouping_flag;
                 unsigned short new_packet_sequence_control;
                 rtems_mode initial_mode_set;
                 rtems_mode current_mode_set;
                 rtems_status_code status;
                 initial_mode_set = RTEMS_DEFAULT_MODES;
                 current_mode_set = RTEMS_DEFAULT_MODES;
                 sequence_cnt = NULL;
                 //******************************************
                 // CHANGE THE MODE OF THE CALLING RTEMS TASK
                 status =  rtems_task_mode( RTEMS_NO_PREEMPT, RTEMS_PREEMPT_MASK, &initial_mode_set );
                 if ( (sid == SID_NORM_SWF_F0)    || (sid == SID_NORM_SWF_F1) || (sid == SID_NORM_SWF_F2)
                      || (sid == SID_NORM_CWF_F3) || (sid == SID_NORM_CWF_LONG_F3)
                      || (sid == SID_BURST_CWF_F2)
                      || (sid == SID_NORM_ASM_F0) || (sid == SID_NORM_ASM_F1) || (sid == SID_NORM_ASM_F2)
                      || (sid == SID_NORM_BP1_F0) || (sid == SID_NORM_BP1_F1) || (sid == SID_NORM_BP1_F2)
                      || (sid == SID_NORM_BP2_F0) || (sid == SID_NORM_BP2_F1) || (sid == SID_NORM_BP2_F2)
                      || (sid == SID_BURST_BP1_F0) || (sid == SID_BURST_BP2_F0)
                      || (sid == SID_BURST_BP1_F1) || (sid == SID_BURST_BP2_F1) )
                 {
                     sequence_cnt = (unsigned short *) &sequenceCounters_SCIENCE_NORMAL_BURST;
                 }
                 else if ( (sid ==SID_SBM1_CWF_F1) || (sid ==SID_SBM2_CWF_F2)
                           || (sid == SID_SBM1_BP1_F0) || (sid == SID_SBM1_BP2_F0)
                           || (sid == SID_SBM2_BP1_F0) || (sid == SID_SBM2_BP2_F0)
                           || (sid == SID_SBM2_BP1_F1) || (sid == SID_SBM2_BP2_F1) )
                 {
                     sequence_cnt = (unsigned short *) &sequenceCounters_SCIENCE_SBM1_SBM2;
                 }
                 else
                 {
                     sequence_cnt = (unsigned short *) NULL;
                     PRINTF1("in increment_seq_counter_source_id *** ERR apid_destid %d not known\n", sid)
                 }
                 if (sequence_cnt != NULL)
                 {
                     segmentation_grouping_flag  = TM_PACKET_SEQ_CTRL_STANDALONE << SHIFT_1_BYTE;
                     *sequence_cnt                = (*sequence_cnt) & SEQ_CNT_MASK;
                     new_packet_sequence_control = segmentation_grouping_flag | (*sequence_cnt) ;
                     packet_sequence_control[0] = (unsigned char) (new_packet_sequence_control >> SHIFT_1_BYTE);
                     packet_sequence_control[1] = (unsigned char) (new_packet_sequence_control     );
                     // increment the sequence counter
                     if ( *sequence_cnt < SEQ_CNT_MAX)
                     {
                         *sequence_cnt = *sequence_cnt + 1;
                     }
                     else
                     {
                         *sequence_cnt = 0;
                     }
                 }
                 //*************************************
                 // RESTORE THE MODE OF THE CALLING TASK
                 status =  rtems_task_mode( initial_mode_set, RTEMS_PREEMPT_MASK, &current_mode_set );
             }

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