1 #include <isotp/send.h>
3 #define PCI_NIBBLE_INDEX 0
4 #define PAYLOAD_LENGTH_NIBBLE_INDEX 1
5 #define PAYLOAD_BYTE_INDEX 1
7 void isotp_complete_send(IsoTpShims* shims, IsoTpMessage* message,
8 bool status, IsoTpMessageSentHandler callback) {
9 callback(message, status);
12 IsoTpHandle isotp_send_single_frame(IsoTpShims* shims, IsoTpMessage* message,
13 IsoTpMessageSentHandler callback) {
14 IsoTpHandle handle = {
17 type: ISOTP_HANDLE_SENDING
20 uint8_t can_data[CAN_MESSAGE_BYTE_SIZE] = {0};
21 if(!set_nibble(PCI_NIBBLE_INDEX, PCI_SINGLE, can_data, sizeof(can_data))) {
22 shims->log("Unable to set PCI in CAN data");
26 if(!set_nibble(PAYLOAD_LENGTH_NIBBLE_INDEX, message->size, can_data,
28 shims->log("Unable to set payload length in CAN data");
32 if(message->size > 0) {
33 memcpy(&can_data[1], message->payload, message->size);
36 shims->send_can_message(message->arbitration_id, can_data,
38 handle.success = true;
39 isotp_complete_send(shims, message, true, callback);
43 IsoTpHandle isotp_send_multi_frame(IsoTpShims* shims, IsoTpMessage* message,
44 IsoTpMessageSentHandler callback) {
45 // TODO make sure to copy payload into a local buffer
46 shims->log("Only single frame messages are supported");
47 IsoTpHandle handle = {
50 type: ISOTP_HANDLE_SENDING
52 // TODO need to set sending and receiving arbitration IDs separately if we
53 // can't always just add 0x8 (and I think we can't)
57 IsoTpHandle isotp_send(IsoTpShims* shims, const uint16_t arbitration_id,
58 const uint8_t* payload, uint16_t size,
59 IsoTpMessageSentHandler callback) {
60 IsoTpMessage message = {
61 arbitration_id: arbitration_id,
67 return isotp_send_single_frame(shims, &message, callback);
69 return isotp_send_multi_frame(shims, &message, callback);