123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633 |
- #include <AP_HAL/AP_HAL.h>
- #include <AP_Math/AP_Math.h>
- #include <AP_RCProtocol/AP_RCProtocol.h>
- #include "AP_SerialManager.h"
- extern const AP_HAL::HAL& hal;
- #ifdef HAL_SERIAL2_PROTOCOL
- #define SERIAL2_PROTOCOL HAL_SERIAL2_PROTOCOL
- #else
- #define SERIAL2_PROTOCOL SerialProtocol_MAVLink
- #endif
- #ifndef HAL_SERIAL3_PROTOCOL
- #define SERIAL3_PROTOCOL SerialProtocol_GPS
- #else
- #define SERIAL3_PROTOCOL HAL_SERIAL3_PROTOCOL
- #endif
- #ifndef HAL_SERIAL4_PROTOCOL
- #define SERIAL4_PROTOCOL SerialProtocol_GPS
- #else
- #define SERIAL4_PROTOCOL HAL_SERIAL4_PROTOCOL
- #endif
- #ifdef HAL_SERIAL5_PROTOCOL
- #define SERIAL5_PROTOCOL HAL_SERIAL5_PROTOCOL
- #define SERIAL5_BAUD HAL_SERIAL5_BAUD
- #else
- #define SERIAL5_PROTOCOL SerialProtocol_None
- #define SERIAL5_BAUD AP_SERIALMANAGER_MAVLINK_BAUD/1000
- #endif
- #ifndef HAL_SERIAL6_PROTOCOL
- #define SERIAL6_PROTOCOL SerialProtocol_None
- #define SERIAL6_BAUD AP_SERIALMANAGER_MAVLINK_BAUD/1000
- #else
- #define SERIAL6_PROTOCOL HAL_SERIAL6_PROTOCOL
- #define SERIAL6_BAUD HAL_SERIAL6_BAUD
- #endif
- #ifndef HAL_SERIAL7_PROTOCOL
- #define SERIAL7_PROTOCOL SerialProtocol_None
- #define SERIAL7_BAUD AP_SERIALMANAGER_MAVLINK_BAUD/1000
- #else
- #define SERIAL7_PROTOCOL HAL_SERIAL7_PROTOCOL
- #define SERIAL7_BAUD HAL_SERIAL7_BAUD
- #endif
- const AP_Param::GroupInfo AP_SerialManager::var_info[] = {
-
-
-
-
-
- AP_GROUPINFO("0_BAUD", 0, AP_SerialManager, state[0].baud, AP_SERIALMANAGER_CONSOLE_BAUD/1000),
-
-
-
-
-
-
- AP_GROUPINFO("0_PROTOCOL", 11, AP_SerialManager, state[0].protocol, SerialProtocol_MAVLink2),
-
-
-
-
-
-
-
- AP_GROUPINFO("1_PROTOCOL", 1, AP_SerialManager, state[1].protocol, SerialProtocol_MAVLink),
-
-
-
-
-
- AP_GROUPINFO("1_BAUD", 2, AP_SerialManager, state[1].baud, AP_SERIALMANAGER_MAVLINK_BAUD/1000),
-
-
-
-
-
-
- AP_GROUPINFO("2_PROTOCOL", 3, AP_SerialManager, state[2].protocol, 24),
-
-
-
-
-
- AP_GROUPINFO("2_BAUD", 4, AP_SerialManager, state[2].baud, BAUD_115200/1000),
-
-
-
-
-
-
- AP_GROUPINFO("3_PROTOCOL", 5, AP_SerialManager, state[3].protocol, SERIAL3_PROTOCOL),
-
-
-
-
-
- AP_GROUPINFO("3_BAUD", 6, AP_SerialManager, state[3].baud, AP_SERIALMANAGER_GPS_BAUD/1000),
-
-
-
-
-
-
- AP_GROUPINFO("4_PROTOCOL", 7, AP_SerialManager, state[4].protocol, 25),
-
-
-
-
-
- AP_GROUPINFO("4_BAUD", 8, AP_SerialManager, state[4].baud, BAUD_115200/1000),
-
-
-
-
-
-
- AP_GROUPINFO("5_PROTOCOL", 9, AP_SerialManager, state[5].protocol, SERIAL5_PROTOCOL),
-
-
-
-
-
- AP_GROUPINFO("5_BAUD", 10, AP_SerialManager, state[5].baud, SERIAL5_BAUD),
-
-
-
-
-
-
-
-
- AP_GROUPINFO("6_PROTOCOL", 12, AP_SerialManager, state[6].protocol, SERIAL6_PROTOCOL),
-
-
-
-
-
- AP_GROUPINFO("6_BAUD", 13, AP_SerialManager, state[6].baud, SERIAL6_BAUD),
-
-
-
-
-
-
- AP_GROUPINFO("1_OPTIONS", 14, AP_SerialManager, state[1].options, 0),
-
-
-
-
-
-
- AP_GROUPINFO("2_OPTIONS", 15, AP_SerialManager, state[2].options, 0),
-
-
-
-
-
-
- AP_GROUPINFO("3_OPTIONS", 16, AP_SerialManager, state[3].options, 0),
-
-
-
-
-
-
- AP_GROUPINFO("4_OPTIONS", 17, AP_SerialManager, state[4].options, 0),
-
-
-
-
-
-
- AP_GROUPINFO("5_OPTIONS", 18, AP_SerialManager, state[5].options, 0),
-
-
-
-
-
-
- AP_GROUPINFO("6_OPTIONS", 19, AP_SerialManager, state[6].options, 0),
-
-
-
-
-
- AP_GROUPINFO("_PASS1", 20, AP_SerialManager, passthru_port1, 0),
-
-
-
-
-
- AP_GROUPINFO("_PASS2", 21, AP_SerialManager, passthru_port2, -1),
-
-
-
-
-
-
- AP_GROUPINFO("_PASSTIMO", 22, AP_SerialManager, passthru_timeout, 15),
-
-
-
-
-
-
- AP_GROUPINFO("7_PROTOCOL", 23, AP_SerialManager, state[7].protocol, SERIAL7_PROTOCOL),
-
-
-
-
-
- AP_GROUPINFO("7_BAUD", 24, AP_SerialManager, state[7].baud, SERIAL7_BAUD),
-
-
-
-
-
-
- AP_GROUPINFO("7_OPTIONS", 25, AP_SerialManager, state[7].options, 0),
-
- AP_GROUPEND
- };
- AP_SerialManager *AP_SerialManager::_singleton;
- AP_SerialManager::AP_SerialManager()
- {
- _singleton = this;
-
- AP_Param::setup_object_defaults(this, var_info);
- }
- void AP_SerialManager::init_console()
- {
-
- state[0].uart = hal.uartA;
- state[0].uart->begin(AP_SERIALMANAGER_CONSOLE_BAUD,
- AP_SERIALMANAGER_CONSOLE_BUFSIZE_RX,
- AP_SERIALMANAGER_CONSOLE_BUFSIZE_TX);
- }
- extern bool g_nsh_should_exit;
- void AP_SerialManager::init()
- {
-
- passthru_port2.set_and_save_ifchanged(-1);
-
- state[1].uart = hal.uartC;
- state[2].uart = hal.uartD;
- state[3].uart = hal.uartB;
- state[4].uart = hal.uartE;
- state[5].uart = hal.uartF;
- state[6].uart = hal.uartG;
- state[7].uart = hal.uartH;
- if (state[0].uart == nullptr) {
- init_console();
- }
-
-
- for (uint8_t i=1; i<SERIALMANAGER_NUM_PORTS; i++) {
- if (state[i].uart != nullptr) {
-
- if (state[i].protocol != SerialProtocol_None && state[i].options) {
- set_options(i);
- }
- switch (state[i].protocol) {
- case SerialProtocol_None:
- break;
- case SerialProtocol_Console:
- case SerialProtocol_MAVLink:
- case SerialProtocol_MAVLink2:
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_MAVLINK_BUFSIZE_RX,
- AP_SERIALMANAGER_MAVLINK_BUFSIZE_TX);
- break;
- case SerialProtocol_FrSky_D:
-
- state[i].baud = AP_SERIALMANAGER_FRSKY_D_BAUD/1000;
-
- break;
- case SerialProtocol_FrSky_SPort:
- case SerialProtocol_FrSky_SPort_Passthrough:
-
- state[i].baud = AP_SERIALMANAGER_FRSKY_SPORT_BAUD/1000;
-
- break;
- case SerialProtocol_GPS:
- case SerialProtocol_GPS2:
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_GPS_BUFSIZE_RX,
- AP_SERIALMANAGER_GPS_BUFSIZE_TX);
- break;
- case SerialProtocol_AlexMos:
-
- state[i].baud = AP_SERIALMANAGER_ALEXMOS_BAUD / 1000;
- state[i].uart->begin(AP_SERIALMANAGER_ALEXMOS_BAUD,
- AP_SERIALMANAGER_ALEXMOS_BUFSIZE_RX,
- AP_SERIALMANAGER_ALEXMOS_BUFSIZE_TX);
- break;
- case SerialProtocol_SToRM32:
-
- state[i].baud = AP_SERIALMANAGER_SToRM32_BAUD / 1000;
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_SToRM32_BUFSIZE_RX,
- AP_SERIALMANAGER_SToRM32_BUFSIZE_TX);
- break;
- case SerialProtocol_Aerotenna_uLanding:
- state[i].protocol.set_and_save(SerialProtocol_Rangefinder);
- break;
- case SerialProtocol_Volz:
-
- state[i].baud = AP_SERIALMANAGER_VOLZ_BAUD;
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_VOLZ_BUFSIZE_RX,
- AP_SERIALMANAGER_VOLZ_BUFSIZE_TX);
- state[i].uart->set_unbuffered_writes(true);
- state[i].uart->set_flow_control(AP_HAL::UARTDriver::FLOW_CONTROL_DISABLE);
- break;
- case SerialProtocol_Sbus1:
- state[i].baud = AP_SERIALMANAGER_SBUS1_BAUD / 1000;
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_SBUS1_BUFSIZE_RX,
- AP_SERIALMANAGER_SBUS1_BUFSIZE_TX);
- state[i].uart->configure_parity(2);
- state[i].uart->set_stop_bits(2);
- state[i].uart->set_unbuffered_writes(true);
- state[i].uart->set_flow_control(AP_HAL::UARTDriver::FLOW_CONTROL_DISABLE);
- break;
- case SerialProtocol_ESCTelemetry:
-
- state[i].baud = 115200;
- state[i].uart->begin(map_baudrate(state[i].baud), 30, 30);
- state[i].uart->set_flow_control(AP_HAL::UARTDriver::FLOW_CONTROL_DISABLE);
- break;
- case SerialProtocol_Robotis:
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_ROBOTIS_BUFSIZE_RX,
- AP_SERIALMANAGER_ROBOTIS_BUFSIZE_TX);
- state[i].uart->set_unbuffered_writes(true);
- state[i].uart->set_flow_control(AP_HAL::UARTDriver::FLOW_CONTROL_DISABLE);
- break;
- case SerialProtocol_SLCAN:
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_SLCAN_BUFSIZE_RX,
- AP_SERIALMANAGER_SLCAN_BUFSIZE_TX);
- break;
- #ifndef HAL_BUILD_AP_PERIPH
- case SerialProtocol_RCIN:
- AP::RC().add_uart(state[i].uart);
- break;
- #endif
- case SerialProtocol_usart2:
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_USART2_BUFSIZE_RX,
- AP_SERIALMANAGER_USART2_BUFSIZE_TX);
- break;
- case SerialProtocol_usart1:
- state[i].uart->begin(map_baudrate(state[i].baud),
- AP_SERIALMANAGER_USART1_BUFSIZE_RX,
- AP_SERIALMANAGER_USART1_BUFSIZE_TX);
- default:
- state[i].uart->begin(map_baudrate(state[i].baud));
- }
- }
- }
- }
- const AP_SerialManager::UARTState *AP_SerialManager::find_protocol_instance(enum SerialProtocol protocol, uint8_t instance) const
- {
- uint8_t found_instance = 0;
-
- for(uint8_t i=0; i<SERIALMANAGER_NUM_PORTS; i++) {
- if (protocol_match(protocol, (enum SerialProtocol)state[i].protocol.get())) {
- if (found_instance == instance) {
- return &state[i];
- }
- found_instance++;
- }
- }
-
- return nullptr;
- }
- AP_HAL::UARTDriver *AP_SerialManager::find_serial(enum SerialProtocol protocol, uint8_t instance) const
- {
- const struct UARTState *_state = find_protocol_instance(protocol, instance);
- if (_state == nullptr) {
- return nullptr;
- }
- return _state->uart;
- }
- uint32_t AP_SerialManager::find_baudrate(enum SerialProtocol protocol, uint8_t instance) const
- {
- const struct UARTState *_state = find_protocol_instance(protocol, instance);
- if (_state == nullptr) {
- return 0;
- }
- return map_baudrate(_state->baud);
- }
- bool AP_SerialManager::get_mavlink_channel(enum SerialProtocol protocol, uint8_t instance, mavlink_channel_t &mav_chan) const
- {
-
- if (protocol_match(protocol, SerialProtocol_MAVLink)) {
- if (instance < MAVLINK_COMM_NUM_BUFFERS) {
- mav_chan = (mavlink_channel_t)(MAVLINK_COMM_0 + instance);
- return true;
- }
- }
-
- return false;
- }
- AP_SerialManager::SerialProtocol AP_SerialManager::get_mavlink_protocol(mavlink_channel_t mav_chan) const
- {
- uint8_t instance = 0;
- uint8_t chan_idx = (uint8_t)(mav_chan - MAVLINK_COMM_0);
- for (uint8_t i=0; i<SERIALMANAGER_NUM_PORTS; i++) {
- if (state[i].protocol == SerialProtocol_MAVLink ||
- state[i].protocol == SerialProtocol_MAVLink2) {
- if (instance == chan_idx) {
- return (SerialProtocol)state[i].protocol.get();
- }
- instance++;
- }
- }
- return SerialProtocol_None;
- }
- AP_HAL::UARTDriver *AP_SerialManager::get_serial_by_id(uint8_t id)
- {
- if (id < SERIALMANAGER_NUM_PORTS) {
- return state[id].uart;
- }
- return nullptr;
- }
- void AP_SerialManager::set_blocking_writes_all(bool blocking)
- {
-
- for (uint8_t i=0; i<SERIALMANAGER_NUM_PORTS; i++) {
- if (state[i].uart != nullptr) {
- state[i].uart->set_blocking_writes(blocking);
- }
- }
- }
- uint32_t AP_SerialManager::map_baudrate(int32_t rate) const
- {
- if (rate <= 0) {
- rate = 57;
- }
- switch (rate) {
- case 1: return 1200;
- case 2: return 2400;
- case 4: return 4800;
- case 9: return 9600;
- case 19: return 19200;
- case 38: return 38400;
- case 57: return 57600;
- case 100: return 100000;
- case 111: return 111100;
- case 115: return 115200;
- case 230: return 230400;
- case 256: return 256000;
- case 460: return 460800;
- case 500: return 500000;
- case 921: return 921600;
- case 1500: return 1500000;
- }
- if (rate > 2000) {
-
-
- return (uint32_t)rate;
- }
-
- return rate*1000;
- }
- bool AP_SerialManager::protocol_match(enum SerialProtocol protocol1, enum SerialProtocol protocol2) const
- {
-
- if (protocol1 == protocol2) {
- return true;
- }
-
- if (((protocol1 == SerialProtocol_MAVLink) || (protocol1 == SerialProtocol_MAVLink2)) &&
- ((protocol2 == SerialProtocol_MAVLink) || (protocol2 == SerialProtocol_MAVLink2))) {
- return true;
- }
-
- if (((protocol1 == SerialProtocol_GPS) || (protocol1 == SerialProtocol_GPS2)) &&
- ((protocol2 == SerialProtocol_GPS) || (protocol2 == SerialProtocol_GPS2))) {
- return true;
- }
- return false;
- }
- void AP_SerialManager::set_options(uint8_t i)
- {
- struct UARTState &opt = state[i];
-
- if (!opt.uart->set_options(opt.options)) {
- hal.console->printf("Unable to setup options for Serial%u\n", i);
- }
- }
- bool AP_SerialManager::get_passthru(AP_HAL::UARTDriver *&port1, AP_HAL::UARTDriver *&port2, uint8_t &timeout_s) const
- {
- if (passthru_port2 < 0 ||
- passthru_port2 >= SERIALMANAGER_NUM_PORTS ||
- passthru_port1 < 0 ||
- passthru_port1 >= SERIALMANAGER_NUM_PORTS) {
- return false;
- }
- port1 = state[passthru_port1].uart;
- port2 = state[passthru_port2].uart;
- timeout_s = MAX(passthru_timeout, 0);
- return true;
- }
- void AP_SerialManager::disable_passthru(void)
- {
- passthru_port2.set_and_notify(-1);
- }
- namespace AP {
- AP_SerialManager &serialmanager()
- {
- return *AP_SerialManager::get_singleton();
- }
- }
|