rt_sbus.h File Reference

#include <stdint.h>

Include dependency graph for rt_sbus.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
void	unpack_sbus_data (uint8_t sbus_data[], uint16_t *channels)
int	read_sbus_data (int port, uint8_t *sbus_data)
int	read_sbus_channel (int channel)
int	receive_sbus (int port)
int	init_sbus (int is_simulator)

Function Documentation

int init_sbus

(

int

is_simulator

)

Definition at line 119 of file rt_sbus.cpp.

References K_SBUS_PORT_MC, K_SBUS_PORT_SIM, sbus_data_m, and set_interface_attribs_custom_baud().

                                {
  // char *port1;
  std::string port1;
  if (is_simulator) {
    port1 = K_SBUS_PORT_SIM;
  } else {
    port1 = K_SBUS_PORT_MC;
  }

  if (pthread_mutex_init(&sbus_data_m, NULL) != 0) {
    printf("Failed to initialize sbus data mutex.\n");
  }

  int fd1 = open(port1.c_str(), O_RDWR | O_NOCTTY | O_SYNC);
  if (fd1 < 0) {
    printf("Error opening %s: %s\n", port1.c_str(), strerror(errno));
  } else {
    set_interface_attribs_custom_baud(fd1, 100000, 0, 0);
  }
  return fd1;
}

Here is the call graph for this function:

Here is the caller graph for this function:

int read_sbus_channel

(

int

channel

)

Definition at line 101 of file rt_sbus.cpp.

References channel_data, and sbus_data_m.

                                   {
  pthread_mutex_lock(&sbus_data_m);
  int value = channel_data[channel];
  pthread_mutex_unlock(&sbus_data_m);
  return value;
}

Here is the caller graph for this function:

int read_sbus_data	(	int	port,
		uint8_t *	sbus_data
	)

Definition at line 76 of file rt_sbus.cpp.

                                                 {
  uint8_t packet_full = 0;
  uint8_t read_byte[1] = {0};
  int timeout_counter = 0;
  // int n = read(fd1, read_buff, sizeof(read_buff));
  while ((!packet_full) && (timeout_counter < 50)) {
    timeout_counter++;
    // Read a byte //
    int n = read(port, read_byte, sizeof(read_byte));
    (void)n;
    // Shift the buffer //
    for (int i = 0; i < 24; i++) {
      sbus_data[i] = sbus_data[i + 1];
    }
    sbus_data[24] = read_byte[0];

    // Check for the correct start and stop bytes ///
    if ((sbus_data[0] == 15) && (sbus_data[24] == 0)) {
      // unpack_sbus_data(sbus_data_buff, channels);
      packet_full = 1;
    }
  }
  return packet_full;
}

Here is the caller graph for this function:

int receive_sbus

(

int

port

)

Definition at line 108 of file rt_sbus.cpp.

References channels, read_sbus_data(), and unpack_sbus_data().

                           {
  uint16_t read_buff[25] = {0};
  int x = read_sbus_data(port, (uint8_t *)read_buff);
  if (x) {
    unpack_sbus_data((uint8_t *)read_buff, channels);
  } else {
    printf("SBUS tried read 50 bytes without seeing a packet\n");
  }
  return x;
}

Here is the call graph for this function:

Here is the caller graph for this function:

void unpack_sbus_data	(	uint8_t	sbus_data[],
		uint16_t *	channels
	)

Definition at line 33 of file rt_sbus.cpp.

References channel_data, and sbus_data_m.

                                                                {
  if ((sbus_data[0] == 0xF) && (sbus_data[24] == 0x0)) {
    channels_[0] = ((sbus_data[1]) | ((sbus_data[2] & 0x7) << 8));
    channels_[1] = (sbus_data[2] >> 3) | ((sbus_data[3] & 0x3F) << 5);
    channels_[2] = ((sbus_data[3] & 0xC0) >> 6) | (sbus_data[4] << 2) |
                   ((sbus_data[5] & 0x1) << 10);
    channels_[3] = ((sbus_data[5] & 0xFE) >> 1) | ((sbus_data[6] & 0xF) << 7);
    channels_[4] = ((sbus_data[6] & 0xF0) >> 4) | ((sbus_data[7] & 0x7F) << 4);
    channels_[5] = ((sbus_data[7] & 0x80) >> 7) | (sbus_data[8] << 1) |
                   ((sbus_data[9] & 0x3) << 9);
    channels_[6] = ((sbus_data[9] & 0xFC) >> 2) | ((sbus_data[10] & 0x1F) << 6);
    channels_[7] = ((sbus_data[10] & 0xE0) >> 5) | (sbus_data[11] << 3);

    channels_[8] = ((sbus_data[12]) | ((sbus_data[13] & 0x7) << 8));
    channels_[9] = (sbus_data[13] >> 3) | ((sbus_data[14] & 0x3F) << 5);
    channels_[10] = ((sbus_data[14] & 0xC0) >> 6) | (sbus_data[15] << 2) |
                    ((sbus_data[16] & 0x1) << 10);
    channels_[11] =
        ((sbus_data[16] & 0xFE) >> 1) | ((sbus_data[17] & 0xF) << 7);
    channels_[12] =
        ((sbus_data[17] & 0xF0) >> 4) | ((sbus_data[18] & 0x7F) << 4);
    channels_[13] = ((sbus_data[18] & 0x80) >> 7) | (sbus_data[19] << 1) |
                    ((sbus_data[20] & 0x3) << 9);
    channels_[14] =
        ((sbus_data[20] & 0xFC) >> 2) | ((sbus_data[21] & 0x1F) << 6);
    channels_[15] = ((sbus_data[21] & 0xE0) >> 5) | (sbus_data[22] << 3);

    channels_[16] = (sbus_data[23] & 0x80) >> 7;
    channels_[17] = (sbus_data[23] & 0x40) >> 6;

    pthread_mutex_lock(&sbus_data_m);
    for (int i = 0; i < 18; i++) {
      // printf("%d ", channels_[i]);
      channel_data[i] = channels_[i];
    }
    // printf("\n\n");
    pthread_mutex_unlock(&sbus_data_m);

  } else {
    printf("Bad Packet\n");
  }
}

Here is the caller graph for this function: