ssdo.c

Go to the documentation of this file.

#include "co.h"
#include "sdo.h"
#include <lely/co/crc.h>
#include <lely/co/dev.h>
#include <lely/co/obj.h>
#include <lely/co/ssdo.h>
#include <lely/co/val.h>
#include <lely/util/endian.h>
#include <lely/util/errnum.h>

#include <assert.h>
#include <inttypes.h>
#include <stdlib.h>

struct __co_ssdo_state;
typedef const struct __co_ssdo_state co_ssdo_state_t;

struct __co_ssdo {
        can_net_t *net;
        co_dev_t *dev;
        co_unsigned8_t num;
        struct co_sdo_par par;
        can_recv_t *recv;
        int timeout;
        can_timer_t *timer;
        co_ssdo_state_t *state;
        co_unsigned16_t idx;
        co_unsigned8_t subidx;
        uint8_t toggle;
        uint8_t blksize;
        uint8_t ackseq;
        unsigned gencrc : 1;
        uint16_t crc;
        struct co_sdo_req req;
        struct membuf buf;
        size_t nbyte;
};

static int co_ssdo_update(co_ssdo_t *sdo);

static co_unsigned32_t co_1200_dn_ind(
                co_sub_t *sub, struct co_sdo_req *req, void *data);

static int co_ssdo_recv(const struct can_msg *msg, void *data);

static int co_ssdo_timer(const struct timespec *tp, void *data);

static inline void co_ssdo_enter(co_ssdo_t *sdo, co_ssdo_state_t *next);

static inline void co_ssdo_emit_abort(co_ssdo_t *sdo, co_unsigned32_t ac);

static inline void co_ssdo_emit_time(co_ssdo_t *sdo, const struct timespec *tp);

static inline void co_ssdo_emit_recv(co_ssdo_t *sdo, const struct can_msg *msg);

struct __co_ssdo_state {
        co_ssdo_state_t *(*on_abort)(co_ssdo_t *sdo, co_unsigned32_t ac);
        co_ssdo_state_t *(*on_time)(co_ssdo_t *sdo, const struct timespec *tp);
        co_ssdo_state_t *(*on_recv)(co_ssdo_t *sdo, const struct can_msg *msg);
};

#define LELY_CO_DEFINE_STATE(name, ...) \
        static co_ssdo_state_t *const name = &(co_ssdo_state_t){ __VA_ARGS__ };

static co_ssdo_state_t *co_ssdo_wait_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_wait_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_wait_state,
        .on_abort = &co_ssdo_wait_on_abort,
        .on_recv = &co_ssdo_wait_on_recv
)
// clang-format on


static co_ssdo_state_t *co_ssdo_dn_ini_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// LELY_CO_DEFINE_STATE(co_ssdo_dn_ini_state,
//      .on_recv = &co_ssdo_dn_ini_on_recv
//)

static co_ssdo_state_t *co_ssdo_dn_seg_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_dn_seg_on_time(
                co_ssdo_t *sdo, const struct timespec *tp);

static co_ssdo_state_t *co_ssdo_dn_seg_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_dn_seg_state,
        .on_abort = &co_ssdo_dn_seg_on_abort,
        .on_time = &co_ssdo_dn_seg_on_time,
        .on_recv = &co_ssdo_dn_seg_on_recv
)
// clang-format on

static co_ssdo_state_t *co_ssdo_up_ini_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// LELY_CO_DEFINE_STATE(co_ssdo_up_ini_state,
//      .on_recv = &co_ssdo_up_ini_on_recv
//)

static co_ssdo_state_t *co_ssdo_up_seg_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_up_seg_on_time(
                co_ssdo_t *sdo, const struct timespec *tp);

static co_ssdo_state_t *co_ssdo_up_seg_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_up_seg_state,
        .on_abort = &co_ssdo_up_seg_on_abort,
        .on_time = &co_ssdo_up_seg_on_time,
        .on_recv = &co_ssdo_up_seg_on_recv
)
// clang-format on

static co_ssdo_state_t *co_ssdo_blk_dn_ini_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// LELY_CO_DEFINE_STATE(co_ssdo_blk_dn_ini_state,
//      .on_recv = &co_ssdo_blk_dn_ini_on_recv
//)

static co_ssdo_state_t *co_ssdo_blk_dn_sub_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_blk_dn_sub_on_time(
                co_ssdo_t *sdo, const struct timespec *tp);

static co_ssdo_state_t *co_ssdo_blk_dn_sub_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_blk_dn_sub_state,
        .on_abort = &co_ssdo_blk_dn_sub_on_abort,
        .on_time = &co_ssdo_blk_dn_sub_on_time,
        .on_recv = &co_ssdo_blk_dn_sub_on_recv
)
// clang-format on

static co_ssdo_state_t *co_ssdo_blk_dn_end_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_blk_dn_end_on_time(
                co_ssdo_t *sdo, const struct timespec *tp);

static co_ssdo_state_t *co_ssdo_blk_dn_end_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_blk_dn_end_state,
        .on_abort = &co_ssdo_blk_dn_end_on_abort,
        .on_time = &co_ssdo_blk_dn_end_on_time,
        .on_recv = &co_ssdo_blk_dn_end_on_recv
)
// clang-format on

static co_ssdo_state_t *co_ssdo_blk_up_ini_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// LELY_CO_DEFINE_STATE(co_ssdo_blk_up_ini_state,
//      .on_recv = &co_ssdo_blk_up_ini_on_recv
//)

static co_ssdo_state_t *co_ssdo_blk_up_sub_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_blk_up_sub_on_time(
                co_ssdo_t *sdo, const struct timespec *tp);

static co_ssdo_state_t *co_ssdo_blk_up_sub_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_blk_up_sub_state,
        .on_abort = &co_ssdo_blk_up_sub_on_abort,
        .on_time = &co_ssdo_blk_up_sub_on_time,
        .on_recv = &co_ssdo_blk_up_sub_on_recv
)
// clang-format on

static co_ssdo_state_t *co_ssdo_blk_up_end_on_abort(
                co_ssdo_t *sdo, co_unsigned32_t ac);

