nps_main_sitl.c

Go to the documentation of this file.

/*
 * Copyright (C) 2009 Antoine Drouin <poinix@gmail.com>
 * Copyright (C) 2012 The Paparazzi Team
 * Copyright (C) 2016 Michal Podhradsky <http://github.com/podhrmic>
 *
 * This file is part of paparazzi.
 *
 * paparazzi is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2, or (at your option)
 * any later version.
 *
 * paparazzi is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with paparazzi; see the file COPYING.  If not, write to
 * the Free Software Foundation, 59 Temple Place - Suite 330,
 * Boston, MA 02111-1307, USA.
 */
 
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/time.h>
 
#include "nps_main.h"
#include "nps_fdm.h"
 
 
 
 
int main(int argc, char **argv)
{
  if (nps_main_init(argc, argv)) {
    return 1;
  }
 
  if (nps_main.fg_host) {
    pthread_create(&th_flight_gear, NULL, nps_flight_gear_loop, NULL);
  }
  pthread_create(&th_display_ivy, NULL, nps_main_display, NULL);
  pthread_create(&th_main_loop, NULL, nps_main_loop, NULL);
  pthread_join(th_main_loop, NULL);
 
  return 0;
}
int main(int argc, char **argv) {…}
 
 
void nps_update_launch_from_dl(uint8_t value __attribute__((unused))) {}
 
 
void nps_radio_and_autopilot_init(void)
{
  enum NpsRadioControlType rc_type;
  char *rc_dev = NULL;
  if (nps_main.norc) {
    rc_type = NORC;
  } else if (nps_main.js_dev) {
    rc_type = JOYSTICK;
    rc_dev = nps_main.js_dev;
  } else if (nps_main.spektrum_dev) {
    rc_type = SPEKTRUM;
    rc_dev = nps_main.spektrum_dev;
  } else {
    rc_type = SCRIPT;
  }
  nps_autopilot_init(rc_type, nps_main.rc_script, rc_dev);
}
void nps_radio_and_autopilot_init(void) {…}
 
 
void nps_main_run_sim_step(void)
{
  nps_atmosphere_update(SIM_DT);
 
  nps_autopilot_run_systime_step();
 
  nps_fdm_run_step(nps_autopilot.launch, nps_autopilot.commands, NPS_COMMANDS_NB);
 
  nps_sensors_run_step(nps_main.sim_time);
 
  nps_autopilot_run_step(nps_main.sim_time);
 
}
void nps_main_run_sim_step(void) {…}
 
 
void *nps_main_loop(void *data __attribute__((unused)))
{
  struct timespec requestStart;
  struct timespec requestEnd;
  struct timespec waitFor;
  long int period_ns = HOST_TIMEOUT_MS * 1000000LL; // thread period in nanoseconds
  long int task_ns = 0; // time it took to finish the task in nanoseconds
 
  struct timeval tv_now;
  double  host_time_now;
 
  while (TRUE) {
    if (pauseSignal) {
      char line[128];
      double tf = 1.0;
      double t1, t2, irt;
 
      gettimeofday(&tv_now, NULL);
      t1 = time_to_double(&tv_now);
      // unscale to initial real time
      irt = t1 - (t1 - nps_main.scaled_initial_time) * nps_main.host_time_factor;
 
      printf("Press <enter> to continue (or CTRL-Z to suspend).\nEnter a new time factor if needed (current: %f): ",
             nps_main.host_time_factor);
      fflush(stdout);
      if (fgets(line, 127, stdin)) {
        if ((sscanf(line, " %le ", &tf) == 1)) {
          if (tf > 0 && tf < 1000) {
            nps_main.host_time_factor = tf;
          }
        }
        printf("Time factor is %f\n", nps_main.host_time_factor);
      }
      gettimeofday(&tv_now, NULL);
      t2 = time_to_double(&tv_now);
      // add the pause to initial real time
      irt += t2 - t1;
      nps_main.real_initial_time += t2 - t1;
      // convert to scaled initial real time
      nps_main.scaled_initial_time = t2 - (t2 - irt) / nps_main.host_time_factor;
      pauseSignal = 0;
    }
 
    clock_get_current_time(&requestStart); // init measurement (after the pause signal)
 
    gettimeofday(&tv_now, NULL);
    host_time_now = time_to_double(&tv_now);
    double host_time_elapsed = nps_main.host_time_factor * (host_time_now  - nps_main.scaled_initial_time);
 
#if DEBUG_NPS_TIME
    printf("%f,%f,%f,%f,%f,%f,", nps_main.host_time_factor, host_time_elapsed, host_time_now, nps_main.scaled_initial_time,
           nps_main.sim_time, nps_main.display_time);
#endif
 
    int cnt = 0;
    static int prev_cnt = 0;
    static int grow_cnt = 0;
    while (nps_main.sim_time <= host_time_elapsed) {
      pthread_mutex_lock(&fdm_mutex);
      nps_main_run_sim_step();
      nps_main.sim_time += SIM_DT;
      pthread_mutex_unlock(&fdm_mutex);
      cnt++;
    }
 
    // Check to make sure the simulation doesn't get too far behind real time looping
    if (cnt > (prev_cnt)) {grow_cnt++;}
    else { grow_cnt--;}
    if (grow_cnt < 0) {grow_cnt = 0;}
    prev_cnt = cnt;
 
    if (grow_cnt > 10) {
      printf("Warning: The time factor is too large for efficient operation! Please reduce the time factor.\n");
    }
 
#if DEBUG_NPS_TIME
    printf("%f,%f\n", nps_main.sim_time, nps_main.display_time);
#endif
 
    clock_get_current_time(&requestEnd); // end measurement
 
    // Calculate time it took
    task_ns = (requestEnd.tv_sec - requestStart.tv_sec) * 1000000000L + (requestEnd.tv_nsec - requestStart.tv_nsec);
 
    if (task_ns > 0) {
      waitFor.tv_sec = 0;
      waitFor.tv_nsec = period_ns - task_ns;
      nanosleep(&waitFor, NULL);
    } else {
      // task took longer than the period
#ifdef PRINT_TIME
      printf("MAIN THREAD: task took longer than one period, exactly %f [ms], but the period is %f [ms]\n",
             (double)task_ns / 1E6, (double)period_ns / 1E6);
#endif
    }
  }
  return(NULL);
}
void *nps_main_loop(void *data __attribute__((unused))) {…}