5.4 データ・キュー

マルチタスク処理では，あるタスクの処理結果を他タスクに通知するといったタスク間の通信機能（データの受け渡し機能）が必要となります。そこで，RI850V4では，規定されたデータ・サイズの通信機能として“データの書き込み／読み出しが可能なデータ・キュー領域を有するデータ・キュー”を提供しています。

以下に，データ・キューを利用した処理の流れを示します。

図5−3　 処理の流れ（データ・キュー）

備考 1回のデータ送信／受信処理で送信／受信するデータのサイズは，4バイトです。

5.4.1 データ・キューの生成

RI850V4では，データ・キューの静的な生成のみサポートしています。処理プログラムからサービス・コールを発行して動的に生成することはできません。

データ・キューの静的生成とは，システム・コンフィギュレーション・ファイルで静的API“CRE_DTQ”を使用してデータ・キューを定義することをいいます。

静的API“CRE_DTQ”の詳細は，「17.5.4　データ・キュー情報」を参照してください。

5.4.2 データの送信

データの送信は，以下に示したサービス・コールを処理プログラムから発行することにより実現されます。

- snd_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域にパラメータdataで指定されたデータを書き込みます。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域にデータを書き込むための空き領域が存在しなかった場合には，データの書き込みは行わず，自タスクを対象データ・キューの送信待ちキューにキューイングしたのち，RUNNING状態からWAITING状態（データ送信待ち状態）へと遷移させます。
なお，データ送信待ち状態の解除は，以下の場合に行われ，データ送信待ち状態からREADY状態へと遷移します。

　

データ送信待ち状態の解除操作	エラー・コード
rcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
prcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
iprcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
trcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
rel_waiの発行により，データ送信待ち状態を強制的に解除された	E_RLWAI
irel_waiの発行により，データ送信待ち状態を強制的に解除された	E_RLWAI

また，本サービス・コールを発行した際，対象データ・キューの受信待ちキューにタスクがキューイングされていた場合には，データの書き込みは行わず，該当タスクにデータを渡します。これにより，該当タスクは，受信待ちキューから外れ，WAITING状態（データ受信待ち状態）からREADY状態へ，またはWAITING-SUSPENDED状態からSUSPENDED状態へと遷移します。
以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ER ercd; /*変数の宣言*/ ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT data = 123; /*変数の宣言，初期化*/ ............ ............ ercd = snd_dtq ( dtqid, data ); /*データの送信*/ if ( ercd == E_OK ) { ............ /*正常終了処理*/ ............ } else if ( ercd == E_RLWAI ) { ............ /*強制終了処理*/ ............ } ............ ............ }

備考1 データを対象データ・キューのデータ・キュー領域に書き込む際の書き込み方法は，データの送信要求を行った順に行われます。

備考2 自タスクを対象データ・キューの送信待ちキューにキューイングする際のキューイング方式は，コンフィギュレーション時に定義された順（FIFO順，優先度順）に行われます。

- psnd_dtq，ipsnd_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域にパラメータdataで指定されたデータを書き込みます。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域にデータを書き込むための空き領域が存在しなかった場合には，データの書き込みは行わず，戻り値としてE_TMOUTを返します。
また，本サービス・コールを発行した際，対象データ・キューの受信待ちキューにタスクがキューイングされていた場合には，データの書き込みは行わず，該当タスクにデータを渡します。これにより，該当タスクは，受信待ちキューから外れ，WAITING状態（データ受信待ち状態）からREADY状態へ，またはWAITING-SUSPENDED状態からSUSPENDED状態へと遷移します。
以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ER ercd; /*変数の宣言*/ ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT data = 123; /*変数の宣言，初期化*/ ............ ............ ercd = psnd_dtq ( dtqid, data );/*データの送信（ポーリング）*/ if ( ercd == E_OK ) { ............ /*ポーリング成功処理*/ ............ } else if ( ercd == E_TMOUT ) { ............ /*ポーリング失敗処理*/ ............ } ............ ............ }

備考 データを対象データ・キューのデータ・キュー領域に書き込む際の書き込み方法は，データの送信要求を行った順に行われます。

- tsnd_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域にパラメータdataで指定されたデータを書き込みます。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域にデータを書き込むための空き領域が存在しなかった場合には，データの書き込みは行わず，自タスクを対象データ・キューの送信待ちキューにキューイングしたのち，RUNNING状態からタイムアウト付きのWAITING状態（データ送信待ち状態）へと遷移させます。
なお，データ送信待ち状態の解除は，以下の場合に行われ，データ送信待ち状態からREADY状態へと遷移します。

　