static co_ssdo_state_t *co_ssdo_blk_up_end_on_time(
                co_ssdo_t *sdo, const struct timespec *tp);

static co_ssdo_state_t *co_ssdo_blk_up_end_on_recv(
                co_ssdo_t *sdo, const struct can_msg *msg);

// clang-format off
LELY_CO_DEFINE_STATE(co_ssdo_blk_up_end_state,
        .on_abort = &co_ssdo_blk_up_end_on_abort,
        .on_time = &co_ssdo_blk_up_end_on_time,
        .on_recv = &co_ssdo_blk_up_end_on_recv
)
// clang-format on

#undef LELY_CO_DEFINE_STATE

static co_ssdo_state_t *co_ssdo_abort_ind(co_ssdo_t *sdo);

static co_ssdo_state_t *co_ssdo_abort_res(co_ssdo_t *sdo, co_unsigned32_t ac);

static co_unsigned32_t co_ssdo_dn_ind(co_ssdo_t *sdo);

static co_unsigned32_t co_ssdo_up_ind(co_ssdo_t *sdo);

static co_unsigned32_t co_ssdo_up_buf(co_ssdo_t *sdo, size_t nbyte);

static void co_ssdo_send_abort(co_ssdo_t *sdo, co_unsigned32_t ac);

static void co_ssdo_send_dn_ini_res(co_ssdo_t *sdo);

static void co_ssdo_send_dn_seg_res(co_ssdo_t *sdo);

static void co_ssdo_send_up_exp_res(co_ssdo_t *sdo);

static void co_ssdo_send_up_ini_res(co_ssdo_t *sdo);

static void co_ssdo_send_up_seg_res(co_ssdo_t *sdo, int last);

static void co_ssdo_send_blk_dn_ini_res(co_ssdo_t *sdo);

static void co_ssdo_send_blk_dn_sub_res(co_ssdo_t *sdo);

static void co_ssdo_send_blk_dn_end_res(co_ssdo_t *sdo);

static void co_ssdo_send_blk_up_ini_res(co_ssdo_t *sdo);

static void co_ssdo_send_blk_up_sub_res(co_ssdo_t *sdo, int last);

static void co_ssdo_send_blk_up_end_res(co_ssdo_t *sdo);

static void co_ssdo_init_ini_res(
                co_ssdo_t *sdo, struct can_msg *msg, uint8_t cs);

static void co_ssdo_init_seg_res(
                co_ssdo_t *sdo, struct can_msg *msg, uint8_t cs);

void *
__co_ssdo_alloc(void)
{
        void *ptr = malloc(sizeof(struct __co_ssdo));
        if (__unlikely(!ptr))
                set_errc(errno2c(errno));
        return ptr;
}

void
__co_ssdo_free(void *ptr)
{
        free(ptr);
}

struct __co_ssdo *
__co_ssdo_init(struct __co_ssdo *sdo, can_net_t *net, co_dev_t *dev,
                co_unsigned8_t num)
{
        assert(sdo);
        assert(net);
        assert(dev);

        int errc = 0;

        if (__unlikely(!num || num > 128)) {
                errc = errnum2c(ERRNUM_INVAL);
                goto error_param;
        }

        // Find the SDO server parameter in the object dictionary. The default
        // SDO (1200) is optional.
        co_obj_t *obj_1200 = co_dev_find_obj(dev, 0x1200 + num - 1);
        if (__unlikely(num != 1 && !obj_1200)) {
                errc = errnum2c(ERRNUM_INVAL);
                goto error_param;
        }

        sdo->net = net;
        sdo->dev = dev;
        sdo->num = num;

        // Initialize the SDO parameter record with the default values.
        sdo->par.n = 3;
        sdo->par.id = co_dev_get_id(dev);
        sdo->par.cobid_req = 0x600 + sdo->par.id;
        sdo->par.cobid_res = 0x580 + sdo->par.id;

        if (obj_1200) {
                // Copy the SDO parameter record.
                size_t size = co_obj_sizeof_val(obj_1200);
                memcpy(&sdo->par, co_obj_addressof_val(obj_1200),
                                MIN(size, sizeof(sdo->par)));
        }

        sdo->recv = can_recv_create();
        if (__unlikely(!sdo->recv)) {
                errc = get_errc();
                goto error_create_recv;
        }
        can_recv_set_func(sdo->recv, &co_ssdo_recv, sdo);

        sdo->timeout = 0;

        sdo->timer = can_timer_create();
        if (__unlikely(!sdo->timer)) {
                errc = get_errc();
                goto error_create_timer;
        }
        can_timer_set_func(sdo->timer, &co_ssdo_timer, sdo);

        sdo->state = co_ssdo_wait_state;

        sdo->idx = 0;
        sdo->subidx = 0;

        sdo->toggle = 0;
        sdo->blksize = 0;
        sdo->ackseq = 0;
        sdo->gencrc = 0;
        sdo->crc = 0;

        co_sdo_req_init(&sdo->req);
        membuf_init(&sdo->buf);
        sdo->nbyte = 0;

        // Set the download indication function for the SDO parameter record.
        if (obj_1200)
                co_obj_set_dn_ind(obj_1200, &co_1200_dn_ind, sdo);

        if (__unlikely(co_ssdo_update(sdo) == -1)) {
                errc = get_errc();
                goto error_update;
        }

        return sdo;

error_update:
        if (obj_1200)
                co_obj_set_dn_ind(obj_1200, NULL, NULL);
        can_timer_destroy(sdo->timer);
error_create_timer:
        can_recv_destroy(sdo->recv);
error_create_recv:
error_param:
        set_errc(errc);
        return NULL;
}

void
__co_ssdo_fini(struct __co_ssdo *sdo)
{
        assert(sdo);
        assert(sdo->num >= 1 && sdo->num <= 128);

        // Remove the download indication functions for the SDO parameter
        // record.
        co_obj_t *obj_1200 = co_dev_find_obj(sdo->dev, 0x1200 + sdo->num - 1);
        if (obj_1200)
                co_obj_set_dn_ind(obj_1200, NULL, NULL);

        // Abort any ongoing transfer.
        co_ssdo_emit_abort(sdo, CO_SDO_AC_NO_SDO);

        membuf_fini(&sdo->buf);
        co_sdo_req_fini(&sdo->req);

        can_timer_destroy(sdo->timer);

        can_recv_destroy(sdo->recv);
}

