ALPAKA/CAN-Demo
1
0
Fork 0
mirror of https://git.intern.spaceteamaachen.de/ALPAKA/CAN-Demo.git synced 2025-06-10 19:15:59 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

can task

Browse Source
This commit is contained in:
CarlWachter 2024-03-11 14:42:35 +01:00
parent 28937bb199
commit c688f08966
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
App/Src/tasks/can_task.cpp
View File

@ -10,6 +10,7 @@
#include <sta/rtos/debug/heap_stats.hpp>
#include "can.h"
#include <sta/tacos.hpp>
#include <sta/tacos/manager.hpp>
#include <cmsis_os2.h>
@ -27,15 +28,13 @@ namespace tasks
void CanTask::func()
{
if (CAN_queue_.available() > 0)
CanSysMsg msg;
if (CAN_queue_.get(&msg, osWaitForever))
{
// Receiving message
CanSysMsg msg;
CAN_queue_.get(&msg);
// Interpret received
uint8_t type_id, sensor_ID, value, include;
unpackValues(canRX[0], &type_id, &sensor_ID, &value, &include);
unpackValues(msg.payload[0], &type_id, &sensor_ID, &value, &include);
// Reformat for internal use
msg.header.payloadLength = 2;
@ -60,9 +59,9 @@ namespace tasks
}
// Append to the correct thread's queue
for (std::shared_ptr<TacosThread> thread : Manager::instance()->getActiveThreads()){
for (std::shared_ptr<TacosThread> thread : sta::tacos::Manager::instance()->getActiveThreads()){
if (thread->getCanID() == target_ID){
thread->CAN_queue_.put(sysMsg);
thread->CAN_queue_.put(msg);
break;
}
}