gnss-sdr/src/algorithms/telemetry_decoder/libs/gps_l1_ca_subframe_fsm.cc

#include "gps_l1_ca_subframe_fsm.h"

//************ GPS WORD TO SUBFRAME DECODER STATE MACHINE **********

struct Ev_gps_word_valid : sc::event<Ev_gps_word_valid> {};
struct Ev_gps_word_invalid : sc::event<Ev_gps_word_invalid>{};
struct Ev_gps_word_preamble : sc::event<Ev_gps_word_preamble>{};

struct gps_subframe_fsm_S0: public sc::state<gps_subframe_fsm_S0, GpsL1CaSubframeFsm > {
public:
  // sc::transition(evento,estado_destino)
  typedef sc::transition< Ev_gps_word_preamble, gps_subframe_fsm_S1 > reactions;
  gps_subframe_fsm_S0(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S0 "<<std::endl;
  }
};
struct gps_subframe_fsm_S1: public sc::state<gps_subframe_fsm_S1, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S2 > > reactions;

  gps_subframe_fsm_S1(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S1 "<<std::endl;
  }
};

struct gps_subframe_fsm_S2: public sc::state<gps_subframe_fsm_S2, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S3 > > reactions;

  gps_subframe_fsm_S2(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S2 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(0);
  }
};
struct gps_subframe_fsm_S3: public sc::state<gps_subframe_fsm_S3, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S4 > > reactions;

  gps_subframe_fsm_S3(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S3 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(1);
  }
};
struct gps_subframe_fsm_S4: public sc::state<gps_subframe_fsm_S4, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S5 > > reactions;

  gps_subframe_fsm_S4(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S4 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(2);
  }
};
struct gps_subframe_fsm_S5: public sc::state<gps_subframe_fsm_S5, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S6 > > reactions;

  gps_subframe_fsm_S5(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S5 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(3);
  }
};
struct gps_subframe_fsm_S6: public sc::state<gps_subframe_fsm_S6, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S7 > > reactions;

  gps_subframe_fsm_S6(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S6 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(4);
  }
};
struct gps_subframe_fsm_S7: public sc::state<gps_subframe_fsm_S7, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S8 > > reactions;

  gps_subframe_fsm_S7(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S7 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(5);
  }
};
struct gps_subframe_fsm_S8: public sc::state<gps_subframe_fsm_S8, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S9 > > reactions;

  gps_subframe_fsm_S8(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S8 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(6);
  }
};
struct gps_subframe_fsm_S9: public sc::state<gps_subframe_fsm_S9, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S10 > > reactions;

  gps_subframe_fsm_S9(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S9 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(7);
  }
};
struct gps_subframe_fsm_S10: public sc::state<gps_subframe_fsm_S10, GpsL1CaSubframeFsm > {
public:
  typedef mpl::list<sc::transition< Ev_gps_word_invalid, gps_subframe_fsm_S0 >,
  sc::transition< Ev_gps_word_valid, gps_subframe_fsm_S11 > > reactions;

  gps_subframe_fsm_S10(my_context ctx): my_base( ctx ){
    //std::cout<<"Enter S10 "<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(8);
  }
};
struct gps_subframe_fsm_S11: public sc::state<gps_subframe_fsm_S11, GpsL1CaSubframeFsm > {
public:
  typedef sc::transition< Ev_gps_word_preamble, gps_subframe_fsm_S1 > reactions;

  gps_subframe_fsm_S11(my_context ctx): my_base( ctx ){
    //std::cout<<"Completed GPS Subframe!"<<std::endl;
    context< GpsL1CaSubframeFsm >().gps_word_to_subframe(9);
    context< GpsL1CaSubframeFsm >().gps_subframe_to_nav_msg(); //decode the subframe
    // DECODE SUBFRAME
    //std::cout<<"Enter S11"<<std::endl;
  }
};

GpsL1CaSubframeFsm::GpsL1CaSubframeFsm()
{
  d_nav.reset();
  initiate(); //start the FSM
}

void GpsL1CaSubframeFsm::gps_word_to_subframe(int position)
{
  // insert the word in the correct position of the subframe
  std::memcpy(&d_subframe[position*GPS_WORD_LENGTH],&d_GPS_frame_4bytes,sizeof(char)*GPS_WORD_LENGTH);
}

void GpsL1CaSubframeFsm::gps_subframe_to_nav_msg()
{
  int subframe_ID;
  // NEW GPS SUBFRAME HAS ARRIVED!

  subframe_ID=d_nav.subframe_decoder(this->d_subframe); //decode the subframe

  d_nav.d_satellite_PRN=d_satellite_PRN;
  d_nav.d_channel_ID=d_channel_ID;
  if (subframe_ID==1) {
    d_nav.d_subframe1_timestamp_ms=this->d_preamble_time_ms-6002;
    std::cout<<"FSM: set subframe1 preamble timestamp for sat "<<d_nav.d_satellite_PRN<<std::endl;
  }
  //TODO: change to subframe 5
  if (subframe_ID==3) { // if the subframe is the 5th, then
    if (d_nav.satellite_validation()) // if all the satellite ephemeris parameters are good, then
      {
        // Send the procesed satellite ephemeris packet
        d_nav_queue->push(d_nav);
      }
  }

}

void GpsL1CaSubframeFsm::Event_gps_word_valid()
{
  this->process_event(Ev_gps_word_valid());
}

void GpsL1CaSubframeFsm::Event_gps_word_invalid()
{
  this->process_event(Ev_gps_word_invalid());
}

void GpsL1CaSubframeFsm::Event_gps_word_preamble()
{
  this->process_event(Ev_gps_word_preamble());
}