co_ssdo_t *
co_ssdo_create(can_net_t *net, co_dev_t *dev, co_unsigned8_t num)
{
        trace("creating Server-SDO %d", num);

        int errc = 0;

        co_ssdo_t *sdo = __co_ssdo_alloc();
        if (__unlikely(!sdo)) {
                errc = get_errc();
                goto error_alloc_sdo;
        }

        if (__unlikely(!__co_ssdo_init(sdo, net, dev, num))) {
                errc = get_errc();
                goto error_init_sdo;
        }

        return sdo;

error_init_sdo:
        __co_ssdo_free(sdo);
error_alloc_sdo:
        set_errc(errc);
        return NULL;
}

void
co_ssdo_destroy(co_ssdo_t *ssdo)
{
        if (ssdo) {
                trace("destroying Server-SDO %d", ssdo->num);
                __co_ssdo_fini(ssdo);
                __co_ssdo_free(ssdo);
        }
}

can_net_t *
co_ssdo_get_net(const co_ssdo_t *sdo)
{
        assert(sdo);

        return sdo->net;
}

co_dev_t *
co_ssdo_get_dev(const co_ssdo_t *sdo)
{
        assert(sdo);

        return sdo->dev;
}

co_unsigned8_t
co_ssdo_get_num(const co_ssdo_t *sdo)
{
        assert(sdo);

        return sdo->num;
}

const struct co_sdo_par *
co_ssdo_get_par(const co_ssdo_t *sdo)
{
        assert(sdo);

        return &sdo->par;
}

int
co_ssdo_get_timeout(const co_ssdo_t *sdo)
{
        assert(sdo);

        return sdo->timeout;
}

void
co_ssdo_set_timeout(co_ssdo_t *sdo, int timeout)
{
        assert(sdo);

        if (sdo->timeout && timeout <= 0)
                can_timer_stop(sdo->timer);

        sdo->timeout = MAX(0, timeout);
}

static int
co_ssdo_update(co_ssdo_t *sdo)
{
        assert(sdo);

        // Abort any ongoing transfer.
        co_ssdo_emit_abort(sdo, CO_SDO_AC_NO_SDO);

        int valid_req = !(sdo->par.cobid_req & CO_SDO_COBID_VALID);
        int valid_res = !(sdo->par.cobid_res & CO_SDO_COBID_VALID);
        if (valid_req && valid_res) {
                uint32_t id = sdo->par.cobid_req;
                uint8_t flags = 0;
                if (id & CO_SDO_COBID_FRAME) {
                        id &= CAN_MASK_EID;
                        flags |= CAN_FLAG_IDE;
                } else {
                        id &= CAN_MASK_BID;
                }
                can_recv_start(sdo->recv, sdo->net, id, flags);
        } else {
                can_recv_stop(sdo->recv);
        }

        return 0;
}

static co_unsigned32_t
co_1200_dn_ind(co_sub_t *sub, struct co_sdo_req *req, void *data)
{
        assert(sub);
        assert(req);
        co_ssdo_t *sdo = data;
        assert(sdo);
        assert(co_obj_get_idx(co_sub_get_obj(sub)) == 0x1200 + sdo->num - 1);

        co_unsigned32_t ac = 0;

        co_unsigned16_t type = co_sub_get_type(sub);
        union co_val val;
        if (__unlikely(co_sdo_req_dn_val(req, type, &val, &ac) == -1))
                return ac;

        switch (co_sub_get_subidx(sub)) {
        case 0: ac = CO_SDO_AC_NO_WRITE; goto error;
        case 1: {
                assert(type == CO_DEFTYPE_UNSIGNED32);
                co_unsigned32_t cobid = val.u32;
                co_unsigned32_t cobid_old = co_sub_get_val_u32(sub);
                if (cobid == cobid_old)
                        goto error;

                // The CAN-ID cannot be changed when the SDO is and remains
                // valid.
                int valid = !(cobid & CO_SDO_COBID_VALID);
                int valid_old = !(cobid_old & CO_SDO_COBID_VALID);
                uint32_t canid = cobid & CAN_MASK_EID;
                uint32_t canid_old = cobid_old & CAN_MASK_EID;
                if (__unlikely(valid && valid_old && canid != canid_old)) {
                        ac = CO_SDO_AC_PARAM_VAL;
                        goto error;
                }

                // A 29-bit CAN-ID is only valid if the frame bit is set.
                // clang-format off
                if (__unlikely(!(cobid & CO_SDO_COBID_FRAME)
                                && (cobid & (CAN_MASK_EID ^ CAN_MASK_BID)))) {
                        // clang-format on
                        ac = CO_SDO_AC_PARAM_VAL;
                        goto error;
                }

                sdo->par.cobid_req = cobid;
                break;
        }
        case 2: {
                assert(type == CO_DEFTYPE_UNSIGNED32);
                co_unsigned32_t cobid = val.u32;
                co_unsigned32_t cobid_old = co_sub_get_val_u32(sub);
                if (cobid == cobid_old)
                        goto error;

                // The CAN-ID cannot be changed when the SDO is and remains
                // valid.
                int valid = !(cobid & CO_SDO_COBID_VALID);
                int valid_old = !(cobid_old & CO_SDO_COBID_VALID);
                uint32_t canid = cobid & CAN_MASK_EID;
                uint32_t canid_old = cobid_old & CAN_MASK_EID;
                if (__unlikely(valid && valid_old && canid != canid_old)) {
                        ac = CO_SDO_AC_PARAM_VAL;
                        goto error;
                }

                // A 29-bit CAN-ID is only valid if the frame bit is set.
                // clang-format off
                if (__unlikely(!(cobid & CO_SDO_COBID_FRAME)
                                && (cobid & (CAN_MASK_EID ^ CAN_MASK_BID)))) {
                        // clang-format on
                        ac = CO_SDO_AC_PARAM_VAL;
                        goto error;
                }

                sdo->par.cobid_res = cobid;
                break;
        }
        case 3: {
                assert(type == CO_DEFTYPE_UNSIGNED8);
                co_unsigned8_t id = val.u8;
                co_unsigned8_t id_old = co_sub_get_val_u8(sub);
                if (id == id_old)
                        goto error;

                sdo->par.id = id;
                break;
        }
        default: ac = CO_SDO_AC_NO_SUB; goto error;
        }

        co_sub_dn(sub, &val);
        co_val_fini(type, &val);

        co_ssdo_update(sdo);
        return 0;

error:
        co_val_fini(type, &val);
        return ac;
}

