diff --git a/Inc/CanSerialPortFrameTP.h b/Inc/CanSerialPortFrameTP.h index 30f1574..bc210ae 100644 --- a/Inc/CanSerialPortFrameTP.h +++ b/Inc/CanSerialPortFrameTP.h @@ -116,7 +116,14 @@ typedef struct { uint32_t *filterRespId; uint8_t *filterDirReq; - tStaticThreadBlock(384) T_can_Listener; + struct { + osThreadId_t id; + uint32_t stack[384]; + StaticTask_t controlBlock; + osThreadAttr_t attr; + } threadCanListener; + +// tStaticThreadBlock(384) T_can_Listener; } tCanSerialPortFrameTp; void CanSerialPortFrameTpInit( diff --git a/Src/CanSerialPortFrameTP.c b/Src/CanSerialPortFrameTP.c index 7566479..256e2e3 100644 --- a/Src/CanSerialPortFrameTP.c +++ b/Src/CanSerialPortFrameTP.c @@ -471,7 +471,12 @@ _Noreturn void CanTpProcessing_ListenerTask(tCanSerialPortFrameTp *env) { } void CanSerialPortFrameTp_Start(tCanSerialPortFrameTp *env) { - ThreadBlock_Start(env->T_can_Listener, env, CanTpProcessing_ListenerTask); +// ThreadBlock_Start(env->T_can_Listener, env, CanTpProcessing_ListenerTask); + + if (!env->threadCanListener.id) { + env->threadCanListener.id = osThreadNew((osThreadFunc_t) (CanTpProcessing_ListenerTask), (void *) (env), &env->threadCanListener.attr); + SystemDelayMs(10); + } } void CanSerialPortFrameTpInit( @@ -521,7 +526,10 @@ void CanSerialPortFrameTpInit( env->logger = logger; - InitThreadBlock(env->T_can_Listener, "CanTpUds", osPriorityNormal); +// InitThreadBlock(env->T_can_Listener, "CanTpUds", osPriorityNormal); + InitThreadAtrStatic(&env->threadCanListener.attr, "CanTpUds", env->threadCanListener.controlBlock, env->threadCanListener.stack, + osPriorityNormal); + }