summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--app/src/can_task.c2
-rw-r--r--drivers/src/fsl_flexcan.c15
2 files changed, 9 insertions, 8 deletions
diff --git a/app/src/can_task.c b/app/src/can_task.c
index 4efb0e3..b758806 100644
--- a/app/src/can_task.c
+++ b/app/src/can_task.c
@@ -265,8 +265,6 @@ static inline void can_fifo_rx(uint8_t id, flexcan_fifo_transfer_t * rxXfer)
FLEXCAN_TransferReceiveFifoNonBlocking(can_regs[id].base, &can_regs[id].handle, rxXfer);
xSemaphoreTake(can_msg->sem, portMAX_DELAY);
if (can_msg->async_status == pdTRUE) {
- FLEXCAN_ReadRxFifo(can_regs[id].base, can_regs[id].handle.rxFifoFrameBuf);
- FLEXCAN_TransferAbortReceiveFifo(can_regs[id].base, &can_regs[id].handle);
frame_to_buffer(rxXfer->frame, id);
can_regs[id].frames_in_buf++;
if (can_regs[id].frames_in_buf >= CAN_RX_BUF_SIZE)
diff --git a/drivers/src/fsl_flexcan.c b/drivers/src/fsl_flexcan.c
index 45db478..2a07dc5 100644
--- a/drivers/src/fsl_flexcan.c
+++ b/drivers/src/fsl_flexcan.c
@@ -1295,12 +1295,12 @@ void FLEXCAN_TransferHandleIRQ(CAN_Type *base, flexcan_handle_t *handle)
break;
case kFLEXCAN_RxFifoFrameAvlFlag:
- //status = FLEXCAN_ReadRxFifo(base, handle->rxFifoFrameBuf);
- //if (kStatus_Success == status)
- //{
+ status = FLEXCAN_ReadRxFifo(base, handle->rxFifoFrameBuf);
+ if (kStatus_Success == status)
+ {
status = kStatus_FLEXCAN_RxFifoIdle;
- //}
- //FLEXCAN_TransferAbortReceiveFifo(base, handle);
+ }
+ FLEXCAN_TransferAbortReceiveFifo(base, handle);
break;
default:
@@ -1354,7 +1354,10 @@ void FLEXCAN_TransferHandleIRQ(CAN_Type *base, flexcan_handle_t *handle)
/* Calling Callback Function if has one. */
if (handle->callback != NULL)
- reschedule = handle->callback(base, handle, status, result, handle->userData);
+ {
+ if (handle->callback(base, handle, status, result, handle->userData) == pdTRUE)
+ reschedule = pdTRUE;
+ }
/* Reset return status */
status = kStatus_FLEXCAN_UnHandled;