static int
co_ssdo_recv(const struct can_msg *msg, void *data)
{
        assert(msg);
        co_ssdo_t *sdo = data;
        assert(sdo);

        // Ignore remote frames.
        if (__unlikely(msg->flags & CAN_FLAG_RTR))
                return 0;

#ifndef LELY_NO_CANFD
        // Ignore CAN FD format frames.
        if (__unlikely(msg->flags & CAN_FLAG_EDL))
                return 0;
#endif

        co_ssdo_emit_recv(sdo, msg);

        return 0;
}

static int
co_ssdo_timer(const struct timespec *tp, void *data)
{
        assert(tp);
        co_ssdo_t *sdo = data;
        assert(sdo);

        co_ssdo_emit_time(sdo, tp);

        return 0;
}

static inline void
co_ssdo_enter(co_ssdo_t *sdo, co_ssdo_state_t *next)
{
        assert(sdo);

        if (next)
                sdo->state = next;
}

static inline void
co_ssdo_emit_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        assert(sdo);
        assert(sdo->state);
        assert(sdo->state->on_recv);

        co_ssdo_enter(sdo, sdo->state->on_abort(sdo, ac));
}

static inline void
co_ssdo_emit_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        assert(sdo);
        assert(sdo->state);
        assert(sdo->state->on_time);

        co_ssdo_enter(sdo, sdo->state->on_time(sdo, tp));
}

static inline void
co_ssdo_emit_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(sdo->state);
        assert(sdo->state->on_recv);

        co_ssdo_enter(sdo, sdo->state->on_recv(sdo, msg));
}

static co_ssdo_state_t *
co_ssdo_wait_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        (void)sdo;
        (void)ac;

        return NULL;
}

static co_ssdo_state_t *
co_ssdo_wait_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        switch (cs & CO_SDO_CS_MASK) {
        case CO_SDO_CCS_DN_INI_REQ: return co_ssdo_dn_ini_on_recv(sdo, msg);
        case CO_SDO_CCS_UP_INI_REQ: return co_ssdo_up_ini_on_recv(sdo, msg);
        case CO_SDO_CCS_BLK_DN_REQ: return co_ssdo_blk_dn_ini_on_recv(sdo, msg);
        case CO_SDO_CCS_BLK_UP_REQ: return co_ssdo_blk_up_ini_on_recv(sdo, msg);
        case CO_SDO_CS_ABORT: return NULL;
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }
}

static co_ssdo_state_t *
co_ssdo_dn_ini_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        assert(msg->len > 0);
        uint8_t cs = msg->data[0];

        // Load the object index and sub-index from the CAN frame.
        if (__unlikely(msg->len < 3))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_OBJ);
        sdo->idx = ldle_u16(msg->data + 1);
        if (__unlikely(msg->len < 4))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_SUB);
        sdo->subidx = msg->data[3];

        trace("SSDO: %04X:%02X: received download request", sdo->idx,
                        sdo->subidx);

        // Obtain the size from the command specifier.
        co_sdo_req_clear(&sdo->req);
        int exp = !!(cs & CO_SDO_INI_SIZE_EXP);
        if (exp) {
                if (cs & CO_SDO_INI_SIZE_IND)
                        sdo->req.size = CO_SDO_INI_SIZE_EXP_GET(cs);
                else
                        sdo->req.size = msg->len - 4;
        } else if (cs & CO_SDO_INI_SIZE_IND) {
                if (__unlikely(msg->len < 8))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
                sdo->req.size = ldle_u32(msg->data + 4);
        }

        if (exp) {
                // Perform an expedited transfer.
                sdo->req.buf = msg->data + 4;
                sdo->req.nbyte = sdo->req.size;
                co_unsigned32_t ac = co_ssdo_dn_ind(sdo);
                if (__unlikely(ac))
                        return co_ssdo_abort_res(sdo, ac);
                // Finalize the transfer.
                co_ssdo_send_dn_ini_res(sdo);
                return co_ssdo_abort_ind(sdo);
        } else {
                co_ssdo_send_dn_ini_res(sdo);
                if (sdo->timeout)
                        can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
                return co_ssdo_dn_seg_state;
        }
}

static co_ssdo_state_t *
co_ssdo_dn_seg_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        return co_ssdo_abort_res(sdo, ac);
}

static co_ssdo_state_t *
co_ssdo_dn_seg_on_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        (void)tp;

        return co_ssdo_abort_res(sdo, CO_SDO_AC_TIMEOUT);
}

static co_ssdo_state_t *
co_ssdo_dn_seg_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        // Check the client command specifier.
        switch (cs & CO_SDO_CS_MASK) {
        case CO_SDO_CCS_DN_SEG_REQ: break;
        case CO_SDO_CS_ABORT: return co_ssdo_abort_ind(sdo);
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }

        // Check the value of the toggle bit.
        if (__unlikely((cs & CO_SDO_SEG_TOGGLE) != sdo->toggle))
                return co_ssdo_dn_seg_state;

        // Obtain the size of the segment.
        size_t n = CO_SDO_SEG_SIZE_GET(cs);
        if (__unlikely(msg->len < 1 + n))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        int last = !!(cs & CO_SDO_SEG_LAST);

        sdo->req.buf = msg->data + 1;
        sdo->req.offset += sdo->req.nbyte;
        sdo->req.nbyte = n;

        if (__unlikely(last && !co_sdo_req_last(&sdo->req)))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_TYPE_LEN);

        co_unsigned32_t ac = co_ssdo_dn_ind(sdo);
        if (__unlikely(ac))
                return co_ssdo_abort_res(sdo, ac);

        co_ssdo_send_dn_seg_res(sdo);

        if (last) {
                return co_ssdo_abort_ind(sdo);
        } else {
                if (sdo->timeout)
                        can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
                return co_ssdo_dn_seg_state;
        }
}

