src/main/rx/srxl2.c

   1 /*
   2  * This file is part of Cleanflight and Betaflight.
   3  *
   4  * Cleanflight and Betaflight are free software. You can redistribute
   5  * this software and/or modify this software under the terms of the
   6  * GNU General Public License as published by the Free Software
   7  * Foundation, either version 3 of the License, or (at your option)
   8  * any later version.
   9  *
  10  * Cleanflight and Betaflight are distributed in the hope that they
  11  * will be useful, but WITHOUT ANY WARRANTY; without even the implied
  12  * warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
  13  * See the GNU General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License
  16  * along with this software.
  17  *
  18  * If not, see <http://www.gnu.org/licenses/>.
  19  */
  20
  21 #include <string.h>
  22
  23 #include "platform.h"
  24
  25 #ifdef USE_SERIALRX_SRXL2
  26
  27 #include "common/crc.h"
  28 #include "common/maths.h"
  29 #include "common/streambuf.h"
  30
  31 #include "drivers/nvic.h"
  32 #include "drivers/time.h"
  33 #include "drivers/serial.h"
  34 #include "drivers/serial_uart.h"
  35
  36 #include "io/serial.h"
  37
  38 #include "rx/srxl2.h"
  39 #include "rx/srxl2_types.h"
  40
  41 #ifndef SRXL2_DEBUG
  42 #define SRXL2_DEBUG 0
  43 #endif
  44
  45 #if SRXL2_DEBUG
  46 //void cliPrintf(const char *format, ...);
  47 //#define DEBUG_PRINTF(format, ...) cliPrintf(format, __VA_ARGS__)
  48 #define DEBUG_PRINTF(...) //Temporary until a better debug printf can be included
  49 #else
  50 #define DEBUG_PRINTF(...)
  51 #endif
  52
  53
  54
  55 #define SRXL2_MAX_CHANNELS             32
  56 #define SRXL2_FRAME_PERIOD_US   11000 // 5500 for DSMR
  57 #define SRXL2_CHANNEL_SHIFT            5
  58 #define SRXL2_CHANNEL_CENTER           0x8000
  59
  60 #define SRXL2_PORT_BAUDRATE_DEFAULT    115200
  61 #define SRXL2_PORT_BAUDRATE_HIGH       400000
  62 #define SRXL2_PORT_OPTIONS             (SERIAL_STOPBITS_1 | SERIAL_PARITY_NO | SERIAL_BIDIR)
  63 #define SRXL2_PORT_MODE                MODE_RXTX
  64
  65 #define SRXL2_REPLY_QUIESCENCE         (2 * 10 * 1000000 / SRXL2_PORT_BAUDRATE_DEFAULT) // 2 * (lastIdleTimestamp - lastReceiveTimestamp). Time taken to send 2 bytes
  66
  67 #define SRXL2_ID                       0xA6
  68 #define SRXL2_MAX_PACKET_LENGTH        80
  69 #define SRXL2_DEVICE_ID_BROADCAST      0xFF
  70
  71 #define SRXL2_FRAME_TIMEOUT_US         50000
  72
  73 #define SRXL2_LISTEN_FOR_ACTIVITY_TIMEOUT_US 50000
  74 #define SRXL2_SEND_HANDSHAKE_TIMEOUT_US 50000
  75 #define SRXL2_LISTEN_FOR_HANDSHAKE_TIMEOUT_US 200000
  76
  77 #define SPEKTRUM_PULSE_OFFSET          988 // Offset value to convert digital data into RC pulse
  78
  79 typedef union {
  80         uint8_t raw[SRXL2_MAX_PACKET_LENGTH];
  81         Srxl2Header header;
  82 } Srxl2Frame;
  83
  84 struct rxBuf {
  85     volatile unsigned len;
  86     Srxl2Frame packet;
  87 };
  88
  89 static uint8_t unitId = 0;
  90 static uint8_t baudRate = 0;
  91
  92 static Srxl2State state = Disabled;
  93 static uint32_t timeoutTimestamp = 0;
  94 static uint32_t fullTimeoutTimestamp = 0;
  95 static uint32_t lastValidPacketTimestamp = 0;
  96 static volatile uint32_t lastReceiveTimestamp = 0;
  97 static volatile uint32_t lastIdleTimestamp = 0;
  98
  99 struct rxBuf readBuffer[2];
 100 struct rxBuf* readBufferPtr = &readBuffer[0];
 101 struct rxBuf* processBufferPtr = &readBuffer[1];
 102 static volatile unsigned readBufferIdx = 0;
 103 static volatile bool transmittingTelemetry = false;
 104 static uint8_t writeBuffer[SRXL2_MAX_PACKET_LENGTH];
 105 static unsigned writeBufferIdx = 0;
 106
 107 static serialPort_t *serialPort;
 108
 109 static uint8_t busMasterDeviceId = 0xFF;
 110 static bool telemetryRequested = false;
 111
 112 static uint8_t telemetryFrame[22];
 113
 114 uint8_t globalResult = 0;
 115
 116 /* handshake protocol
 117     1. listen for 50ms for serial activity and go to State::Running if found, autobaud may be necessary
 118     2. if srxl2_unitId = 0:
 119             send a Handshake with destinationDeviceId = 0 every 50ms for at least 200ms
 120         else:
 121             listen for Handshake for at least 200ms
 122     3.  respond to Handshake as currently implemented in process if rePst received
 123     4.  respond to broadcast Handshake
 124 */
 125
 126 // if 50ms with not activity, go to default baudrate and to step 1
 127
 128 bool srxl2ProcessHandshake(const Srxl2Header* header)
 129 {
 130     const Srxl2HandshakeSubHeader* handshake = (Srxl2HandshakeSubHeader*)(header + 1);
 131     if (handshake->destinationDeviceId == Broadcast) {
 132         DEBUG_PRINTF("broadcast handshake from %x\r\n", handshake->sourceDeviceId);
 133         busMasterDeviceId = handshake->sourceDeviceId;
 134
 135         if (handshake->baudSupported == 1) {
 136             serialSetBaudRate(serialPort, SRXL2_PORT_BAUDRATE_HIGH);
 137             DEBUG_PRINTF("switching to %d baud\r\n", SRXL2_PORT_BAUDRATE_HIGH);
 138         }
 139
 140         state = Running;
 141
 142         return true;
 143     }
 144
 145
 146     if (handshake->destinationDeviceId != ((FlightController << 4) | unitId)) {
 147         return true;
 148     }
 149
 150     DEBUG_PRINTF("FC handshake from %x\r\n", handshake->sourceDeviceId);
 151
 152     Srxl2HandshakeFrame response = {
 153         .header = *header,
 154         .payload = {
 155             handshake->destinationDeviceId,
 156             handshake->sourceDeviceId,
 157             /* priority */ 10,
 158             /* baudSupported*/ baudRate,
 159             /* info */ 0,
 160             // U_ID_2
 161         }
 162     };
 163
 164     srxl2RxWriteData(&response, sizeof(response));
 165
 166     return true;
 167 }
 168
 169 void srxl2ProcessChannelData(const Srxl2ChannelDataHeader* channelData, rxRuntimeConfig_t *rxRuntimeConfig) {
 170     globalResult = RX_FRAME_COMPLETE;
 171
 172     if (channelData->rssi >= 0) {
 173         const int rssiPercent = channelData->rssi;
 174         lqTrackerSet(rxRuntimeConfig->lqTracker, scaleRange(constrain(rssiPercent, 0, 100), 0, 100, 0, RSSI_MAX_VALUE));
 175         //setRssi(scaleRange(rssiPercent, 0, 100, 0, RSSI_MAX_VALUE), RSSI_SOURCE_RX_PROTOCOL);
 176     }
 177
 178     //If receiver is in a connected state, and a packet is missed, the channel mask will be 0.
 179     if (!channelData->channelMask.u32) {
 180         globalResult |= RX_FRAME_FAILSAFE;
 181         return;
 182     }
 183
 184     const uint16_t *frameChannels = (const uint16_t *) (channelData + 1);
 185     uint32_t channelMask = channelData->channelMask.u32;
 186     while (channelMask) {
 187         unsigned idx = __builtin_ctz (channelMask);
 188         uint32_t mask = 1 << idx;
 189         rxRuntimeConfig->channelData[idx] = *frameChannels++;
 190         channelMask &= ~mask;
 191     }
 192
 193      DEBUG_PRINTF("channel data: %d %d %x\r\n", channelData_header->rssi, channelData_header->frameLosses, channelData_header->channelMask.u32);
 194 }
 195
 196 bool srxl2ProcessControlData(const Srxl2Header* header, rxRuntimeConfig_t *rxRuntimeConfig)
 197 {
 198     const Srxl2ControlDataSubHeader* controlData = (Srxl2ControlDataSubHeader*)(header + 1);
 199     const uint8_t ownId = (FlightController << 4) | unitId;
 200     if (controlData->replyId == ownId) {
 201         telemetryRequested = true;
 202         DEBUG_PRINTF("command: %x replyId: %x ownId: %x\r\n", controlData->command, controlData->replyId, ownId);
 203     }
 204
 205     switch (controlData->command) {
 206     case ChannelData:
 207         srxl2ProcessChannelData((const Srxl2ChannelDataHeader *) (controlData + 1), rxRuntimeConfig);
 208         break;
 209
 210     case FailsafeChannelData: {
 211         globalResult |= RX_FRAME_FAILSAFE;
 212         //setRssiDirect(0, RSSI_SOURCE_RX_PROTOCOL);
 213         lqTrackerSet(rxRuntimeConfig->lqTracker, 0);
 214         // DEBUG_PRINTF("fs channel data\r\n");
 215     } break;
 216
 217     case VTXData: {
 218 #if defined(USE_SPEKTRUM_VTX_CONTROL) && defined(USE_VTX_COMMON)
 219         Srxl2VtxData *vtxData = (Srxl2VtxData*)(controlData + 1);
 220         DEBUG_PRINTF("vtx data\r\n");
 221         DEBUG_PRINTF("vtx band: %x\r\n", vtxData->band);
 222         DEBUG_PRINTF("vtx channel: %x\r\n", vtxData->channel);
 223         DEBUG_PRINTF("vtx pit: %x\r\n", vtxData->pit);
 224         DEBUG_PRINTF("vtx power: %x\r\n", vtxData->power);
 225         DEBUG_PRINTF("vtx powerDec: %x\r\n", vtxData->powerDec);
 226         DEBUG_PRINTF("vtx region: %x\r\n", vtxData->region);
 227         // Pack data as it was used before srxl2 to use existing functions.
 228         // Get the VTX control bytes in a frame
 229         uint32_t vtxControl =   (0xE0 << 24) | (0xE0 << 8) |
 230                                 ((vtxData->band & 0x07) << 21) |
 231                                 ((vtxData->channel & 0x0F) << 16) |
 232                                 ((vtxData->pit & 0x01) << 4) |
 233                                 ((vtxData->region & 0x01) << 3) |
 234                                 ((vtxData->power & 0x07));
 235         spektrumHandleVtxControl(vtxControl);
 236 #endif
 237     } break;
 238     }
 239
 240     return true;
 241 }
 242
 243 bool srxl2ProcessPacket(const Srxl2Header* header, rxRuntimeConfig_t *rxRuntimeConfig)
 244 {
 245     switch (header->packetType) {
 246     case Handshake:
 247         return srxl2ProcessHandshake(header);
 248     case ControlData:
 249         return srxl2ProcessControlData(header, rxRuntimeConfig);
 250     default:
 251         DEBUG_PRINTF("Other packet type, ID: %x \r\n", header->packetType);
 252         break;
 253     }
 254
 255     return false;
 256 }
 257
 258 // @note assumes packet is fully there
 259 void srxl2Process(rxRuntimeConfig_t *rxRuntimeConfig)
 260 {
 261     if (processBufferPtr->packet.header.id != SRXL2_ID || processBufferPtr->len != processBufferPtr->packet.header.length) {
 262         DEBUG_PRINTF("invalid header id: %x, or length: %x received vs %x expected \r\n", processBufferPtr->packet.header.id, processBufferPtr->len, processBufferPtr->packet.header.length);
 263         globalResult = RX_FRAME_DROPPED;
 264         return;
 265     }
 266
 267     const uint16_t calculatedCrc = crc16_ccitt_update(0, processBufferPtr->packet.raw, processBufferPtr->packet.header.length);
 268
 269     //Invalid if crc non-zero
 270     if (calculatedCrc) {
 271         globalResult = RX_FRAME_DROPPED;
 272         DEBUG_PRINTF("crc mismatch %x\r\n", calculatedCrc);
 273         return;
 274     }
 275
 276     //Packet is valid only after ID and CRC check out
 277     lastValidPacketTimestamp = micros();
 278
 279     if (srxl2ProcessPacket(&processBufferPtr->packet.header, rxRuntimeConfig)) {
 280         return;
 281     }
 282
 283     DEBUG_PRINTF("could not parse packet: %x\r\n", processBufferPtr->packet.header.packetType);
 284     globalResult = RX_FRAME_DROPPED;
 285 }
 286
 287
 288 static void srxl2DataReceive(uint16_t character, void *data)
 289 {
 290     UNUSED(data);
 291
 292     lastReceiveTimestamp = microsISR();
 293
 294     //If the buffer len is not reset for whatever reason, disable reception
 295     if (readBufferPtr->len > 0 || readBufferIdx >= SRXL2_MAX_PACKET_LENGTH) {
 296         readBufferIdx = 0;
 297         globalResult = RX_FRAME_DROPPED;
 298     }
 299     else {
 300         readBufferPtr->packet.raw[readBufferIdx] = character;
 301         readBufferIdx++;
 302     }
 303 }
 304
 305 static void srxl2Idle(void)
 306 {
 307     if(transmittingTelemetry) { // Transmitting telemetry triggers idle interrupt as well. We dont want to change buffers then
 308         transmittingTelemetry = false;
 309     }
 310     else if(readBufferIdx == 0) { // Packet was invalid
 311         readBufferPtr->len = 0;
 312     }
 313     else {
 314         lastIdleTimestamp = microsISR();
 315         //Swap read and process buffer pointers
 316         if(processBufferPtr == &readBuffer[0]) {
 317             processBufferPtr = &readBuffer[1];
 318             readBufferPtr = &readBuffer[0];
 319         } else {
 320             processBufferPtr = &readBuffer[0];
 321             readBufferPtr = &readBuffer[1];
 322         }
 323         processBufferPtr->len = readBufferIdx;
 324     }
 325
 326     readBufferIdx = 0;
 327 }
 328
 329 static uint8_t srxl2FrameStatus(rxRuntimeConfig_t *rxRuntimeConfig)
 330 {
 331     UNUSED(rxRuntimeConfig);
 332
 333     if(serialIsIdle(serialPort))
 334     {
 335         srxl2Idle();
 336     }
 337
 338     globalResult = RX_FRAME_PENDING;
 339
 340     // len should only be set after an idle interrupt (packet reception complete)
 341     if (processBufferPtr != NULL && processBufferPtr->len) {
 342         srxl2Process(rxRuntimeConfig);
 343         processBufferPtr->len = 0;
 344     }
 345
 346     uint8_t result = globalResult;
 347
 348     const uint32_t now = micros();
 349
 350     switch (state) {
 351     case Disabled: break;
 352
 353     case ListenForActivity: {
 354         // activity detected
 355         if (lastValidPacketTimestamp != 0) {
 356             // as ListenForActivity is done at default baud-rate, we don't need to change anything
 357             // @todo if there were non-handshake packets - go to running,
 358             // if there were - go to either Send Handshake or Listen For Handshake
 359             state = Running;
 360         } else if (cmpTimeUs(lastIdleTimestamp, lastReceiveTimestamp) > 0) {
 361             if (baudRate != 0) {
 362                 uint32_t currentBaud = serialGetBaudRate(serialPort);
 363
 364                 if(currentBaud == SRXL2_PORT_BAUDRATE_DEFAULT)
 365                     serialSetBaudRate(serialPort, SRXL2_PORT_BAUDRATE_HIGH);
 366                 else
 367                     serialSetBaudRate(serialPort, SRXL2_PORT_BAUDRATE_DEFAULT);
 368             }
 369         } else if (cmpTimeUs(now, timeoutTimestamp) >= 0) {
 370             // @todo if there was activity - detect baudrate and ListenForHandshake
 371
 372             if (unitId == 0) {
 373                 state = SendHandshake;
 374                 timeoutTimestamp = now + SRXL2_SEND_HANDSHAKE_TIMEOUT_US;
 375                 fullTimeoutTimestamp = now + SRXL2_LISTEN_FOR_HANDSHAKE_TIMEOUT_US;
 376             } else {
 377                 state = ListenForHandshake;
 378                 timeoutTimestamp = now + SRXL2_LISTEN_FOR_HANDSHAKE_TIMEOUT_US;
 379             }
 380         }
 381     } break;
 382
 383     case SendHandshake: {
 384         if (cmpTimeUs(now, timeoutTimestamp) >= 0) {
 385             // @todo set another timeout for 50ms tries
 386             // fill write buffer with handshake frame
 387             result |= RX_FRAME_PROCESSING_REQUIRED;
 388         }
 389
 390         if (cmpTimeUs(now, fullTimeoutTimestamp) >= 0) {
 391             serialSetBaudRate(serialPort, SRXL2_PORT_BAUDRATE_DEFAULT);
 392             DEBUG_PRINTF("case SendHandshake: switching to %d baud\r\n", SRXL2_PORT_BAUDRATE_DEFAULT);
 393             timeoutTimestamp = now + SRXL2_LISTEN_FOR_ACTIVITY_TIMEOUT_US;
 394             result = (result & ~RX_FRAME_PENDING) | RX_FRAME_FAILSAFE;
 395
 396             state = ListenForActivity;
 397             lastReceiveTimestamp = 0;
 398         }
 399     } break;
 400
 401     case ListenForHandshake: {
 402         if (cmpTimeUs(now, timeoutTimestamp) >= 0)  {
 403             serialSetBaudRate(serialPort, SRXL2_PORT_BAUDRATE_DEFAULT);
 404             DEBUG_PRINTF("case ListenForHandshake: switching to %d baud\r\n", SRXL2_PORT_BAUDRATE_DEFAULT);
 405             timeoutTimestamp = now + SRXL2_LISTEN_FOR_ACTIVITY_TIMEOUT_US;
 406             result = (result & ~RX_FRAME_PENDING) | RX_FRAME_FAILSAFE;
 407
 408             state = ListenForActivity;
 409             lastReceiveTimestamp = 0;
 410         }
 411     } break;
 412
 413     case Running: {
 414         // frame timed out, reset state
 415         if (cmpTimeUs(now, lastValidPacketTimestamp) >= SRXL2_FRAME_TIMEOUT_US) {
 416             serialSetBaudRate(serialPort, SRXL2_PORT_BAUDRATE_DEFAULT);
 417             DEBUG_PRINTF("case Running: switching to %d baud: %d %d\r\n", SRXL2_PORT_BAUDRATE_DEFAULT, now, lastValidPacketTimestamp);
 418             timeoutTimestamp = now + SRXL2_LISTEN_FOR_ACTIVITY_TIMEOUT_US;
 419             result = (result & ~RX_FRAME_PENDING) | RX_FRAME_FAILSAFE;
 420
 421             state = ListenForActivity;
 422             lastReceiveTimestamp = 0;
 423             lastValidPacketTimestamp = 0;
 424         }
 425     } break;
 426     };
 427
 428     if (writeBufferIdx) {
 429         result |= RX_FRAME_PROCESSING_REQUIRED;
 430     }
 431
 432     return result;
 433 }
 434
 435 static bool srxl2ProcessFrame(const rxRuntimeConfig_t *rxRuntimeConfig)
 436 {
 437     UNUSED(rxRuntimeConfig);
 438
 439     if (writeBufferIdx == 0) {
 440         return true;
 441     }
 442
 443     const uint32_t now = micros();
 444
 445     if (cmpTimeUs(lastIdleTimestamp, lastReceiveTimestamp) > 0) {
 446         // time sufficient for at least 2 characters has passed
 447         if (cmpTimeUs(now, lastReceiveTimestamp) > SRXL2_REPLY_QUIESCENCE) {
 448             transmittingTelemetry = true;
 449             serialWriteBuf(serialPort, writeBuffer, writeBufferIdx);
 450             writeBufferIdx = 0;
 451         } else {
 452             DEBUG_PRINTF("not enough time to send 2 characters passed yet, %d us since last receive, %d required\r\n", now - lastReceiveTimestamp, SRXL2_REPLY_QUIESCENCE);
 453         }
 454     } else {
 455         DEBUG_PRINTF("still receiving a frame, %d %d\r\n", lastIdleTimestamp, lastReceiveTimestamp);
 456     }
 457
 458     return true;
 459 }
 460
 461 static uint16_t srxl2ReadRawRC(const rxRuntimeConfig_t *rxRuntimeConfig, uint8_t channelIdx)
 462 {
 463     if (channelIdx >= rxRuntimeConfig->channelCount) {
 464         return 0;
 465     }
 466
 467     return SPEKTRUM_PULSE_OFFSET + ((rxRuntimeConfig->channelData[channelIdx] >> SRXL2_CHANNEL_SHIFT) >> 1);
 468 }
 469
 470 void srxl2RxWriteData(const void *data, int len)
 471 {
 472     const uint16_t crc = crc16_ccitt_update(0, (uint8_t*)data, len - 2);
 473     ((uint8_t*)data)[len-2] = ((uint8_t *) &crc)[1] & 0xFF;
 474     ((uint8_t*)data)[len-1] = ((uint8_t *) &crc)[0] & 0xFF;
 475
 476     len = MIN(len, (int)sizeof(writeBuffer));
 477     memcpy(writeBuffer, data, len);
 478     writeBufferIdx = len;
 479 }
 480
 481 bool srxl2RxInit(const rxConfig_t *rxConfig, rxRuntimeConfig_t *rxRuntimeConfig)
 482 {
 483     static uint16_t channelData[SRXL2_MAX_CHANNELS];
 484     for (size_t i = 0; i < SRXL2_MAX_CHANNELS; ++i) {
 485         channelData[i] = SRXL2_CHANNEL_CENTER;
 486     }
 487
 488     unitId = rxConfig->srxl2_unit_id;
 489     baudRate = rxConfig->srxl2_baud_fast;
 490
 491     rxRuntimeConfig->channelData = channelData;
 492     rxRuntimeConfig->channelCount = SRXL2_MAX_CHANNELS;
 493     rxRuntimeConfig->rcReadRawFn = srxl2ReadRawRC;
 494     rxRuntimeConfig->rcFrameStatusFn = srxl2FrameStatus;
 495     rxRuntimeConfig->rcProcessFrameFn = srxl2ProcessFrame;
 496
 497     const serialPortConfig_t *portConfig = findSerialPortConfig(FUNCTION_RX_SERIAL);
 498     if (!portConfig) {
 499         return false;
 500     }
 501
 502     portOptions_t options = SRXL2_PORT_OPTIONS;
 503     if (rxConfig->serialrx_inverted) {
 504         options |= SERIAL_INVERTED;
 505     }
 506     if (rxConfig->halfDuplex) {
 507         options |= SERIAL_BIDIR;
 508     }
 509
 510     serialPort = openSerialPort(portConfig->identifier, FUNCTION_RX_SERIAL, srxl2DataReceive,
 511         NULL, SRXL2_PORT_BAUDRATE_DEFAULT, SRXL2_PORT_MODE, options);
 512
 513     if (!serialPort) {
 514         return false;
 515     }
 516
 517     state = ListenForActivity;
 518     timeoutTimestamp = micros() + SRXL2_LISTEN_FOR_ACTIVITY_TIMEOUT_US;
 519
 520     //Looks like this needs to be set in cli config
 521     //if (rssiSource == RSSI_SOURCE_NONE) {
 522     //    rssiSource = RSSI_SOURCE_RX_PROTOCOL;
 523     //}
 524
 525     return (bool)serialPort;
 526 }
 527
 528 bool srxl2RxIsActive(void)
 529 {
 530     return serialPort;
 531 }
 532
 533 bool srxl2TelemetryRequested(void)
 534 {
 535     return telemetryRequested;
 536 }
 537
 538 void srxl2InitializeFrame(sbuf_t *dst)
 539 {
 540     dst->ptr = telemetryFrame;
 541     dst->end = ARRAYEND(telemetryFrame);
 542
 543     sbufWriteU8(dst, SRXL2_ID);
 544     sbufWriteU8(dst, TelemetrySensorData);
 545     sbufWriteU8(dst, ARRAYLEN(telemetryFrame));
 546     sbufWriteU8(dst, busMasterDeviceId);
 547 }
 548
 549 void srxl2FinalizeFrame(sbuf_t *dst)
 550 {
 551   sbufSwitchToReader(dst, telemetryFrame);
 552   // Include 2 additional bytes of length since we're letting the srxl2RxWriteData function add the CRC in
 553   srxl2RxWriteData(sbufPtr(dst), sbufBytesRemaining(dst) + 2);
 554   telemetryRequested = false;
 555 }
 556
 557 void srxl2Bind(void)
 558 {
 559     const size_t length = sizeof(Srxl2BindInfoFrame);
 560
 561     Srxl2BindInfoFrame bind = {
 562         .header = {
 563             .id = SRXL2_ID,
 564             .packetType = BindInfo,
 565             .length = length
 566         },
 567         .payload = {
 568             .request = EnterBindMode,
 569             .deviceId = busMasterDeviceId,
 570             .bindType = DMSX_11ms,
 571             .options = SRXL_BIND_OPT_TELEM_TX_ENABLE | SRXL_BIND_OPT_BIND_TX_ENABLE,
 572         }
 573     };
 574
 575     srxl2RxWriteData(&bind, length);
 576 }
 577
 578 #endif