データ送信待ち状態の解除操作	エラー・コード
rcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
prcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
iprcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
trcv_dtqの発行により，対象データ・キューのデータ・キュー領域に空き領域が確保された	E_OK
rel_waiの発行により，データ送信待ち状態を強制的に解除された	E_RLWAI
irel_waiの発行により，データ送信待ち状態を強制的に解除された	E_RLWAI
パラメータtmoutで指定された待ち時間が経過した	E_TMOUT

また，本サービス・コールを発行した際，対象データ・キューの受信待ちキューにタスクがキューイングされていた場合には，データの書き込みは行わず，該当タスクにデータを渡します。これにより，該当タスクは，受信待ちキューから外れ，WAITING状態（データ受信待ち状態）からREADY状態へ，またはWAITING-SUSPENDED状態からSUSPENDED状態へと遷移します。
以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ER ercd; /*変数の宣言*/ ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT data = 123; /*変数の宣言，初期化*/ TMO tmout = 3600; /*変数の宣言，初期化*/ ............ ............ /*データの送信（タイムアウト付き）*/ ercd = tsnd_dtq ( dtqid, data, tmout ); if ( ercd == E_OK ) { ............ /*正常終了処理*/ ............ } else if ( ercd == E_RLWAI ) { ............ /*強制終了処理*/ ............ } else if ( ercd == E_TMOUT ) { ............ /*タイムアウト処理*/ ............ } ............ ............

}

備考1 データを対象データ・キューのデータ・キュー領域に書き込む際の書き込み方法は，データの送信要求を行った順に行われます。

備考2 自タスクを対象データ・キューの送信待ちキューにキューイングする際のキューイング方式は，コンフィギュレーション時に定義された順（FIFO順，優先度順）に行われます。

備考3 待ち時間tmoutにTMO_FEVRが指定された際には“snd_dtqと同等の処理”を，TMO_POLが指定された際には“psnd_dtq，ipsnd_dtqと同等の処理”を実行します。

5.4.3 データの強制送信

データの強制送信は，以下に示したサービス・コールを処理プログラムから発行することにより実現されます。

- fsnd_dtq，ifsnd_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域にパラメータdataで指定されたデータを書き込みます。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域にデータを書き込むための空き領域が存在しなかった場合には，書き込まれてから最も時間が経過しているデータの領域に該当データを上書きします。
また，本サービス・コールを発行した際，対象データ・キューの受信待ちキューにタスクがキューイングされていた場合には，データの書き込みは行わず，該当タスクにデータを渡します。これにより，該当タスクは，受信待ちキューから外れ，WAITING状態（データ受信待ち状態）からREADY状態へ，またはWAITING-SUSPENDED状態からSUSPENDED状態へと遷移します。
以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT data = 123; /*変数の宣言，初期化*/ ............ ............ fsnd_dtq ( dtqid, data ); /*データの強制送信*/ ............ ............ }

5.4.4 データの受信

データの受信は，以下に示したサービス・コールを処理プログラムから発行することにより実現されます。

- rcv_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域からデータを読み込み，パラメータp_dataで指定された領域に格納します。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域からデータを読み込むことができなかった（データ・キュー領域にデータが書き込まれていなかった）場合には，データの読み込みは行わず，自タスクを対象データ・キューの受信待ちキューにキューイングしたのち，RUNNING状態からWAITING状態（データ受信待ち状態）へと遷移させます。
なお，データ受信待ち状態の解除は，以下の場合に行われ，データ受信待ち状態からREADY状態へと遷移します。

　

データ受信待ち状態の解除操作	エラー・コード
snd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
psnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
ipsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
tsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
fsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
ifsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
rel_waiの発行により，データ受信待ち状態を強制的に解除された	E_RLWAI
irel_waiの発行により，データ受信待ち状態を強制的に解除された	E_RLWAI

以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ER ercd; /*変数の宣言*/ ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT p_data; /*変数の宣言*/ ............ ............ /*データの受信*/ ercd = rcv_dtq ( dtqid, &p_data ); if ( ercd == E_OK ) { ............ /*正常終了処理*/ ............ } else if ( ercd == E_RLWAI ) { ............ /*強制終了処理*/ ............ } ............ ............ }

備考1 自タスクを対象データ・キューの受信待ちキューにキューイングする際のキューイング方式は，データの受信要求を行った順に行われます。

備考2 rel_wai，またはirel_waiの発行によりデータ受信待ち状態を解除された場合，パラメータp_dataで指定された領域の内容は不定となります。