static co_ssdo_state_t *
co_ssdo_up_ini_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        // Load the object index and sub-index from the CAN frame.
        if (__unlikely(msg->len < 3))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_OBJ);
        sdo->idx = ldle_u16(msg->data + 1);
        if (__unlikely(msg->len < 4))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_SUB);
        sdo->subidx = msg->data[3];

        trace("SSDO: %04X:%02X: received upload request", sdo->idx,
                        sdo->subidx);

        // Perform access checks and start serializing the value.
        co_sdo_req_clear(&sdo->req);
        co_unsigned32_t ac = co_ssdo_up_ind(sdo);
        if (__unlikely(ac))
                return co_ssdo_abort_res(sdo, ac);

        if (sdo->req.size && sdo->req.size <= 4) {
                // Perform an expedited transfer.
                if (__unlikely((ac = co_ssdo_up_buf(sdo, sdo->req.size)) != 0))
                        return co_ssdo_abort_res(sdo, ac);
                co_ssdo_send_up_exp_res(sdo);
                return co_ssdo_abort_ind(sdo);
        } else {
                co_ssdo_send_up_ini_res(sdo);
                if (sdo->timeout)
                        can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
                return co_ssdo_up_seg_state;
        }
}

static co_ssdo_state_t *
co_ssdo_up_seg_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        return co_ssdo_abort_res(sdo, ac);
}

static co_ssdo_state_t *
co_ssdo_up_seg_on_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        (void)tp;

        return co_ssdo_abort_res(sdo, CO_SDO_AC_TIMEOUT);
}

static co_ssdo_state_t *
co_ssdo_up_seg_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        // Check the client command specifier.
        switch (cs & CO_SDO_CS_MASK) {
        case CO_SDO_CCS_UP_SEG_REQ: break;
        case CO_SDO_CS_ABORT: return co_ssdo_abort_ind(sdo);
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }

        // Check the value of the toggle bit.
        if (__unlikely((cs & CO_SDO_SEG_TOGGLE) != sdo->toggle))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_TOGGLE);

        membuf_clear(&sdo->buf);
        co_unsigned32_t ac = co_ssdo_up_buf(sdo, 7);
        if (__unlikely(ac))
                return co_ssdo_abort_res(sdo, ac);

        int last = co_sdo_req_last(&sdo->req) && sdo->nbyte == sdo->req.nbyte;
        co_ssdo_send_up_seg_res(sdo, last);

        if (last) {
                // Finalize the transfer.
                return co_ssdo_abort_ind(sdo);
        } else {
                if (sdo->timeout)
                        can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
                return co_ssdo_up_seg_state;
        }
}

static co_ssdo_state_t *
co_ssdo_blk_dn_ini_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        assert(msg->len > 0);
        uint8_t cs = msg->data[0];

        // Check the client subcommand.
        if (__unlikely((cs & 0x01) != CO_SDO_SC_INI_BLK))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);

        // Check if the client supports generating a CRC.
        sdo->gencrc = !!(cs & CO_SDO_BLK_CRC);

        // Load the object index and sub-index from the CAN frame.
        if (__unlikely(msg->len < 3))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_OBJ);
        sdo->idx = ldle_u16(msg->data + 1);
        if (__unlikely(msg->len < 4))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_SUB);
        sdo->subidx = msg->data[3];

        trace("SSDO: %04X:%02X: received block download request", sdo->idx,
                        sdo->subidx);

        // Obtain the data set size.
        co_sdo_req_clear(&sdo->req);
        if (cs & CO_SDO_BLK_SIZE_IND) {
                if (__unlikely(msg->len < 8))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
                sdo->req.size = ldle_u32(msg->data + 4);
        }

        // Use the maximum block size by default.
        sdo->blksize = CO_SDO_MAX_SEQNO;
        sdo->ackseq = 0;

        co_ssdo_send_blk_dn_ini_res(sdo);

        if (sdo->timeout)
                can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
        return co_ssdo_blk_dn_sub_state;
}

static co_ssdo_state_t *
co_ssdo_blk_dn_sub_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        return co_ssdo_abort_res(sdo, ac);
}

static co_ssdo_state_t *
co_ssdo_blk_dn_sub_on_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        (void)tp;

        return co_ssdo_abort_res(sdo, CO_SDO_AC_TIMEOUT);
}

static co_ssdo_state_t *
co_ssdo_blk_dn_sub_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        if (__unlikely(cs == CO_SDO_CS_ABORT))
                return co_ssdo_abort_ind(sdo);

        uint8_t seqno = cs & ~CO_SDO_SEQ_LAST;
        int last = !!(cs & CO_SDO_SEQ_LAST);

        if (__unlikely(!seqno || seqno > sdo->blksize))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_BLK_SEQ);

        // Only accept sequential segments. Dropped segments will be resent
        // after the confirmation message.
        if (seqno == sdo->ackseq + 1) {
                sdo->ackseq++;
                // Update the CRC.
                if (sdo->gencrc)
                        sdo->crc = co_crc(
                                        sdo->crc, sdo->req.buf, sdo->req.nbyte);
                // Pass the previous frame to the download indication function.
                co_unsigned32_t ac = co_ssdo_dn_ind(sdo);
                if (__unlikely(ac))
                        return co_ssdo_abort_res(sdo, ac);
                // Copy the new frame to the SDO request.
                membuf_clear(&sdo->buf);
                if (__unlikely(!membuf_reserve(&sdo->buf, 7)))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_MEM);
                membuf_write(&sdo->buf, msg->data + 1, 7);
                sdo->req.buf = membuf_begin(&sdo->buf);
                sdo->req.offset += sdo->req.nbyte;
                sdo->req.nbyte = membuf_size(&sdo->buf);
        }

        // If this is the last segment in the block, send a confirmation.
        if (seqno == sdo->blksize || last) {
                co_ssdo_send_blk_dn_sub_res(sdo);
                sdo->ackseq = 0;
        }

        if (sdo->timeout)
                can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
        return last ? co_ssdo_blk_dn_end_state : co_ssdo_blk_dn_sub_state;
}

