FreeRTOSにiTRONタスク管理APIっぽいの入れてみた。
開発環境：STM32CubeMX (Ver5.6.1)
コンパイラは、EWARM、MDK-ARM などお好きな環境で
FreeRTOSの初期状態からの設定変更
タスク状態やスタック領域管理のため、CubeMXにて下記FreeRTOS設定を変更した。
CubeMX画面上の、
タブ 「Pinout＆Configuration」
画面左帯 「Categories」→「Middleware」→「FREERTOS」
を選択。（Modeは「CMSIS_V1」を選択。※V2未評価のため）
「Configuration」→「Config parameters」を選択。
RECORD_STACK_HIGH_ADDRESS ⇒ Enabled ※スタックサイズを求めるため。
Memory Allocation ⇒ Dynamic/Static ※静的関数(...Static)を有効に。
GENERATE_RUN_TIME_STATS ⇒ Enabled ※タスク状態確認。
USE_TRACE_FACILITY ⇒ Enabled ※タスクトレース有効化。
USE_STATS_FORMATTING_FUNCTIONS ⇒ Enabled ※タスクトレース有効化。
「Configuration」→「Include parameters」を選択。
uxTaskGetStackHighWaterMark ⇒ Enabled ※タスクの残りスタック量を取得するため。
ソースコード
【注意事項】
・タスク管理のため、メモリ操作やソートをしまくっている無理くりソースコードです。
・下記ソースコード中の「表示関数の別名定義」箇所（文字出力、メモリ操作関数）は実装済みの関数名に置き換えます。
※本記事中のソフトウェアはサンプルコードであり、ソフトウェアを使用した結果いかなる損害等が発生しても当方は一切責任を負いません。
itron.c
/****************************************************************************
* iTRON風サポートライブラリ
****************************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include "itron.h"
#include "clib.h"
#include "klib.h"
/*** 表示関数の別名定義 ***/
#define _PS sc_puts
#define _PF sc_printf
#define _PR sc_print
#define _NL sc_crlf
#ifdef INC_FREERTOS_H
#define _MAL pvPortMalloc // RAM割当関数
#define _FRE vPortFree // RAM開放関数
#else
#define _MAL malloc
#define _FRE free
#endif
TaskStatus_t *pxTaskStaArr = NULL;
int vTaskNum = 0;
/****************************************************************************
* テーブルソート関数
* input:
* const void *x, *y 比較データ (C標準ライブラリ参照)
* output:
* int 0 or 1 or -1
*---------------------------------------------------------------------------
* (解説)
* タスク番号順に並び替える。
*/
static int sort_info(const void *x, const void *y)
{
int r1, r2;
// タスク番号順に並び替える
r1 = ((const TaskStatus_t*)x)->xTaskNumber;
r2 = ((const TaskStatus_t*)y)->xTaskNumber;
//_PF(" r1=%d r2=%d\n", r1, r2);
#if 1
// 小さい順（昇順）に並び替える。
return (r1 == r2)? 0: (r1 > r2)? 1: -1;
#else
// 大きい順（降順）に並び替える。
return (r1 == r2)? 0: (r1 < r2)? 1: -1;
#endif
}
/************************************************/
/* Get Task Handle */
/************************************************/
TaskHandle_t GetTaskHandle(ID tid, int ref)
{
int num = uxTaskGetNumberOfTasks(); // タスク数チェック
if (num <= 0) {
// タスク数エラー
if (pxTaskStaArr) {
// 以前の情報領域を破棄
_FRE(pxTaskStaArr);
pxTaskStaArr = NULL;
}
_PF("Task Number error. %d\n", num);
vTaskNum = 0;
return NULL;
}
if (vTaskNum != num) {
// 前回チェックしたタスク数と違う
vTaskNum = num;
if (pxTaskStaArr) {
_FRE(pxTaskStaArr); // 以前の情報領域を破棄
pxTaskStaArr = NULL;
}
}
if (pxTaskStaArr == NULL) {
// 新しい情報領域を取得
pxTaskStaArr = (TaskStatus_t*)_MAL(vTaskNum * sizeof(TaskStatus_t));
if (pxTaskStaArr == NULL) {
_PS(" memory alloc error.");
vTaskNum = 0;
return NULL;
}
//_PF("Arry:%08X tasks:%d (unit-size=%d total=%d) \n\n", pxTaskStaArr, vTaskNum, sizeof(TaskStatus_t), vTaskNum * sizeof(TaskStatus_t));
ref = 1;
}
if (ref) {
// タスク情報取得
num = uxTaskGetSystemState( pxTaskStaArr, vTaskNum, NULL );
if ( vTaskNum != num ) _PF("Illegal task num. %d %d\n", vTaskNum, num);
// 管理領域をタスク番号順に並び替える。
qsort(pxTaskStaArr, vTaskNum, sizeof(TaskStatus_t), sort_info);
}
if (tid) {
for (int x = 0; x < vTaskNum; x++) {
if (tid == pxTaskStaArr[x].xTaskNumber) {
// タスクハンドルを返す。
return pxTaskStaArr[x].xHandle;
}
}
}
return NULL; // 該当なし
}
/* タスク生成 */
ER_ID acre_tsk(const T_CTSK *pk_ctsk)
{
TaskHandle_t pxTask;
TaskStatus_t xTaskStatus;
if (pk_ctsk->stk) {
// 静的スタック領域
/*
※注意
静的コール（スタックアドレス指定あり）の場合、
スタック後半ブロックをFreeRTOSのタスク管理領域
（TCB：現バージョンでは約96バイト）として使うよう
処理するので、スタック領域サイズはその分余裕をもって
確保すること。
*/
uint32_t ulStackDepth; // スタックの深さ
// スタックサイズ = (指定サイズ - TCBサイズ) / スタック型サイズ
ulStackDepth = ((pk_ctsk->stksz)-TCB_SIZE)/STK_UNIT;
if (ulStackDepth < (uint32_t)configMINIMAL_STACK_SIZE) {
// 最小スタックサイズを満たしていない。
return E_NOMEM;
}
#if 0
_PF(S_BLUE " STK=%08X\n" S_DEF, pk_ctsk->stk);
_PF(S_BLUE " SIZ=%d[w]\n" S_DEF, ulStackDepth);
_PF(S_BLUE " TCB=%08X\n" S_DEF, &((StackType_t *)pk_ctsk->stk)[ulStackDepth]);
dly_tsk(100/MSEC);
#endif
// タスク生成
pxTask = xTaskCreateStatic(
(TaskFunction_t)pk_ctsk->task, /* 実行アドレス */
pk_ctsk->name, /* タスク名 */
ulStackDepth, /* スタックサイズ (ワード単位) */
(void *)pk_ctsk->exinf, /* パラメータ */
(UBaseType_t)pk_ctsk->itskpri, /* 優先順位 */
(StackType_t *)pk_ctsk->stk, /* スタック開始ポインタ */
(StaticTask_t *)&((StackType_t *)pk_ctsk->stk)[ulStackDepth]);
/* タスク管理領域ポインタ（＝スタック後半）*/
}
else {
// 動的スタック領域
BaseType_t xRsl;
unsigned short usStackDepth;
usStackDepth = (unsigned short)((pk_ctsk->stksz)/STK_UNIT);
if (usStackDepth < configMINIMAL_STACK_SIZE) {
// 最小スタックサイズを満たしていない。
return E_NOMEM;
}
// タスク生成
xRsl = xTaskCreate(
(TaskFunction_t)pk_ctsk->task, /* 実行アドレス */
pk_ctsk->name, /* タスク名 */
usStackDepth, /* スタックサイズ (ワード単位) */
(void *)pk_ctsk->exinf, /* パラメータ */
(UBaseType_t)pk_ctsk->itskpri, /* 優先順位 */
&pxTask); /* 作成したタスクのハンドルを引き渡すために使用されます。*/
if (xRsl != pdPASS) {
// タスク生成エラー
return E_SYS;
}
}
if (pxTask == NULL) {
// 生成エラー
return E_SYS;
}
/* タスク状態設定 */
if ((pk_ctsk->tskatr & TA_ACT) == 0) {
// サスペンド状態にする。
vTaskSuspend(pxTask);
}
// タスク番号を返す。
vTaskGetTaskInfo(pxTask, &xTaskStatus, pdFALSE, eInvalid);
return (ER_ID)xTaskStatus.xTaskNumber;
}
/* タスク削除 */
ER del_tsk( ID tid )
{
TaskHandle_t pxTask;
if (tid <= 0) {
return E_ID; // 不正ID
}
else if (tid == TSK_SELF) {
return E_OBJ; // 自タスク指定禁止
}
else {
pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
}
// 削除
vTaskDelete(pxTask);
return E_OK;
}
/* タスク起動 */
ER act_tsk( ID tid )
{
// レジュームと同じ扱いとする。
return rsm_tsk(tid);
}
/* タスク起動キャンセル */
ER can_act( ID tid )
{
// サスペンドと同等扱いとする。
return sus_tsk(tid);
}
/* タスク起動 */
ER sta_tsk( ID tid, int val )
{
// レジュームと同じ扱いとする。
return rsm_tsk(tid);
}
/* タスク強制終了 */
ER ter_tsk( ID tid )
{
// サスペンドと同等扱いとする。
return sus_tsk(tid);
}
/* タスク優先度変更 */
ER chg_pri( ID tid, int val )
{
TaskHandle_t pxTask;
if (tid <= 0) {
return E_ID; // 不正ID
}
else if (tid == TSK_SELF) {
pxTask = NULL; // 自タスク
}
else {
pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
}
// 変更
vTaskPrioritySet(pxTask, (UBaseType_t)val);
// 確認
if (val != (int)uxTaskPriorityGet(pxTask)) {
return E_PAR; // 設定エラー
}
return E_OK;
}
/* タスク強制待ち状態へ */
ER sus_tsk( ID tid )
{
TaskHandle_t pxTask;
if (tid <= 0) {
return E_ID; // 不正ID
}
else if (tid == TSK_SELF) {
pxTask = NULL; // 自タスク
}
else {
pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
}
// サスペンド
vTaskSuspend(pxTask);
return E_OK;
}
/* タスク再開 */
ER rsm_tsk( ID tid )
{
TaskHandle_t pxTask;
if (tid <= 0) {
return E_ID; // 不正ID
}
else if (tid == TSK_SELF) {
return E_OBJ; // 自タスク指定禁止
}
else {
pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
}
// レジューム
vTaskResume(pxTask);
return E_OK;
}
#if 0
/* タスク再開(1回版) */
ER frsm_tsk( ID tid )
{
TaskHandle_t pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
;
;
return E_OK;
}
#endif
/* タスク起床 */
ER wup_tsk( ID tid )
{
TaskHandle_t pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
;
;
return E_OK;
}
/* タスク起床キャンセル */
ER can_wup( ID tid )
{
TaskHandle_t pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
;
;
return E_OK;
}
/* タスク待ち解除 */
ER rel_wai( ID tid )
{
TaskHandle_t pxTask = GetTaskHandle(tid, 0);
if (pxTask == NULL) {
return E_ID;
}
;
;
return E_OK;
}
/************************************************/
/* Refer Task Status */
/************************************************/
ER ref_tsk(ID tid, T_RTSK *pk_rtsk)
{
StaticTask_t *pxTCB;
TaskStatus_t xTaskStatus;
TaskHandle_t pxTask = GetTaskHandle(tid, 1);
if (pxTask == NULL) {
return E_ID;
}
// タスク個別状態取得
vTaskGetTaskInfo(pxTask, &xTaskStatus, pdTRUE, eInvalid);
pk_rtsk->tskstat = (int)xTaskStatus.eCurrentState; /* task state */
pk_rtsk->tskpri = (int)xTaskStatus.uxCurrentPriority; /* current priority */
pk_rtsk->tskbpri = (int)xTaskStatus.uxBasePriority; /* base task priority */
// タスク制御ブロックポインタセット
pxTCB = (StaticTask_t *)xTaskStatus.xHandle; // ハンドルは tasks.c の tskTCB構造体ポインタと同じ。
pk_rtsk->stksz = (SIZE)((char*)pxTCB->pxDummy8 - (char*)pxTCB->pxDummy6); // pxEndOfStack - pxStack と同義
pk_rtsk->stksz = (pk_rtsk->stksz + ((SIZE)portBYTE_ALIGNMENT_MASK+1)) & ~((SIZE)portBYTE_ALIGNMENT_MASK); // マスク
#if 0
_PF(S_BLUE " pxDummy6=%08X\n" S_DEF, pxTCB->pxDummy6);
_PF(S_BLUE " pxDummy8=%08X\n" S_DEF, pxTCB->pxDummy8);
_PF(S_BLUE " SIZ=%d(%d)\n" S_DEF, (int)((char*)pxTCB->pxDummy8 - (char*)pxTCB->pxDummy6), pk_rtsk->stksz);
dly_tsk(100/MSEC);
#endif
return E_OK;
}
/*** End of file ***/
●ヘッダファイル
itron.h
/*
* itron.h
*/
/*
* ITRON仕様共通規定のデータ型・定数・マクロ
*/
#ifndef _ITRON_H
#define _ITRON_H
#include "cmsis_os.h" /* FreeRTOSインクルードファイル */
#ifdef __cplusplus
extern "C" {
#endif
#define _uITRON_
/*
* ITRON仕様共通データ型
*/
#ifdef INT8_MAX
typedef int8_t B; /* 符号付き8ビット整数 */
#endif /* INT8_MAX */
#ifdef UINT8_MAX
typedef uint8_t UB; /* 符号無し8ビット整数 */
typedef uint8_t VB; /* 型が定まらない8ビットの値 */
#endif /* UINT8_MAX */
typedef int16_t H; /* 符号付き16ビット整数 */
typedef uint16_t UH; /* 符号無し16ビット整数 */
typedef uint16_t VH; /* 型が定まらない16ビットの値 */
typedef int32_t W; /* 符号付き32ビット整数 */
typedef uint32_t UW; /* 符号無し32ビット整数 */
typedef uint32_t VW; /* 型が定まらない32ビットの値 */
#ifdef INT64_MAX
typedef int64_t D; /* 符号付き64ビット整数 */
#endif /* INT64_MAX */
#ifdef UINT64_MAX
typedef uint64_t UD; /* 符号無し64ビット整数 */
typedef uint64_t VD; /* 型が定まらない64ビットの値 */
#endif /* UINT64_MAX */
typedef void *VP; /* 型が定まらないものへのポインタ */
typedef int INT; /* 自然なサイズの符号付き整数 */
typedef unsigned int UINT; /* 自然なサイズの符号無し整数 */
typedef int TMO; /* タイムアウト指定 */
typedef uint32_t SYSTIM; /* システム時刻 */
typedef INT BOOL;
typedef INT FN;
typedef INT ID;
typedef INT BOOL_ID;
typedef INT RDVNO;
typedef UINT RDVPTN;
typedef UINT ATR;
typedef UINT MODE;
typedef INT ER;
typedef INT PRI;
typedef ER ER_ID;
typedef UINT STAT;
typedef INT ER_UINT;
typedef UINT TEXPTN;
typedef UINT FLGPTN;
typedef UINT INHNO;
typedef UINT INTNO;
typedef VP VP_INT;
typedef void (*FP)();
typedef unsigned long SIZE;
typedef unsigned long ADDR;
typedef void TASK; /* */
/* tmout */
#define TMO_POL ((TickType_t)0) /* polling */
#define TMO_FEVR ((TickType_t)-1) /* wait forever */
/* tskid */
#define TSK_SELF 0 /* 自タスク指定 */
/*
* 一般定数
*/
#ifndef NULL
#define NULL 0 /* 無効ポインタ */
#endif /* NULL */
#ifndef true
#define true pdTRUE /* 真 */
#endif /* true */
#ifndef false
#define false pdFALSE /* 偽 */
#endif /* false */
#define E_OK 0 /* 正常終了 */
/*
* メインエラーコード
*/
#define E_SYS (-5) /* システムエラー */
#define E_NOSPT (-9) /* 未サポート機能 */
#define E_RSFN (-10) /* 予約機能コード */
#define E_RSATR (-11) /* 予約属性 */
#define E_PAR (-17) /* パラメータエラー */
#define E_ID (-18) /* 不正ID番号 */
#define E_CTX (-25) /* コンテキストエラー */
#define E_MACV (-26) /* メモリアクセス違反 */
#define E_OACV (-27) /* オブジェクトアクセス違反 */
#define E_ILUSE (-28) /* サービスコール不正使用 */
#define E_NOMEM (-33) /* メモリ不足 */
#define E_NOID (-34) /* ID番号不足 */
#define E_NORES (-35) /* 資源不足 */
#define E_OBJ (-41) /* オブジェクト状態エラー */
#define E_NOEXS (-42) /* オブジェクト未生成 */
#define E_QOVR (-43) /* キューイングオーバーフロー */
#define E_RLWAI (-49) /* 待ち状態の強制解除 */
#define E_TMOUT (-50) /* ポーリング失敗またはタイムアウト */
#define E_DLT (-51) /* 待ちオブジェクトの削除 */
#define E_CLS (-52) /* 待ちオブジェクトの状態変化 */
#define E_WBLK (-57) /* ノンブロッキング受付け */
#define E_BOVR (-58) /* バッファオーバーフロー */
/*
* ITRON仕様共通定数
*/
#ifndef TRUE
#define TRUE true /* 真 */
#endif
#ifndef FALSE
#define FALSE false /* 偽 */
#endif
/* tskpri */
#define TPRI_INI -1
#define TPRI_RUN -1
#define TPRI_SELF -1
#define TMIN_TPRI 0
#define TMAX_TPRI (configMAX_PRIORITIES-1)
ER dly_tsk(TMO tmout);
/*
* ITRON API変換 (FreeRTOS関数へ置き換え)
*/
#define rot_rdq(P) taskYIELD() // タスク回転
#if 0
#define dis_int() taskDISABLE_INTERRUPTS() // グローバル割込み禁止
#define ena_int() taskENABLE_INTERRUPTS() // グローバル割込み許可
#else // ↓こちらの方がネスト考慮されるらしい。
#define dis_int() taskENTER_CRITICAL() // クリティカルセクションに入る (非コンテキスト処理用)
#define ena_int() taskEXIT_CRITICAL() // クリティカルセクションから出る (非コンテキスト処理用)
#endif
typedef struct _t_ctsk {
ATR tskatr;
VP_INT exinf;
FP task;
PRI itskpri;
SIZE stksz;
VP stk;
const char *name;
} T_CTSK;
typedef struct _t_rtsk {
int tskstat;
int tskpri;
int tskbpri;
// ;
// ;
// ;
SIZE stksz;
} T_RTSK;
extern int vTaskNum;
TaskHandle_t GetTaskHandle(ID tid, int ref); /* タスクハンドル取得 (FreeRTOSとの整合性を取るための関数) */
#define TA_HLNG 0x0000
#define TA_ACT 0x0002
#define STK_UNIT sizeof(StackType_t)
#define TCB_SIZE sizeof(StaticTask_t)
// タスク状態をFreeRTOSステータスと紐づけ
#define TTS_RUN eRunning /* RUNNING */
#define TTS_RDY eReady /* READY */
#define TTS_WAI eBlocked /* WAITING */
#define TTS_SUS eSuspended /* SUSPENDED */
#define TTS_WAS eDeleted /* WAITING-SUSPENDED */
#define TTS_DMT eInvalid /* DORMANT */
ER_ID acre_tsk(const T_CTSK *pk_ctsk); /* タスク生成 */
ER del_tsk( ID tid ); /* タスク削除 */
ER act_tsk( ID tid ); /* タスク起動 */
ER can_act( ID tid ); /* タスク起動キャンセル */
ER sta_tsk( ID tid, int val ); /* タスク起動 */
ER ter_tsk( ID tid ); /* タスク強制終了 */
ER chg_pri( ID tid, int val ); /* タスク優先度変更 */
ER sus_tsk( ID tid ); /* タスク強制待ち状態へ */
ER rsm_tsk( ID tid ); /* タスク再開 */
//ER frsm_tsk( ID tid ); /* タスク再開(1回版) */
ER wup_tsk( ID tid ); /* タスク起床 */
ER can_wup( ID tid ); /* タスク起床キャンセル */
ER rel_wai( ID tid ); /* タスク待ち解除 */
ER ref_tsk(ID tid, T_RTSK *pk_rtsk); /* Refer Task Status */
#ifdef __cplusplus
}
#endif
#endif /* _ITRON_H */
以上