sensors.cpp

Go to the documentation of this file.

/*
 * Copyright (c) 2017, James Jackson, Daniel Koch, and Craig Bidstrup,
 * BYU MAGICC Lab
 *
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 * * Redistributions of source code must retain the above copyright notice, this
 *   list of conditions and the following disclaimer.
 *
 * * Redistributions in binary form must reproduce the above copyright notice,
 *   this list of conditions and the following disclaimer in the documentation
 *   and/or other materials provided with the distribution.
 *
 * * Neither the name of the copyright holder nor the names of its
 *   contributors may be used to endorse or promote products derived from
 *   this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
 * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#include <stdbool.h>
#include <stdint.h>
#include <math.h>

#include "sensors.h"
#include "rosflight.h"

#include <turbomath/turbomath.h>

namespace rosflight_firmware
{

const float Sensors::BARO_MAX_CHANGE_RATE = 200.0f;    // approx 200 m/s
const float Sensors::BARO_SAMPLE_RATE = 50.0f;
const float Sensors::DIFF_MAX_CHANGE_RATE = 225.0f;      // approx 15 m/s^2
const float Sensors::DIFF_SAMPLE_RATE = 50.0f;
const float Sensors::SONAR_MAX_CHANGE_RATE = 100.0f;    // 100 m/s
const float Sensors::SONAR_SAMPLE_RATE = 50.0f;

const int Sensors::SENSOR_CAL_DELAY_CYCLES = 128;
const int Sensors::SENSOR_CAL_CYCLES = 127;

const float Sensors::BARO_MAX_CALIBRATION_VARIANCE = 25.0;   // standard dev about 0.2 m
const float Sensors::DIFF_PRESSURE_MAX_CALIBRATION_VARIANCE = 100.0;   // standard dev about 3 m/s

Sensors::Sensors(ROSflight &rosflight) :
  rf_(rosflight)
{}

void Sensors::init()
{
  rf_.params_.add_callback([this](uint16_t param_id)
  {
    this->param_change_callback(param_id);
  }, PARAM_FC_ROLL);
  rf_.params_.add_callback([this](uint16_t param_id)
  {
    this->param_change_callback(param_id);
  }, PARAM_FC_PITCH);
  rf_.params_.add_callback([this](uint16_t param_id)
  {
    this->param_change_callback(param_id);
  }, PARAM_FC_YAW);

  new_imu_data_ = false;

  // clear the IMU read error
  rf_.state_manager_.clear_error(StateManager::ERROR_IMU_NOT_RESPONDING);
  rf_.board_.sensors_init();

  init_imu();

  next_sensor_to_update_ = BAROMETER;

  float alt = rf_.params_.get_param_float(PARAM_GROUND_LEVEL);
  ground_pressure_ = 101325.0f*static_cast<float>(pow((1-2.25694e-5 * alt), 5.2553));

  baro_outlier_filt_.init(BARO_MAX_CHANGE_RATE, BARO_SAMPLE_RATE, ground_pressure_);
  diff_outlier_filt_.init(DIFF_MAX_CHANGE_RATE, DIFF_SAMPLE_RATE, 0.0f);
  sonar_outlier_filt_.init(SONAR_MAX_CHANGE_RATE, SONAR_SAMPLE_RATE, 0.0f);
  int_start_us_ = rf_.board_.clock_micros();
}

void Sensors::init_imu()
{
  // Quaternion to compensate for FCU orientation
  float roll = rf_.params_.get_param_float(PARAM_FC_ROLL) * 0.017453293;
  float pitch = rf_.params_.get_param_float(PARAM_FC_PITCH) * 0.017453293;
  float yaw = rf_.params_.get_param_float(PARAM_FC_YAW) * 0.017453293;
  data_.fcu_orientation = turbomath::Quaternion(roll, pitch, yaw);

  // See if the IMU is uncalibrated, and throw an error if it is
  if (rf_.params_.get_param_float(PARAM_ACC_X_BIAS) == 0.0 && rf_.params_.get_param_float(PARAM_ACC_Y_BIAS) == 0.0 &&
      rf_.params_.get_param_float(PARAM_ACC_Z_BIAS) == 0.0 && rf_.params_.get_param_float(PARAM_GYRO_X_BIAS) == 0.0 &&
      rf_.params_.get_param_float(PARAM_GYRO_Y_BIAS) == 0.0 && rf_.params_.get_param_float(PARAM_GYRO_Z_BIAS) == 0.0)
  {
    rf_.state_manager_.set_error(StateManager::ERROR_UNCALIBRATED_IMU);
  }
}

void Sensors::param_change_callback(uint16_t param_id)
{
  (void) param_id; // suppress unused parameter warning
  init_imu();
}


bool Sensors::run(void)
{
  // First, check for new IMU data
  bool got_imu = update_imu();

  // Look for sensors that may not have been recognized at start because they weren't attached
  // to the 5V rail (only if disarmed)
  if (!rf_.state_manager_.state().armed)
    look_for_disabled_sensors();

  // Update other sensors
  update_other_sensors();
  return got_imu;
}


void Sensors::update_other_sensors()
{
  switch (next_sensor_to_update_)
  {
  case GNSS:
    if (rf_.board_.gnss_present() && rf_.board_.gnss_has_new_data())
    {
      data_.gnss_present = true;
      data_.gnss_new_data = true;
      rf_.board_.gnss_update();
      this->data_.gnss_data = rf_.board_.gnss_read();
      this->data_.gnss_raw = rf_.board_.gnss_raw_read();
    }
    break;
  case BAROMETER:
    if (rf_.board_.baro_present())
    {
      data_.baro_present = true;
      rf_.board_.baro_update();
      float raw_pressure;
      float raw_temp;
      rf_.board_.baro_read(&raw_pressure, &raw_temp);
      data_.baro_valid = baro_outlier_filt_.update(raw_pressure, &data_.baro_pressure);
      if (data_.baro_valid)
      {
        data_.baro_temperature = raw_temp;
        correct_baro();
      }
    }
    break;
  case MAGNETOMETER:
    if (rf_.board_.mag_present())
    {
      data_.mag_present = true;
      float mag[3];
      rf_.board_.mag_update();
      rf_.board_.mag_read(mag);
      data_.mag.x = mag[0];
      data_.mag.y = mag[1];
      data_.mag.z = mag[2];
      correct_mag();
    }
    break;

  case DIFF_PRESSURE:
    if (rf_.board_.diff_pressure_present() || data_.diff_pressure_present)
    {
      // if diff_pressure is currently present OR if it has historically been
      //   present (diff_pressure_present default is false)
      rf_.board_.diff_pressure_update(); //update assists in recovering sensor if it temporarily disappears

      if (rf_.board_.diff_pressure_present())
      {
        data_.diff_pressure_present = true;
        float raw_pressure;
        float raw_temp;
        rf_.board_.diff_pressure_read(&raw_pressure, &raw_temp);
        data_.diff_pressure_valid = diff_outlier_filt_.update(raw_pressure, &data_.diff_pressure);
        if (data_.diff_pressure_valid)
        {
          data_.diff_pressure_temp = raw_temp;
          correct_diff_pressure();
        }
      }
    }
    break;

  case SONAR:
    if (rf_.board_.sonar_present())
    {
      data_.sonar_present = true;
      float raw_distance;
      rf_.board_.sonar_update();
      raw_distance = rf_.board_.sonar_read();
      data_.sonar_range_valid = sonar_outlier_filt_.update(raw_distance, &data_.sonar_range);
    }
    break;
  default:
    break;
  }
  next_sensor_to_update_ = (next_sensor_to_update_ + 1) % NUM_LOW_PRIORITY_SENSORS;
}


void Sensors::look_for_disabled_sensors()
{
  // Look for disabled sensors while disarmed (poll every second)
  // These sensors need power to respond, so they might not have been
  // detected on startup, but will be detected whenever power is applied
  // to the 5V rail.
  if (rf_.board_.clock_millis() > last_time_look_for_disarmed_sensors_ + 1000)
  {
    last_time_look_for_disarmed_sensors_ = rf_.board_.clock_millis();
    rf_.board_.baro_update();
    rf_.board_.mag_update();
    rf_.board_.diff_pressure_update();
    rf_.board_.sonar_update();
  }
}

bool Sensors::start_imu_calibration(void)
{
  start_gyro_calibration();

  calibrating_acc_flag_ = true;
  rf_.params_.set_param_float(PARAM_ACC_X_BIAS, 0.0);
  rf_.params_.set_param_float(PARAM_ACC_Y_BIAS, 0.0);
  rf_.params_.set_param_float(PARAM_ACC_Z_BIAS, 0.0);
  return true;
}

bool Sensors::start_gyro_calibration(void)
{
  calibrating_gyro_flag_ = true;
  rf_.params_.set_param_float(PARAM_GYRO_X_BIAS, 0.0);
  rf_.params_.set_param_float(PARAM_GYRO_Y_BIAS, 0.0);
  rf_.params_.set_param_float(PARAM_GYRO_Z_BIAS, 0.0);
  return true;
}

bool Sensors::start_baro_calibration()
{
  baro_calibration_mean_ = 0.0f;
  baro_calibration_var_ = 0.0f;
  baro_calibration_count_ = 0;
  baro_calibrated_ = false;
  rf_.params_.set_param_float(PARAM_BARO_BIAS, 0.0f);
  return true;
}

bool Sensors::start_diff_pressure_calibration()
{
  diff_pressure_calibration_mean_ = 0.0f;
  diff_pressure_calibration_var_ = 0.0f;
  diff_pressure_calibration_count_ = 0;
  diff_pressure_calibrated_ = false;
  rf_.params_.set_param_float(PARAM_DIFF_PRESS_BIAS, 0.0f);
  return true;
}

bool Sensors::gyro_calibration_complete(void)
{
  return !calibrating_gyro_flag_;
}

//==================================================================
// local function definitions
bool Sensors::update_imu(void)
{
  if (rf_.board_.new_imu_data())
  {
    rf_.state_manager_.clear_error(StateManager::ERROR_IMU_NOT_RESPONDING);
    last_imu_update_ms_ = rf_.board_.clock_millis();
    if (!rf_.board_.imu_read(accel_, &data_.imu_temperature, gyro_, &data_.imu_time))
      return false;

    // Move data into local copy
    data_.accel.x = accel_[0];
    data_.accel.y = accel_[1];
    data_.accel.z = accel_[2];

    data_.accel = data_.fcu_orientation * data_.accel;

    data_.gyro.x = gyro_[0];
    data_.gyro.y = gyro_[1];
    data_.gyro.z = gyro_[2];

    data_.gyro = data_.fcu_orientation * data_.gyro;

    if (calibrating_acc_flag_)
      calibrate_accel();
    if (calibrating_gyro_flag_)
      calibrate_gyro();

    // Apply bias correction
    correct_imu();

    // Integrate for filtered IMU
    float dt = (data_.imu_time - prev_imu_read_time_us_) * 1e-6;
    accel_int_ += dt * data_.accel;
    gyro_int_ += dt * data_.gyro;
    prev_imu_read_time_us_ = data_.imu_time;

    return true;
  }
  else
  {
    // if we have lost 10 IMU messages then something is wrong
    // However, because we look for disabled sensors while disarmed,
    // we get IMU timeouts, which last for at least 10 ms.  Therefore
    // we have an adjustable imu_timeout.
    int imu_timeout = rf_.state_manager_.state().armed ? 10 : 1000;
    if (rf_.board_.clock_millis() > last_imu_update_ms_ + imu_timeout)
    {
      // Tell the board to fix it
      last_imu_update_ms_ = rf_.board_.clock_millis();
      if (!rf_.state_manager_.state().armed)
        rf_.board_.imu_not_responding_error();

      // Indicate an IMU error
      rf_.state_manager_.set_error(StateManager::ERROR_IMU_NOT_RESPONDING);
    }
    return false;
  }
}


void Sensors::get_filtered_IMU(turbomath::Vector &accel, turbomath::Vector &gyro, uint64_t &stamp_us)
{
  float delta_t = (data_.imu_time - int_start_us_)*1e-6;
  accel = accel_int_ / delta_t;
  gyro = gyro_int_ / delta_t;
  accel_int_ *= 0.0;
  gyro_int_ *= 0.0;
  int_start_us_ = data_.imu_time;
  stamp_us = data_.imu_time;
}

//======================================================================
// Calibration Functions
void Sensors::calibrate_gyro()
{
  gyro_sum_ += data_.gyro;
  gyro_calibration_count_++;

  if (gyro_calibration_count_ > 1000)
  {
    // Gyros are simple.  Just find the average during the calibration
    turbomath::Vector gyro_bias = gyro_sum_ / static_cast<float>(gyro_calibration_count_);

    if (gyro_bias.norm() < 1.0)
    {
      rf_.params_.set_param_float(PARAM_GYRO_X_BIAS, gyro_bias.x);
      rf_.params_.set_param_float(PARAM_GYRO_Y_BIAS, gyro_bias.y);
      rf_.params_.set_param_float(PARAM_GYRO_Z_BIAS, gyro_bias.z);

      // Tell the estimator to reset it's bias estimate, because it should be zero now
      rf_.estimator_.reset_adaptive_bias();

      // Tell the state manager that we just completed a gyro calibration
      rf_.state_manager_.set_event(StateManager::EVENT_CALIBRATION_COMPLETE);
    }
    else
    {
      // Tell the state manager that we just failed a gyro calibration
      rf_.state_manager_.set_event(StateManager::EVENT_CALIBRATION_FAILED);
      rf_.comm_manager_.log(CommLink::LogSeverity::LOG_ERROR, "Too much movement for gyro cal");
    }

    // reset calibration in case we do it again
    calibrating_gyro_flag_ = false;
    gyro_calibration_count_ = 0;
    gyro_sum_.x = 0.0f;
    gyro_sum_.y = 0.0f;
    gyro_sum_.z = 0.0f;
  }
}

turbomath::Vector vector_max(turbomath::Vector a, turbomath::Vector b)
{
  return turbomath::Vector(a.x > b.x ? a.x : b.x,
                           a.y > b.y ? a.y : b.y,
                           a.z > b.z ? a.z : b.z);
}

turbomath::Vector vector_min(turbomath::Vector a, turbomath::Vector b)
{
  return turbomath::Vector(a.x < b.x ? a.x : b.x,
                           a.y < b.y ? a.y : b.y,
                           a.z < b.z ? a.z : b.z);
}


void Sensors::calibrate_accel(void)
{
  acc_sum_ = acc_sum_ + data_.accel + gravity_;
  acc_temp_sum_ += data_.imu_temperature;
  max_ = vector_max(max_, data_.accel);
  min_ = vector_min(min_, data_.accel);
  accel_calibration_count_++;

  if (accel_calibration_count_ > 1000)
  {
    // The temperature bias is calculated using a least-squares regression.
    // This is computationally intensive, so it is done by the onboard computer in
    // fcu_io and shipped over to the flight controller.
    turbomath::Vector accel_temp_bias =
    {
      rf_.params_.get_param_float(PARAM_ACC_X_TEMP_COMP),
      rf_.params_.get_param_float(PARAM_ACC_Y_TEMP_COMP),
      rf_.params_.get_param_float(PARAM_ACC_Z_TEMP_COMP)
    };

    // Figure out the proper accel bias.
    // We have to consider the contribution of temperature during the calibration,
    // Which is why this line is so confusing. What we are doing, is first removing
    // the contribution of temperature to the measurements during the calibration,
    // Then we are dividing by the number of measurements.
    turbomath::Vector accel_bias = (acc_sum_ - (accel_temp_bias * acc_temp_sum_)) /
                                   static_cast<float>(accel_calibration_count_);

    // Sanity Check -
    // If the accelerometer is upside down or being spun around during the calibration,
    // then don't do anything
    if ((max_- min_).norm() > 1.0)
    {
      rf_.comm_manager_.log(CommLink::LogSeverity::LOG_ERROR, "Too much movement for IMU cal");
      calibrating_acc_flag_ = false;
    }
    else
    {
      // reset the estimated state
      rf_.estimator_.reset_state();
      calibrating_acc_flag_ = false;

      if (accel_bias.norm() < 3.0)
      {
        rf_.params_.set_param_float(PARAM_ACC_X_BIAS, accel_bias.x);
        rf_.params_.set_param_float(PARAM_ACC_Y_BIAS, accel_bias.y);
        rf_.params_.set_param_float(PARAM_ACC_Z_BIAS, accel_bias.z);
        rf_.comm_manager_.log(CommLink::LogSeverity::LOG_INFO, "IMU offsets captured");

        // clear uncalibrated IMU flag
        rf_.state_manager_.clear_error(StateManager::ERROR_UNCALIBRATED_IMU);
      }
      else
      {
        // This usually means the user has the FCU in the wrong orientation, or something is wrong
        // with the board IMU (like it's a cheap chinese clone)
        rf_.comm_manager_.log(CommLink::LogSeverity::LOG_ERROR, "large accel bias: norm = %d.%d",
                              static_cast<uint32_t>(accel_bias.norm()),
                              static_cast<uint32_t>(accel_bias.norm()*1000)%1000);
      }
    }

    // reset calibration counters in case we do it again
    accel_calibration_count_ = 0;
    acc_sum_.x = 0.0f;
    acc_sum_.y = 0.0f;
    acc_sum_.z = 0.0f;
    acc_temp_sum_ = 0.0f;
    max_.x = -1000.0f;
    max_.y = -1000.0f;
    max_.z = -1000.0f;
    min_.x = 1000.0f;
    min_.y = 1000.0f;
    min_.z = 1000.0f;
  }
}

void Sensors::calibrate_baro()
{
  if (rf_.board_.clock_millis() > last_baro_cal_iter_ms_ + 20)
  {
    baro_calibration_count_++;

    // calibrate pressure reading to where it should be
    if (baro_calibration_count_ > SENSOR_CAL_DELAY_CYCLES + SENSOR_CAL_CYCLES)
    {
      // if sample variance within acceptable range, flag calibration as done
      // else reset cal variables and start over
      if (baro_calibration_var_ < BARO_MAX_CALIBRATION_VARIANCE)
      {
        rf_.params_.set_param_float(PARAM_BARO_BIAS, baro_calibration_mean_);
        baro_calibrated_ = true;
        rf_.comm_manager_.log(CommLink::LogSeverity::LOG_INFO, "Baro Cal successful!");
      }
      else
      {
        rf_.comm_manager_.log(CommLink::LogSeverity::LOG_ERROR, "Too much movement for barometer cal");
      }
      baro_calibration_mean_ = 0.0f;
      baro_calibration_var_ = 0.0f;
      baro_calibration_count_ = 0;
    }

    else if (baro_calibration_count_ > SENSOR_CAL_DELAY_CYCLES)
    {
      float measurement = data_.baro_pressure - ground_pressure_;
      float delta = measurement - baro_calibration_mean_;
      baro_calibration_mean_ += delta / (baro_calibration_count_ - SENSOR_CAL_DELAY_CYCLES);
      float delta2 = measurement - baro_calibration_mean_;
      baro_calibration_var_ += delta * delta2 / (SENSOR_CAL_CYCLES - 1);
    }
    last_baro_cal_iter_ms_ = rf_.board_.clock_millis();
  }
}

void Sensors::calibrate_diff_pressure()
{
  if (rf_.board_.clock_millis() > last_diff_pressure_cal_iter_ms_ + 20)
  {
    diff_pressure_calibration_count_++;

    if (diff_pressure_calibration_count_ > SENSOR_CAL_DELAY_CYCLES + SENSOR_CAL_CYCLES)
    {
      // if sample variance within acceptable range, flag calibration as done
      // else reset cal variables and start over
      if (diff_pressure_calibration_var_ < DIFF_PRESSURE_MAX_CALIBRATION_VARIANCE)
      {
        rf_.params_.set_param_float(PARAM_DIFF_PRESS_BIAS, diff_pressure_calibration_mean_);
        diff_pressure_calibrated_ = true;
        rf_.comm_manager_.log(CommLink::LogSeverity::LOG_INFO, "Airspeed Cal Successful!");
      }
      else
      {
        rf_.comm_manager_.log(CommLink::LogSeverity::LOG_ERROR, "Too much movement for diff pressure cal");
      }
      diff_pressure_calibration_mean_ = 0.0f;
      diff_pressure_calibration_var_ = 0.0f;
      diff_pressure_calibration_count_ = 0;
    }
    else if (diff_pressure_calibration_count_ > SENSOR_CAL_DELAY_CYCLES)
    {
      float delta = data_.diff_pressure - diff_pressure_calibration_mean_;
      diff_pressure_calibration_mean_ += delta / (diff_pressure_calibration_count_ - SENSOR_CAL_DELAY_CYCLES);
      float delta2 = data_.diff_pressure - diff_pressure_calibration_mean_;
      diff_pressure_calibration_var_ += delta * delta2 / (SENSOR_CAL_CYCLES - 1);
    }
    last_diff_pressure_cal_iter_ms_ = rf_.board_.clock_millis();
  }
}


//======================================================
// Correction Functions (These apply calibration constants)
void Sensors::correct_imu(void)
{
  // correct according to known biases and temperature compensation
  data_.accel.x -= rf_.params_.get_param_float(PARAM_ACC_X_TEMP_COMP)*data_.imu_temperature
                   + rf_.params_.get_param_float(PARAM_ACC_X_BIAS);
  data_.accel.y -= rf_.params_.get_param_float(PARAM_ACC_Y_TEMP_COMP)*data_.imu_temperature
                   + rf_.params_.get_param_float(PARAM_ACC_Y_BIAS);
  data_.accel.z -= rf_.params_.get_param_float(PARAM_ACC_Z_TEMP_COMP)*data_.imu_temperature
                   + rf_.params_.get_param_float(PARAM_ACC_Z_BIAS);

  data_.gyro.x -= rf_.params_.get_param_float(PARAM_GYRO_X_BIAS);
  data_.gyro.y -= rf_.params_.get_param_float(PARAM_GYRO_Y_BIAS);
  data_.gyro.z -= rf_.params_.get_param_float(PARAM_GYRO_Z_BIAS);
}

void Sensors::correct_mag(void)
{
  // correct according to known hard iron bias
  float mag_hard_x = data_.mag.x - rf_.params_.get_param_float(PARAM_MAG_X_BIAS);
  float mag_hard_y = data_.mag.y - rf_.params_.get_param_float(PARAM_MAG_Y_BIAS);
  float mag_hard_z = data_.mag.z - rf_.params_.get_param_float(PARAM_MAG_Z_BIAS);

  // correct according to known soft iron bias - converts to nT
  data_.mag.x = rf_.params_.get_param_float(PARAM_MAG_A11_COMP)*mag_hard_x + rf_.params_.get_param_float(
                  PARAM_MAG_A12_COMP)*mag_hard_y +
                rf_.params_.get_param_float(PARAM_MAG_A13_COMP)*mag_hard_z;
  data_.mag.y = rf_.params_.get_param_float(PARAM_MAG_A21_COMP)*mag_hard_x + rf_.params_.get_param_float(
                  PARAM_MAG_A22_COMP)*mag_hard_y +
                rf_.params_.get_param_float(PARAM_MAG_A23_COMP)*mag_hard_z;
  data_.mag.z = rf_.params_.get_param_float(PARAM_MAG_A31_COMP)*mag_hard_x + rf_.params_.get_param_float(
                  PARAM_MAG_A32_COMP)*mag_hard_y +
                rf_.params_.get_param_float(PARAM_MAG_A33_COMP)*mag_hard_z;
}

void Sensors::correct_baro(void)
{
  if (!baro_calibrated_)
    calibrate_baro();
  data_.baro_pressure -= rf_.params_.get_param_float(PARAM_BARO_BIAS);
  data_.baro_altitude = turbomath::alt(data_.baro_pressure) - rf_.params_.get_param_float(PARAM_GROUND_LEVEL);
}

void Sensors::correct_diff_pressure()
{
  if (!diff_pressure_calibrated_)
    calibrate_diff_pressure();
  data_.diff_pressure -= rf_.params_.get_param_float(PARAM_DIFF_PRESS_BIAS);
  float atm = 101325.0f;
  if (data_.baro_present)
    atm = data_.baro_pressure;
  data_.diff_pressure_velocity = turbomath::fsign(data_.diff_pressure) * 24.574f /
                                 turbomath::inv_sqrt((turbomath::fabs(data_.diff_pressure) * data_.diff_pressure_temp  /  atm));
}

void Sensors::OutlierFilter::init(float max_change_rate, float update_rate, float center)
{
  max_change_ = max_change_rate / update_rate;
  window_size_ = 1;
  center_ = center;
  init_ = true;
}

bool Sensors::OutlierFilter::update(float new_val, float *val)
{
  float diff = new_val - center_;
  if (fabsf(diff) < window_size_ * max_change_)
  {
    *val = new_val;

    center_ += turbomath::fsign(diff) * fminf(max_change_, fabsf(diff));
    if (window_size_ > 1)
    {
      window_size_--;
    }
    return true;
  }
  else
  {
    window_size_++;
    return false;
  }
}

} // namespace rosflight_firmware