static co_ssdo_state_t *
co_ssdo_blk_dn_end_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        return co_ssdo_abort_res(sdo, ac);
}

static co_ssdo_state_t *
co_ssdo_blk_dn_end_on_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        (void)tp;

        return co_ssdo_abort_res(sdo, CO_SDO_AC_TIMEOUT);
}

static co_ssdo_state_t *
co_ssdo_blk_dn_end_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        // Check the client command specifier.
        switch (cs & CO_SDO_CS_MASK) {
        case CO_SDO_CCS_BLK_DN_REQ: break;
        case CO_SDO_CS_ABORT: return co_ssdo_abort_ind(sdo);
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }

        // Check the client subcommand.
        if (__unlikely((cs & CO_SDO_SC_MASK) != CO_SDO_SC_END_BLK))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);

        // Discard the bytes in the last segment that did not contain data.
        sdo->req.nbyte -= 7 - CO_SDO_BLK_SIZE_GET(cs);

        // Check the CRC.
        if (sdo->gencrc) {
                sdo->crc = co_crc(sdo->crc, sdo->req.buf, sdo->req.nbyte);
                uint16_t crc = ldle_u16(msg->data + 1);
                if (__unlikely(sdo->crc != crc))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_BLK_CRC);
        }

        co_unsigned32_t ac = co_ssdo_dn_ind(sdo);
        if (__unlikely(ac))
                return co_ssdo_abort_res(sdo, ac);

        // Finalize the transfer.
        co_ssdo_send_blk_dn_end_res(sdo);
        return co_ssdo_abort_ind(sdo);
}

static co_ssdo_state_t *
co_ssdo_blk_up_ini_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        assert(msg->len > 0);
        uint8_t cs = msg->data[0];

        // Check the client subcommand.
        if (__unlikely((cs & CO_SDO_SC_MASK) != CO_SDO_SC_INI_BLK))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);

        // Check if the client supports generating a CRC.
        sdo->gencrc = !!(cs & CO_SDO_BLK_CRC);

        // Load the object index and sub-index from the CAN frame.
        if (__unlikely(msg->len < 3))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_OBJ);
        sdo->idx = ldle_u16(msg->data + 1);
        if (__unlikely(msg->len < 4))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_SUB);
        sdo->subidx = msg->data[3];

        trace("SSDO: %04X:%02X: received block upload request", sdo->idx,
                        sdo->subidx);

        // Load the number of segments per block.
        if (__unlikely(msg->len < 5))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_BLK_SIZE);
        sdo->blksize = msg->data[4];
        if (__unlikely(!sdo->blksize || sdo->blksize > CO_SDO_MAX_SEQNO))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_BLK_SIZE);

        // Load the protocol switch threshold (PST).
        uint8_t pst = msg->len > 5 ? msg->data[5] : 0;

        // Perform access checks and start serializing the value.
        co_sdo_req_clear(&sdo->req);
        co_unsigned32_t ac = co_ssdo_up_ind(sdo);
        if (__unlikely(ac))
                return co_ssdo_abort_res(sdo, ac);

        if (pst && sdo->req.size <= pst) {
                // If the PST is non-zero, and the number of bytes is smaller
                // than or equal to the PST, switch to the SDO upload protocol.
                if (sdo->req.size <= 4) {
                        // Perform an expedited transfer.
                        // clang-format off
                        if (__unlikely((ac = co_ssdo_up_buf(sdo, sdo->req.size))
                                        != 0))
                                // clang-format on
                                return co_ssdo_abort_res(sdo, ac);
                        co_ssdo_send_up_exp_res(sdo);
                        return co_ssdo_abort_ind(sdo);
                } else {
                        co_ssdo_send_up_ini_res(sdo);
                        if (sdo->timeout)
                                can_timer_timeout(sdo->timer, sdo->net,
                                                sdo->timeout);
                        return co_ssdo_up_seg_state;
                }
        } else {
                co_ssdo_send_blk_up_ini_res(sdo);
                if (sdo->timeout)
                        can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);
                return co_ssdo_blk_up_sub_state;
        }
}

static co_ssdo_state_t *
co_ssdo_blk_up_sub_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        return co_ssdo_abort_res(sdo, ac);
}

static co_ssdo_state_t *
co_ssdo_blk_up_sub_on_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        (void)tp;

        return co_ssdo_abort_res(sdo, CO_SDO_AC_TIMEOUT);
}

static co_ssdo_state_t *
co_ssdo_blk_up_sub_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        // Check the client command specifier.
        switch (cs & CO_SDO_CS_MASK) {
        case CO_SDO_CCS_BLK_UP_REQ: break;
        case CO_SDO_CS_ABORT: return co_ssdo_abort_ind(sdo);
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }

        // Check the client subcommand.
        switch (cs & CO_SDO_SC_MASK) {
        case CO_SDO_SC_BLK_RES:
                if (__unlikely(co_sdo_req_first(&sdo->req) && !sdo->nbyte))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);

                if (__unlikely(msg->len < 3))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_BLK_SEQ);

                // Flush the successfully sent segments from the buffer.
                uint8_t ackseq = msg->data[1];
                membuf_flush(&sdo->buf, ackseq * 7);

                // Read the number of segments in the next block.
                sdo->blksize = msg->data[2];
                // clang-format off
                if (__unlikely(!sdo->blksize
                                || sdo->blksize > CO_SDO_MAX_SEQNO))
                        // clang-format on
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_BLK_SIZE);

                break;
        case CO_SDO_SC_START_UP:
                if (__unlikely(!(co_sdo_req_first(&sdo->req) && !sdo->nbyte)))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
                break;
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }

        ptrdiff_t n = sdo->blksize * 7 - membuf_size(&sdo->buf);
        if (n > 0) {
                if (__unlikely(!membuf_reserve(&sdo->buf, n)))
                        return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_MEM);
                co_unsigned32_t ac = co_ssdo_up_buf(sdo, n);
                if (__unlikely(ac))
                        return co_ssdo_abort_res(sdo, ac);
                sdo->blksize = (uint8_t)((membuf_size(&sdo->buf) + 6) / 7);
        }
        int last = co_sdo_req_last(&sdo->req) && sdo->nbyte == sdo->req.nbyte;

        if (sdo->timeout)
                can_timer_timeout(sdo->timer, sdo->net, sdo->timeout);

        if (sdo->blksize) {
                // Send all segments in the current block.
                co_ssdo_send_blk_up_sub_res(sdo, last);
                return co_ssdo_blk_up_sub_state;
        } else {
                co_ssdo_send_blk_up_end_res(sdo);
                return co_ssdo_blk_up_end_state;
        }
}

