transmission.h

Go to the documentation of this file.

#pragma once

#include <stdbool.h>
#include <wio.h>
#include "defs.h"

typedef struct wtp_tx_read_info {
    uint8_t _size;
    uint8_t _n_reads;
} wtp_tx_read_info_t;

typedef struct wtp_tx_fragment {
    uint16_t _seq_num;
    uint16_t _msg_size;

    uint8_t* _data;
    uint8_t _size;

    bool _need_send;
} wtp_tx_fragment_t;

typedef struct wtp_tx_ctrl {
    uint16_t _seq_num;
    uint16_t _window_size;
    uint16_t _timeout;
    uint8_t _read_size;

    wio_buf_t _pkt_buf;
    wio_buf_t _msg_buf;

    uint16_t _pkt_begin;
    uint8_t* _pkt_size;

    uint16_t _msg_begin_seq;
    uint16_t _msg_begin_pos;
    uint16_t _msg_fragmented;

    wio_queue_t _fragments_queue;
    wio_queue_t _read_info_queue;
    wio_queue_t _msg_ends_queue;
} wtp_tx_ctrl_t;

typedef struct wtp_rx_fragment {
    uint16_t _seq_num;
    uint8_t* _data;
    uint8_t _size;

    bool _assembled;
    struct wtp_rx_fragment* _next;
} wtp_rx_fragment_t;

typedef struct wtp_rx_msg_info {
    uint16_t _begin;
    uint16_t _size;

    bool _in_use;
    uint8_t _next;
} wtp_rx_msg_info_t;

typedef struct wtp_rx_ctrl {
    uint16_t _seq_num;
    uint16_t _window_size;

    wio_buf_t _msg_data_buf;

    wio_buf_t _fragments_buf;
    wtp_rx_fragment_t* _fragments_begin;

    wtp_rx_msg_info_t* _msg_info_store;
    uint8_t _msg_info_size;
    uint8_t _msg_info_begin;
} wtp_rx_ctrl_t;

extern wtp_status_t wtp_tx_init(
    wtp_tx_ctrl_t* self,
    uint16_t window_size,
    uint16_t timeout,
    uint16_t read_size,
    uint16_t pkt_buf_size,
    uint16_t msg_buf_size,
    uint8_t n_fragments,
    uint8_t n_msgs
);

extern wtp_status_t wtp_tx_fini(
    wtp_tx_ctrl_t* self
);

extern wtp_status_t wtp_tx_begin_packet(
    wtp_tx_ctrl_t* self,
    wtp_pkt_t pkt_type
);

extern wtp_status_t wtp_tx_end_packet(
    wtp_tx_ctrl_t* self
);

extern wtp_status_t wtp_tx_add_msg(
    wtp_tx_ctrl_t* self,
    uint8_t* data,
    uint16_t size,
    wtp_tx_read_info_t** _read_info
);

extern wtp_status_t wtp_tx_make_fragment(
    wtp_tx_ctrl_t* self,
    uint8_t avail_size,
    wtp_tx_fragment_t** _fragment
);

extern wtp_status_t wtp_tx_handle_ack(
    wtp_tx_ctrl_t* self,
    uint16_t seq_num,
    uint8_t* _n_msgs
);

extern wtp_status_t wtp_rx_init(
    wtp_rx_ctrl_t* self,
    uint16_t window_size,
    uint16_t msg_data_size,
    uint16_t fragments_size,
    uint8_t n_msg_info
);

extern wtp_status_t wtp_rx_fini(
    wtp_rx_ctrl_t* self
);

extern wtp_status_t wtp_rx_handle_packet(
    wtp_rx_ctrl_t* self,
    uint16_t seq_num,
    uint8_t* data,
    uint16_t size,
    uint16_t new_msg_size,
    uint8_t* _n_msgs
);