The basics of CSP

The following diagram shows a conceptual overview of the different blocks in CSP. The shown interface is CAN (src/interfaces/csp_if_can.c, driver: src/drivers/can/can_socketcan.c).

    buffer                  connection   send   read/accept
       ^                         |         |         ^
       |                         |         v         |
       |   +-----------------+   |     +----------------+    +-------------------+
       |   | connection pool |   |     |    CSP Core    |    | csp_task_router() |
       |   |  csp_conn.c     |<--+---->| * routing      |<---|    csp_route.c    |
       |   +-----------------+         | * crypt        |    +-------------------+
       |                               | * UDP/RDP      |              ^
       |                  csp_route_t  | * CRC32        |              |
       v                 +------------>|                |     +----------------+
+--------------+         |             |                |     | incoming queue |
| buffer pool  |         |             |                |     |     qfifo.c    |
| csp_buffer.c |  +-------------+      +----------------+     +----------------+
+--------------+  |routing table|            |                         ^
       ^          |  rtable.c   |            v                         |
       |          +-------------+      +------------------------------------+
       |                               |  (next_hop)                        |
       |                               |    CAN interface (csp_if_can.c)    |
       +------------------------------>|                      csp_can_rx()  |
                                       +------------------------------------+
                                             |   CAN frame (8 bytes)   ^
                                             v                         |
                                     csp_can_tx_frame()       socketcan_rx_thread()
                                             (drivers/can/can_socketcan.c)

Buffer

All buffers are allocated once during initialization of CSP, after this the buffer system is entirely self-contained. All allocated elements are of the same size, so the buffer size must be chosen to be able to handle the maximum possible packet length. The buffer pool uses a queue to store pointers to free buffer elements. First of all, this gives a very quick method to get the next free element since the dequeue is an O(1) operation. Furthermore, since the queue is a protected operating system primitive, it can be accessed from both task-context and interrupt-context. The csp_buffer_get() version is for task-context and csp_buffer_get_isr() is for interrupt-context. Using fixed size buffer elements that are preallocated is again a question of speed and safety.

Definition of a buffer element csp_packet_t:

/**
   CSP Packet.

   This structure is constructed to fit with all interface and protocols to prevent the
   need to copy data (zero copy).

   @note In most cases a CSP packet cannot be reused in case of send failure, because the
   lower layers may add additional data causing increased length (e.g. CRC32), convert
   the CSP id to different endian (e.g. I2C), etc.
*/
typedef struct {
    uint32_t rdp_quarantine;      // EACK quarantine period
    uint32_t timestamp_tx;        // Time the message was sent
    uint32_t timestamp_rx;        // Time the message was received

    uint16_t length;              // Data length
    csp_id_t id;                  // CSP id (unpacked version CPU readable)

    uint8_t * frame_begin;
    uint16_t frame_length;

    /* Additional header bytes, to prepend packed data before transmission
     * This must be minimum 6 bytes to accomodate CSP 2.0. But some implementations
     * require much more scratch working area for encryption for example.
     *
     * Ultimately after csp_id_pack() this area will be filled with the CSP header
     */

    uint8_t header[CSP_PACKET_PADDING_BYTES];

    /**
     * Data part of packet.
     */
    union {
        /** Access data as uint8_t. */
        uint8_t data[0];
        /** Access data as uint16_t */
        uint16_t data16[0];
        /** Access data as uint32_t */
        uint32_t data32[0];
   };

} csp_packet_t;

A basic concept in the buffer system is called Zero-Copy. This means that from userspace to the kernel-driver, the buffer is never copied from one buffer to another. This is a big deal for a small microprocessor, where a call to memcpy() can be very expensive. This is achieved by a number of padding bytes in the buffer, allowing for a header to be prepended at the lower layers without copying the actual payload. This also means that there is a strict contract between the layers, which data can be modified and where.

The padding bytes are used by the I2C interface, where the csp_packet_t will be casted to a csp_i2c_frame_t, when the interface calls the driver Tx function csp_i2c_driver_tx_t:

/**
   I2C frame.
   This struct fits on top of a #csp_packet_t, removing the need for copying data.
*/
typedef struct i2c_frame_s {
    //! Not used  (-> csp_packet_t.padding)
    uint8_t padding[3];
    //! Cleared before Tx  (-> csp_packet_t.padding)
    uint8_t retries;
    //! Not used  (-> csp_packet_t.padding)
    uint32_t reserved;
    //! Destination address  (-> csp_packet_t.padding)
    uint8_t dest;
    //! Cleared before Tx  (-> csp_packet_t.padding)
    uint8_t len_rx;
    //! Length of \a data part  (-> csp_packet_t.length)
    uint16_t len;
    //! CSP id + data  (-> csp_packet_t.id)
    uint8_t data[0];
} csp_i2c_frame_t;

Connection

CSP supports both connection-less and connection-oriented connections. See more about protocols in layer4.

During initialization libcsp allocates the configured number of connections. The required number of connections depends on the application. Here is a list functions, that will allocate a connection from the connection pool:

client connection, call to csp_connect()

server socket for listening csp_socket()

server accepting an incoming connection csp_accept()

An application’s receive queue is located on the connection and is also allocated once during initialization. The length of the queue is the same for all queues, and specified in the configuration.