static co_ssdo_state_t *
co_ssdo_blk_up_end_on_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        return co_ssdo_abort_res(sdo, ac);
}

static co_ssdo_state_t *
co_ssdo_blk_up_end_on_time(co_ssdo_t *sdo, const struct timespec *tp)
{
        (void)tp;

        return co_ssdo_abort_res(sdo, CO_SDO_AC_TIMEOUT);
}

static co_ssdo_state_t *
co_ssdo_blk_up_end_on_recv(co_ssdo_t *sdo, const struct can_msg *msg)
{
        assert(sdo);
        assert(msg);

        if (__unlikely(msg->len < 1))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        uint8_t cs = msg->data[0];

        // Check the client command specifier.
        switch (cs & CO_SDO_CS_MASK) {
        case CO_SDO_CCS_BLK_UP_REQ: break;
        case CO_SDO_CS_ABORT: return co_ssdo_abort_ind(sdo);
        default: return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);
        }

        // Check the client subcommand.
        if (__unlikely((cs & CO_SDO_SC_MASK) != CO_SDO_SC_END_BLK))
                return co_ssdo_abort_res(sdo, CO_SDO_AC_NO_CS);

        return co_ssdo_abort_ind(sdo);
}

static co_ssdo_state_t *
co_ssdo_abort_ind(co_ssdo_t *sdo)
{
        assert(sdo);

        if (sdo->timeout)
                can_timer_stop(sdo->timer);

        sdo->idx = 0;
        sdo->subidx = 0;

        sdo->toggle = 0;
        sdo->blksize = 0;
        sdo->ackseq = 0;
        sdo->gencrc = 0;
        sdo->crc = 0;

        co_sdo_req_clear(&sdo->req);
        membuf_clear(&sdo->buf);
        sdo->nbyte = 0;

        return co_ssdo_wait_state;
}

static co_ssdo_state_t *
co_ssdo_abort_res(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        trace("SSDO: abort code %08" PRIX32 " (%s)", ac, co_sdo_ac2str(ac));
        co_ssdo_send_abort(sdo, ac);
        return co_ssdo_abort_ind(sdo);
}

static co_unsigned32_t
co_ssdo_dn_ind(co_ssdo_t *sdo)
{
        assert(sdo);

        // Find the object in the object dictionary.
        co_obj_t *obj = co_dev_find_obj(sdo->dev, sdo->idx);
        if (__unlikely(!obj))
                return CO_SDO_AC_NO_OBJ;

        // Find the sub-object.
        co_sub_t *sub = co_obj_find_sub(obj, sdo->subidx);
        if (__unlikely(!sub))
                return CO_SDO_AC_NO_SUB;

        return co_sub_dn_ind(sub, &sdo->req);
}

static co_unsigned32_t
co_ssdo_up_ind(co_ssdo_t *sdo)
{
        assert(sdo);

        // Find the object in the object dictionary.
        const co_obj_t *obj = co_dev_find_obj(sdo->dev, sdo->idx);
        if (__unlikely(!obj))
                return CO_SDO_AC_NO_OBJ;

        // Find the sub-object.
        const co_sub_t *sub = co_obj_find_sub(obj, sdo->subidx);
        if (__unlikely(!sub))
                return CO_SDO_AC_NO_SUB;

        // If the object is an array, check whether the element exists.
        // clang-format off
        if (co_obj_get_code(obj) == CO_OBJECT_ARRAY && __unlikely(sdo->subidx
                        > co_obj_get_val_u8(obj, 0x00)))
                // clang-format on
                return CO_SDO_AC_NO_DATA;

        sdo->nbyte = 0;
        return co_sub_up_ind(sub, &sdo->req);
}

static co_unsigned32_t
co_ssdo_up_buf(co_ssdo_t *sdo, size_t nbyte)
{
        co_unsigned32_t ac = 0;

        if (__unlikely(nbyte && !membuf_reserve(&sdo->buf, nbyte)))
                return CO_SDO_AC_NO_MEM;

        while (nbyte) {
                if (sdo->nbyte >= sdo->req.nbyte) {
                        if (co_sdo_req_last(&sdo->req)
                                        || __unlikely(ac = co_ssdo_up_ind(sdo)))
                                break;
                        sdo->nbyte = 0;
                }
                const char *src = (const char *)sdo->req.buf + sdo->nbyte;
                size_t n = MIN(nbyte, sdo->req.nbyte - sdo->nbyte);

                if (sdo->gencrc)
                        sdo->crc = co_crc(sdo->crc, src, n);

                membuf_write(&sdo->buf, src, n);
                nbyte -= n;
                sdo->nbyte += n;
        }

        return ac;
}

