dcf.c

Go to the documentation of this file.

/*
 * Copyright (C) 2017 Hector Garcia de Marina
 *
 * 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, see
 * <http://www.gnu.org/licenses/>.
 *
 */
 
#include <math.h>
#include <std.h>
 
#include "modules/muti/dcf/dcf.h"
//#include "modules/datalink/datalink.h" // dl_buffer
#include "modules/datalink/telemetry.h"
#include "modules/nav/common_nav.h"
#include "autopilot.h"
#include "std.h"
 
#if PERIODIC_TELEMETRY
static void send_dcf(struct transport_tx *trans, struct link_device *dev)
{
  pprz_msg_send_DCF(trans, dev, AC_ID, 4 * DCF_MAX_NEIGHBORS, &(dcf_tables.tableNei[0][0]), DCF_MAX_NEIGHBORS,
                    dcf_tables.error_sigma);
}
#endif // PERIODIC TELEMETRY
 
// Control
#ifndef DCF_GAIN_K
#define DCF_GAIN_K 10
#endif
#ifndef DCF_RADIUS
#define DCF_RADIUS 80
#endif
#ifndef DCF_TIMEOUT
#define DCF_TIMEOUT 1500
#endif
#ifndef DCF_BROADTIME
#define DCF_BROADTIME 200
#endif
 
struct dcf_con dcf_control = {DCF_GAIN_K, DCF_RADIUS, DCF_TIMEOUT, 0, DCF_BROADTIME};
struct dcf_tab dcf_tables;
 
uint32_t last_transmision = 0;
 
void dcf_init(void)
{
  for (int i = 0; i < DCF_MAX_NEIGHBORS; i++) {
    dcf_tables.tableNei[i][0] = -1;
    dcf_tables.error_sigma[i] = 0;
  }
 
#if PERIODIC_TELEMETRY
  register_periodic_telemetry(DefaultPeriodic, PPRZ_MSG_ID_DCF, send_dcf);
#endif
}
 
bool distributed_circular(uint8_t wp)
{
  float xc = waypoints[wp].x;
  float yc = waypoints[wp].y;
  struct EnuCoor_f *p = stateGetPositionEnu_f();
  float x = p->x;
  float y = p->y;
  float u = 0;
 
  dcf_control.theta = atan2f(y - yc, x - xc);
 
  uint32_t now = get_sys_time_msec();
 
  for (int i = 0; i < DCF_MAX_NEIGHBORS; i++) {
    if (dcf_tables.tableNei[i][0] != -1) {
      uint32_t timeout = now - dcf_tables.last_theta[i];
      if (timeout > dcf_control.timeout) {
        dcf_tables.tableNei[i][3] = dcf_control.timeout;
      } else {
        dcf_tables.tableNei[i][3] = (uint16_t)timeout;
 
        float t1 = dcf_control.theta;
        float t2 = dcf_tables.tableNei[i][1] * M_PI / 1800.0;
        float td = dcf_tables.tableNei[i][2] * M_PI / 1800.0;
 
        float c1 = cosf(t1);
        float s1 = sinf(t1);
        float c2 = cosf(t2);
        float s2 = sinf(t2);
 
        float e = atan2f(c2 * s1 - s2 * c1, c1 * c2 + s1 * s2) - gvf_control.s * td;
 
        u += e;
        dcf_tables.error_sigma[i] = (uint16_t)(e * 1800.0 / M_PI);
      }
    }
  }
 
  u *= -gvf_control.s * dcf_control.k;
 
  gvf_ellipse_XY(xc, yc, dcf_control.radius + u, dcf_control.radius + u, 0);
 
  if ((now - last_transmision > dcf_control.broadtime) && (autopilot_get_mode() == AP_MODE_AUTO2)) {
    send_theta_to_nei();
    last_transmision = now;
  }
 
  return true;
}
 
void send_theta_to_nei(void)
{
  struct pprzlink_msg msg;
 
  for (int i = 0; i < DCF_MAX_NEIGHBORS; i++)
    if (dcf_tables.tableNei[i][0] != -1) {
      msg.trans = &(DefaultChannel).trans_tx;
      msg.dev = &(DefaultDevice).device;
      msg.sender_id = AC_ID;
      msg.receiver_id = dcf_tables.tableNei[i][0];
      msg.component_id = 0;
      pprzlink_msg_send_DCF_THETA(&msg, &(dcf_control.theta));
    }
}
 
void parseRegTable(uint8_t *buf)
{
  uint8_t ac_id = DL_DCF_REG_TABLE_ac_id(buf);
  if (ac_id == AC_ID) {
    uint8_t nei_id = DL_DCF_REG_TABLE_nei_id(buf);
    int16_t desired_sigma = DL_DCF_REG_TABLE_desired_sigma(buf);
 
    if (nei_id == 0) {
      for (int i = 0; i < DCF_MAX_NEIGHBORS; i++) {
        dcf_tables.tableNei[i][0] = -1;
      }
    } else {
      for (int i = 0; i < DCF_MAX_NEIGHBORS; i++)
        if (dcf_tables.tableNei[i][0] == (int16_t)nei_id) {
          dcf_tables.tableNei[i][0] = (int16_t)nei_id;
          dcf_tables.tableNei[i][2] = desired_sigma;
          return;
        }
 
      for (int i = 0; i < DCF_MAX_NEIGHBORS; i++)
        if (dcf_tables.tableNei[i][0] == -1) {
          dcf_tables.tableNei[i][0] = (int16_t)nei_id;
          dcf_tables.tableNei[i][2] = desired_sigma;
          return;
        }
    }
  }
}
 
void parseThetaTable(uint8_t *buf)
{
  int16_t sender_id = (int16_t)(SenderIdOfPprzMsg(buf));
  for (int i = 0; i < DCF_MAX_NEIGHBORS; i++)
    if (dcf_tables.tableNei[i][0] == sender_id) {
      dcf_tables.last_theta[i] = get_sys_time_msec();
      dcf_tables.tableNei[i][1] = (int16_t)((DL_DCF_THETA_theta(buf)) * 1800 / M_PI);
      break;
    }
}