Send

The data flow from the application to the driver, can basically be broken down into following steps:

if using connection-oriented communication, establish a connection> csp_connect(), csp_accept()

get packet from the buffer pool: csp_buffer_get()

add payload data to the packet

send packet, e.g. csp_send(), csp_sendto()

CSP looks up the destination route, using the routing table, and calls nexthop() on the resolved interface.

The interface (in this case the CAN interface), splits the packet into a number of CAN frames (8 bytes) and forwards them to the driver.

Receive

The data flow from the driver to the application, can basically be broken down into following steps:

the driver layer forwards the raw data frames to the interface, in this case CAN frames

the interface will acquire a free buffer (e.g. csp_buffer_get_isr()) for assembling the CAN frames into a complete packet

once the interface has successfully assembled a packet, the packet is queued for routing - primarily to decouple the interface, e.g. if the interfaces/drivers uses interrupt (ISR).

the router picks up the packet from the incoming queue and routes it on - this can either be to a local destination, or another interface.

the application waits for new packets at its Rx queue, by calling csp_read() or csp_accept in case it is a server socket.

the application can now process the packet, and either send it using e.g. csp_send(), or free the packet using csp_buffer_free().

Routing table

When a packet is routed, the destination address is looked up in the routing table, which results in a csp_route_t record. The record contains the interface (csp_iface_t) the packet is to be sent on, and an optional via address. The via address is used, when the sender cannot directly reach the receiver on one of its connected networks, e.g. sending a packet from the satellite to the ground - the radio will be the via address.

CSP comes with 2 routing table implementations (selected at compile time).

static: supports a one-to-one mapping, meaning routes must be configured per destination address or a single default address. The default address is used, in case there are no routes set for the specific destination address. The static routing table has the fastest lookup, but requires more setup.

cidr (Classless Inter-Domain Routing): supports a one-to-many mapping, meaning routes can be configued for a range of destination addresses. The cidr is a bit slower for lookup, but simple to setup.

Routes can be configured using text strings in the format:

<address>[/mask] <interface name> [via]

address: is the destination address, the routing table will match it against the CSP header destination.

mask (optional): determines how many MSB bits of address are to be matched. mask = 1 will only match the MSB bit, mask = 2 will match 2 MSB bits. Mask values different from 0 and 5, is only supported by the cidr rtable.

interface name: name of the interface to route the packet on.

via (optional) address: if different from 255, route the packet to the via address, instead of the address in the CSP header.

Here are some examples:

“10 I2C” route destination address 10 to the “I2C” interface and send it to address 10 (no via).

“10 I2C 30” route destination address 10 to the “I2C” interface and send it to address 30 (via). The original destination address 10 is not changed in the CSP header of the packet.

“16/1 CAN 4” (CIDR only) route all destination addresses 16-31 to address 4 on the CAN interface.

“0/0 CAN” default route, if no other matching route is found, route packet onto the CAN interface.

Interface

The interface typically implements layer2, and uses drivers from layer1 to send/receive data. The interface is a generic struct, with no knowledge of any specific interface , protocol or driver:

/**
   CSP interface.
*/
struct csp_iface_s {
    uint16_t addr;              // Host address on this subnet
    uint16_t netmask;           // Subnet mask
    const char * name;          // Name, max compare length is #CSP_IFLIST_NAME_MAX
    void * interface_data;      // Interface data, only known/used by the interface layer, e.g. state information.
    void * driver_data;         // Driver data, only known/used by the driver layer, e.g. device/channel references.
    nexthop_t nexthop;          // Next hop (Tx) function
    uint8_t is_default;         // Set default IF flag (CSP supports multiple defaults)
    uint32_t tx;                // Successfully transmitted packets
    uint32_t rx;                // Successfully received packets
    uint32_t tx_error;          // Transmit errors (packets)
    uint32_t rx_error;          // Receive errors, e.g. too large message
    uint32_t drop;              // Dropped packets
    uint32_t autherr;           // Authentication errors (packets)
    uint32_t frame;             // Frame format errors (packets)
    uint32_t txbytes;           // Transmitted bytes
    uint32_t rxbytes;           // Received bytes
    uint32_t irq;               // Interrupts
    struct csp_iface_s * next;  // Internal, interfaces are stored in a linked list
};

If an interface implementation needs to store data, e.g. state information (KISS), it can use the pointer interface_data to reference any data structure needed. The driver implementation can use the pointer driver_data for storing data, e.g. device number.

See function csp_can_socketcan_open_and_add_interface() in src/drivers/can/can_socketcan.c for an example of how to implement a CAN driver and hooking it into CSP, using the CSP standard CAN interface.

Send

When CSP needs to send a packet, it calls nexthop on the interface returned by route lookup. If the interface succeeds in sending the packet, it must free the packet. In case of failure, the packet must not be freed by the interface. The original idea was, that the packet could be retried later on, without having to re-create the packet again. However, the current implementation does not yet fully support this as some interfaces modify the header (endian conversion) or data (adding CRC32).

Receive

When receiving data, the driver calls into the interface with the received data, e.g. csp_can_rx(). The interface will convert/copy the data into a packet (e.g. by assembling all CAN frames). Once a complete packet is received, the packet is queued for later CSP processing, by calling csp_qfifo_write().