static void
co_ssdo_send_abort(co_ssdo_t *sdo, co_unsigned32_t ac)
{
        assert(sdo);

        struct can_msg msg;
        co_ssdo_init_ini_res(sdo, &msg, CO_SDO_CS_ABORT);
        stle_u32(msg.data + 4, ac);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_dn_ini_res(co_ssdo_t *sdo)
{
        assert(sdo);

        uint8_t cs = CO_SDO_SCS_DN_INI_RES;

        struct can_msg msg;
        co_ssdo_init_ini_res(sdo, &msg, cs);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_dn_seg_res(co_ssdo_t *sdo)
{
        assert(sdo);

        uint8_t cs = CO_SDO_SCS_DN_SEG_RES | sdo->toggle;
        sdo->toggle ^= CO_SDO_SEG_TOGGLE;

        struct can_msg msg;
        co_ssdo_init_seg_res(sdo, &msg, cs);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_up_exp_res(co_ssdo_t *sdo)
{
        assert(sdo);
        assert(sdo->req.size && sdo->req.size <= 4);

        const char *buf = membuf_begin(&sdo->buf);
        size_t nbyte = membuf_size(&sdo->buf);
        assert(nbyte == sdo->req.size);

        uint8_t cs = CO_SDO_SCS_UP_INI_RES | CO_SDO_INI_SIZE_EXP_SET(nbyte);

        struct can_msg msg;
        co_ssdo_init_ini_res(sdo, &msg, cs);
        memcpy(msg.data + 4, buf, nbyte);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_up_ini_res(co_ssdo_t *sdo)
{
        assert(sdo);
        assert(!sdo->req.size || sdo->req.size > 4);

        uint8_t cs = CO_SDO_SCS_UP_INI_RES | CO_SDO_INI_SIZE_IND;

        struct can_msg msg;
        co_ssdo_init_ini_res(sdo, &msg, cs);
        stle_u32(msg.data + 4, sdo->req.size);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_up_seg_res(co_ssdo_t *sdo, int last)
{
        assert(sdo);
        assert(!sdo->req.size || sdo->req.size > 4);

        const char *buf = membuf_begin(&sdo->buf);
        size_t nbyte = membuf_size(&sdo->buf);
        assert(nbyte <= 7);

        uint8_t cs = CO_SDO_SCS_UP_SEG_RES | sdo->toggle
                        | CO_SDO_SEG_SIZE_SET(nbyte);
        sdo->toggle ^= CO_SDO_SEG_TOGGLE;
        if (last)
                cs |= CO_SDO_SEG_LAST;

        struct can_msg msg;
        co_ssdo_init_seg_res(sdo, &msg, cs);
        memcpy(msg.data + 1, buf, nbyte);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_blk_dn_ini_res(co_ssdo_t *sdo)
{
        assert(sdo);

        uint8_t cs = CO_SDO_SCS_BLK_DN_RES | CO_SDO_BLK_CRC | CO_SDO_SC_INI_BLK;

        struct can_msg msg;
        co_ssdo_init_ini_res(sdo, &msg, cs);
        msg.data[4] = sdo->blksize;
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_blk_dn_sub_res(co_ssdo_t *sdo)
{
        assert(sdo);

        uint8_t cs = CO_SDO_SCS_BLK_DN_RES | CO_SDO_SC_BLK_RES;

        struct can_msg msg;
        co_ssdo_init_seg_res(sdo, &msg, cs);
        msg.data[1] = sdo->ackseq;
        msg.data[2] = sdo->blksize;
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_blk_dn_end_res(co_ssdo_t *sdo)
{
        assert(sdo);

        uint8_t cs = CO_SDO_SCS_BLK_DN_RES | CO_SDO_SC_END_BLK;

        struct can_msg msg;
        co_ssdo_init_seg_res(sdo, &msg, cs);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_blk_up_ini_res(co_ssdo_t *sdo)
{
        assert(sdo);

        uint8_t cs = CO_SDO_SCS_BLK_UP_RES | CO_SDO_BLK_CRC
                        | CO_SDO_BLK_SIZE_IND | CO_SDO_SC_INI_BLK;

        struct can_msg msg;
        co_ssdo_init_ini_res(sdo, &msg, cs);
        stle_u32(msg.data + 4, sdo->req.size);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_send_blk_up_sub_res(co_ssdo_t *sdo, int last)
{
        assert(sdo);

        const char *buf = membuf_begin(&sdo->buf);
        size_t nbyte = membuf_size(&sdo->buf);

        for (uint8_t seqno = 1; seqno <= sdo->blksize;
                        seqno++, buf += 7, nbyte -= 7) {
                uint8_t cs = seqno;
                if (last && nbyte <= 7)
                        cs |= CO_SDO_SEQ_LAST;

                struct can_msg msg;
                co_ssdo_init_seg_res(sdo, &msg, cs);
                memcpy(msg.data + 1, buf, MIN(nbyte, 7));
                can_net_send(sdo->net, &msg);
        }
}

static void
co_ssdo_send_blk_up_end_res(co_ssdo_t *sdo)
{
        assert(sdo);

        // Compute the number of bytes in the last segment containing data.
        uint8_t n = sdo->req.size ? (sdo->req.size - 1) % 7 + 1 : 0;

        uint8_t cs = CO_SDO_SCS_BLK_UP_RES | CO_SDO_SC_END_BLK
                        | CO_SDO_BLK_SIZE_SET(n);

        struct can_msg msg;
        co_ssdo_init_seg_res(sdo, &msg, cs);
        stle_u16(msg.data + 1, sdo->crc);
        can_net_send(sdo->net, &msg);
}

static void
co_ssdo_init_ini_res(co_ssdo_t *sdo, struct can_msg *msg, uint8_t cs)
{
        assert(sdo);
        assert(msg);

        *msg = (struct can_msg)CAN_MSG_INIT;
        msg->id = sdo->par.cobid_res;
        if (sdo->par.cobid_res & CO_SDO_COBID_FRAME) {
                msg->id &= CAN_MASK_EID;
                msg->flags |= CAN_FLAG_IDE;
        } else {
                msg->id &= CAN_MASK_BID;
        }
        msg->len = CAN_MAX_LEN;
        msg->data[0] = cs;
        stle_u16(msg->data + 1, sdo->idx);
        msg->data[3] = sdo->subidx;
}

static void
co_ssdo_init_seg_res(co_ssdo_t *sdo, struct can_msg *msg, uint8_t cs)
{
        assert(sdo);
        assert(msg);

        *msg = (struct can_msg)CAN_MSG_INIT;
        msg->id = sdo->par.cobid_res;
        if (sdo->par.cobid_res & CO_SDO_COBID_FRAME) {
                msg->id &= CAN_MASK_EID;
                msg->flags |= CAN_FLAG_IDE;
        } else {
                msg->id &= CAN_MASK_BID;
        }
        msg->len = CAN_MAX_LEN;
        msg->data[0] = cs;
}