- prcv_dtq，iprcv_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域からデータを読み込み，パラメータp_dataで指定された領域に格納します。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域からデータを読み込むことができなかった（データ・キュー領域にデータが書き込まれていなかった）場合には，データの読み込みは行わず，戻り値としてE_TMOUTを返します。
以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ER ercd; /*変数の宣言*/ ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT p_data; /*変数の宣言*/ ............ ............ /*データの受信（ポーリング）*/ ercd = prcv_dtq ( dtqid, &p_data ); if ( ercd == E_OK ) { ............ /*ポーリング成功処理*/ ............ } else if ( ercd == E_TMOUT ) { ............ /*ポーリング失敗処理*/ ............ } ............ ............ }

備考 本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域からデータを読み込むことができなかった（データ・キュー領域にデータが書き込まれていなかった）場合，パラメータp_dataで指定された領域の内容は不定となります。

- trcv_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー領域からデータを読み込み，パラメータp_dataで指定された領域に格納します。
ただし，本サービス・コールを発行した際，対象データ・キューのデータ・キュー領域からデータを読み込むことができなかった（データ・キュー領域にデータが書き込まれていなかった）場合には，データの読み込みは行わず，自タスクを対象データ・キューの受信待ちキューにキューイングしたのち，RUNNING状態からタイムアウト付きのWAITING状態（データ受信待ち状態）へと遷移させます。
なお，データ受信待ち状態の解除は，以下の場合に行われ，データ受信待ち状態からREADY状態へと遷移します。

　

データ受信待ち状態の解除操作	エラー・コード
snd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
psnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
ipsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
tsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
fsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
ifsnd_dtqの発行により，対象データ・キューのデータ・キュー領域にデータが書き込まれた	E_OK
rel_waiの発行により，データ受信待ち状態を強制的に解除された	E_RLWAI
irel_waiの発行により，データ受信待ち状態を強制的に解除された	E_RLWAI
パラメータtmoutで指定された待ち時間が経過した	E_TMOUT

以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ER ercd; /*変数の宣言*/ ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ VP_INT p_data; /*変数の宣言*/ TMO tmout = 3600; /*変数の宣言，初期化*/ ............ ............ /*データの受信（タイムアウト付き）*/ ercd = trcv_dtq ( dtqid, &p_data, tmout ); if ( ercd == E_OK ) { ............ /*正常終了処理*/ ............ } else if ( ercd == E_RLWAI ) { ............ /*強制終了処理*/ ............ } else if ( ercd == E_TMOUT ) { ............ /*タイムアウト処理*/ ............ } ............ ............ }

備考1 自タスクを対象データ・キューの受信待ちキューにキューイングする際のキューイング方式は，データの受信要求を行った順に行われます。

備考2 rel_wai，またはirel_waiの発行，または待ち時間の経過によりデータ受信待ち状態を解除された場合，パラメータp_dataで指定された領域の内容は不定となります。

備考3 待ち時間tmoutにTMO_FEVRが指定された際には“rcv_dtqと同等の処理”を，TMO_POLが指定された際には“prcv_dtq，iprcv_dtqと同等の処理”を実行します。

5.4.5 データ・キュー詳細情報の参照

データ・キュー詳細情報の参照は，以下に示したサービス・コールを処理プログラムから発行することにより実現されます。

- ref_dtq，iref_dtq
パラメータdtqidで指定されたデータ・キューのデータ・キュー詳細情報（待ちタスクの有無，未受信データの総数など）をパラメータpk_rdtqで指定された領域に格納します。
以下に，本サービス・コールの記述例を示します。

#include <kernel.h> /*標準ヘッダ・ファイルの定義*/ #include <kernel_id.h> /*システム情報ヘッダ・ファイルの定義*/ void task ( VP_INT exinf ) { ID dtqid = ID_DTQ1; /*変数の宣言，初期化*/ T_RDTQ pk_rdtq; /*データ構造体の宣言*/ ID stskid; /*変数の宣言*/ ID rtskid; /*変数の宣言*/ UINT sdtqcnt; /*変数の宣言*/ ATR dtqatr; /*変数の宣言*/ UINT dtqcnt; /*変数の宣言*/ ............ ............ ref_dtq ( dtqid, &pk_rdtq ); /*データ・キュー詳細情報の参照*/ stskid = pk_rdtq.stskid; /*データ送信待ちタスクの有無の獲得*/ rtskid = pk_rdtq.rtskid; /*データ受信待ちタスクの有無の獲得*/ sdtqcnt = pk_rdtq.sdtqcnt; /*未受信データの総数の獲得*/ dtqatr = pk_rdtq.dtqatr; /*属性の獲得*/ dtqcnt = pk_rdtq.dtqcnt; /*データ数の獲得*/ ............ ............ }

備考 データ・キュー詳細情報T_RDTQについての詳細は，「15.2.5　データ・キュー詳細情報」を参照してください。