asp/kernel/dataqueue.h

   1 /*
   2  *  TOPPERS/ASP Kernel
   3  *      Toyohashi Open Platform for Embedded Real-Time Systems/
   4  *      Advanced Standard Profile Kernel
   5  *
   6  *  Copyright (C) 2000-2003 by Embedded and Real-Time Systems Laboratory
   7  *                              Toyohashi Univ. of Technology, JAPAN
   8  *  Copyright (C) 2005-2010 by Embedded and Real-Time Systems Laboratory
   9  *              Graduate School of Information Science, Nagoya Univ., JAPAN
  10  *
  11  *  上記著作権者は，以下の(1)〜(4)の条件を満たす場合に限り，本ソフトウェ
  12  *  ア（本ソフトウェアを改変したものを含む．以下同じ）を使用・複製・改
  13  *  変・再配布（以下，利用と呼ぶ）することを無償で許諾する．
  14  *  (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
  15  *      権表示，この利用条件および下記の無保証規定が，そのままの形でソー
  16  *      スコード中に含まれていること．
  17  *  (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
  18  *      用できる形で再配布する場合には，再配布に伴うドキュメント（利用
  19  *      者マニュアルなど）に，上記の著作権表示，この利用条件および下記
  20  *      の無保証規定を掲載すること．
  21  *  (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
  22  *      用できない形で再配布する場合には，次のいずれかの条件を満たすこ
  23  *      と．
  24  *    (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著
  25  *        作権表示，この利用条件および下記の無保証規定を掲載すること．
  26  *    (b) 再配布の形態を，別に定める方法によって，TOPPERSプロジェクトに
  27  *        報告すること．
  28  *  (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
  29  *      害からも，上記著作権者およびTOPPERSプロジェクトを免責すること．
  30  *      また，本ソフトウェアのユーザまたはエンドユーザからのいかなる理
  31  *      由に基づく請求からも，上記著作権者およびTOPPERSプロジェクトを
  32  *      免責すること．
  33  *
  34  *  本ソフトウェアは，無保証で提供されているものである．上記著作権者お
  35  *  よびTOPPERSプロジェクトは，本ソフトウェアに関して，特定の使用目的
  36  *  に対する適合性も含めて，いかなる保証も行わない．また，本ソフトウェ
  37  *  アの利用により直接的または間接的に生じたいかなる損害に関しても，そ
  38  *  の責任を負わない．
  39  *
  40  *  @(#) $Id: dataqueue.h 1960 2010-11-20 02:20:40Z ertl-hiro $
  41  */
  42
  43 /*
  44  *              データキュー機能
  45  */
  46
  47 #ifndef TOPPERS_DATAQUEUE_H
  48 #define TOPPERS_DATAQUEUE_H
  49
  50 #include <queue.h>
  51
  52 /*
  53  *  データ管理ブロック
  54  */
  55 typedef struct data_management_block {
  56         intptr_t        data;                   /* データ本体 */
  57 } DTQMB;
  58
  59 /*
  60  *  データキュー初期化ブロック
  61  *
  62  *  この構造体は，同期・通信オブジェクトの初期化ブロックの共通部分
  63  *  （WOBJINIB）を拡張（オブジェクト指向言語の継承に相当）したもので，
  64  *  最初のフィールドが共通になっている．
  65  */
  66 typedef struct dataqueue_initialization_block {
  67         ATR                     dtqatr;                 /* データキュー属性 */
  68         uint_t          dtqcnt;                 /* データキューの容量 */
  69         DTQMB           *p_dtqmb;               /* データキュー管理領域の先頭番地 */
  70 } DTQINIB;
  71
  72 /*
  73  *  データキュー管理ブロック
  74  *
  75  *  この構造体は，同期・通信オブジェクトの管理ブロックの共通部分（WOBJCB）
  76  *  を拡張（オブジェクト指向言語の継承に相当）したもので，最初の2つの
  77  *  フィールドが共通になっている．
  78  */
  79 typedef struct dataqueue_control_block {
  80         QUEUE           swait_queue;    /* データキュー送信待ちキュー */
  81         const DTQINIB *p_dtqinib;       /* 初期化ブロックへのポインタ */
  82         QUEUE           rwait_queue;    /* データキュー受信待ちキュー */
  83         uint_t          count;                  /* データキュー中のデータの数 */
  84         uint_t          head;                   /* 最初のデータの格納場所 */
  85         uint_t          tail;                   /* 最後のデータの格納場所の次 */
  86 } DTQCB;
  87
  88 /*
  89  *  データキュー待ち情報ブロックの定義
  90  *
  91  *  この構造体は，同期・通信オブジェクトの待ち情報ブロックの共通部分
  92  *  （WINFO_WOBJ）を拡張（オブジェクト指向言語の継承に相当）したもので，
  93  *  最初の2つのフィールドが共通になっている．
  94  *  データキューへの送信待ちとデータキューからの受信待ちで，同じ待ち情
  95  *  報ブロックを使う．
  96  */
  97 typedef struct dataqueue_waiting_information {
  98         WINFO           winfo;                  /* 標準の待ち情報ブロック */
  99         DTQCB           *p_dtqcb;               /* 待っているデータキューの管理ブロック */
 100         intptr_t        data;                   /* 送受信データ */
 101 } WINFO_DTQ;
 102
 103 /*
 104  *  データキューIDの最大値（kernel_cfg.c）
 105  */
 106 extern const ID tmax_dtqid;
 107
 108 /*
 109  *  データキュー初期化ブロックのエリア（kernel_cfg.c）
 110  */
 111 extern const DTQINIB    dtqinib_table[];
 112
 113 /*
 114  *  データキュー管理ブロックのエリア（kernel_cfg.c）
 115  */
 116 extern DTQCB    dtqcb_table[];
 117
 118 /*
 119  *  データキュー管理ブロックからデータキューIDを取り出すためのマクロ
 120  */
 121 #define DTQID(p_dtqcb)  ((ID)(((p_dtqcb) - dtqcb_table) + TMIN_DTQID))
 122
 123 /*
 124  *  データキュー機能の初期化
 125  */
 126 extern void     initialize_dataqueue(void);
 127
 128 /*
 129  *  データキュー管理領域へのデータの格納
 130  */
 131 extern void     enqueue_data(DTQCB *p_dtqcb, intptr_t data);
 132
 133 /*
 134  *  データキュー管理領域へのデータの強制格納
 135  */
 136 extern void     force_enqueue_data(DTQCB *p_dtqcb, intptr_t data);
 137
 138 /*
 139  *  データキュー管理領域からのデータの取出し
 140  */
 141 extern void     dequeue_data(DTQCB *p_dtqcb, intptr_t *p_data);
 142
 143 /*
 144  *  データキューへのデータ送信
 145  */
 146 extern bool_t   send_data(DTQCB *p_dtqcb, intptr_t data, bool_t *p_reqdsp);
 147
 148 /*
 149  *  データキューへのデータ強制送信
 150  */
 151 extern bool_t   force_send_data(DTQCB *p_dtqcb, intptr_t data);
 152
 153 /*
 154  *  データキューからのデータ受信
 155  */
 156 extern bool_t   receive_data(DTQCB *p_dtqcb, intptr_t *p_data,
 157                                                                                                         bool_t *p_reqdsp);
 158
 159 #endif /* TOPPERS_DATAQUEUE_H */