source: azure_iot_hub/trunk/asp3_dcre/kernel/dataqueue.h@ 388

Last change on this file since 388 was 388, checked in by coas-nagasima, 5 years ago

Azure IoT Hub Device C SDK を使ったサンプルの追加

  • Property svn:eol-style set to native
  • Property svn:keywords set to Id
  • Property svn:mime-type set to text/x-chdr
File size: 6.6 KB
Line 
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-2014 by Embedded and Real-Time Systems Laboratory
9 * Graduate School of Information Science, Nagoya Univ., JAPAN
10 *
11 * 上記著作権者
12は,以下の(1)~(4)の条件を満たす場合に限り,本ソフトウェ
13 * ア(本ソフトウェアを改変したものを含む.以下同じ)を使用・複製・改
14 * 変・再é…
15å¸ƒï¼ˆä»¥ä¸‹ï¼Œåˆ©ç”¨ã¨å‘¼ã¶ï¼‰ã™ã‚‹ã“とを無償で許諾する.
16 * (1) 本ソフトウェアをソースコードの形で利用する場合には,上記の著作
17 * 権表示,この利用条件および下記の無保証規定が,そのままの形でソー
18 * スコード中に含まれていること.
19 * (2) 本ソフトウェアを,ライブラリ形式など,他のソフトウェア開発に使
20 * 用できる形で再é…
21å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œå†é…
22å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨
23 * 者
24マニュアルなど)に,上記の著作権表示,この利用条件および下記
25 * の無保証規定を掲載すること.
26 * (3) 本ソフトウェアを,機器に組み込むなど,他のソフトウェア開発に使
27 * 用できない形で再é…
28å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œæ¬¡ã®ã„ずれかの条件を満たすこ
29 * と.
30 * (a) 再é…
31å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨è€…
32マニュアルなど)に,上記の著
33 * 作権表示,この利用条件および下記の無保証規定を掲載すること.
34 * (b) 再é…
35å¸ƒã®å½¢æ…
36‹ã‚’,別に定める方法によって,TOPPERSプロジェクトに
37 * 報告すること.
38 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
39 * 害からも,上記著作権者
40およびTOPPERSプロジェクトをå…
41è²¬ã™ã‚‹ã“と.
42 * また,本ソフトウェアのユーザまたはエンドユーザからのいかなる理
43 * 由に基づく請求からも,上記著作権者
44およびTOPPERSプロジェクトを
45 * å…
46è²¬ã™ã‚‹ã“と.
47 *
48 * 本ソフトウェアは,無保証で提供されているものである.上記著作権者
49お
50 * よびTOPPERSプロジェクトは,本ソフトウェアに関して,特定の使用目的
51 * に対する適合性も含めて,いかなる保証も行わない.また,本ソフトウェ
52 * アの利用により直接的または間接的に生じたいかなる損害に関しても,そ
53 * の責任を負わない.
54 *
55 * $Id: dataqueue.h 388 2019-05-22 11:25:18Z coas-nagasima $
56 */
57
58/*
59 * データキュー機能
60 */
61
62#ifndef TOPPERS_DATAQUEUE_H
63#define TOPPERS_DATAQUEUE_H
64
65#include "kernel_impl.h"
66#include <queue.h>
67#include "wait.h"
68
69/*
70 * データ管理ブロック
71 */
72typedef struct data_management_block {
73 intptr_t data; /* データ本体 */
74} DTQMB;
75
76/*
77 * データキュー初期化ブロック
78 *
79 * この構造体は,同期・通信オブジェクトの初期化ブロックのå…
80±é€šéƒ¨åˆ†
81 * (WOBJINIB)を拡張(オブジェクト指向言語の継承に相当)したもので,
82 * 最初のフィールドがå…
83±é€šã«ãªã£ã¦ã„る.
84 */
85typedef struct dataqueue_initialization_block {
86 ATR dtqatr; /* データキュー属性 */
87 uint_t dtqcnt; /* データキューの容量 */
88 DTQMB *p_dtqmb; /* データキュー管理領域のå…
89ˆé ­ç•ªåœ° */
90} DTQINIB;
91
92/*
93 * データキュー管理ブロック
94 *
95 * この構造体は,同期・通信オブジェクトの管理ブロックのå…
96±é€šéƒ¨åˆ†ï¼ˆWOBJCB)
97 * を拡張(オブジェクト指向言語の継承に相当)したもので,最初の2つの
98 * フィールドがå…
99±é€šã«ãªã£ã¦ã„る.
100 */
101typedef struct dataqueue_control_block {
102 QUEUE swait_queue; /* データキュー送信待
103ちキュー */
104 const DTQINIB *p_dtqinib; /* 初期化ブロックへのポインタ */
105 QUEUE rwait_queue; /* データキュー受信待
106ちキュー */
107 uint_t count; /* データキュー中のデータの数 */
108 uint_t head; /* 最初のデータの格納場所 */
109 uint_t tail; /* 最後のデータの格納場所の次 */
110} DTQCB;
111
112/*
113 * データキュー待
114ち情
115報ブロックの定義
116 *
117 * この構造体は,同期・通信オブジェクトの待
118ち情
119報ブロックのå…
120±é€šéƒ¨åˆ†
121 * (WINFO_WOBJ)を拡張(オブジェクト指向言語の継承に相当)したもので,
122 * 最初の2つのフィールドがå…
123±é€šã«ãªã£ã¦ã„る.
124 */
125typedef struct dataqueue_send_waiting_information {
126 WINFO winfo; /* 標準の待
127ち情
128報ブロック */
129 DTQCB *p_dtqcb; /* 待
130っているデータキューの管理ブロック */
131 intptr_t data; /* 送信データ */
132} WINFO_SDTQ;
133
134typedef struct dataqueue_receive_waiting_information {
135 WINFO winfo; /* 標準の待
136ち情
137報ブロック */
138 DTQCB *p_dtqcb; /* 待
139っているデータキューの管理ブロック */
140 intptr_t data; /* 受信データ */
141} WINFO_RDTQ;
142
143/*
144 * 使用していないデータキュー管理ブロックのリスト
145 */
146extern QUEUE free_dtqcb;
147
148/*
149 * データキューIDの最大値(kernel_cfg.c)
150 */
151extern const ID tmax_dtqid;
152extern const ID tmax_sdtqid;
153
154/*
155 * データキュー初期化ブロックのエリア(kernel_cfg.c)
156 */
157extern const DTQINIB dtqinib_table[];
158extern DTQINIB adtqinib_table[];
159
160/*
161 * データキュー管理ブロックのエリア(kernel_cfg.c)
162 */
163extern DTQCB dtqcb_table[];
164
165/*
166 * データキュー管理ブロックからデータキューIDを取り出すためのマクロ
167 */
168#define DTQID(p_dtqcb) ((ID)(((p_dtqcb) - dtqcb_table) + TMIN_DTQID))
169
170/*
171 * データキュー機能の初期化
172 */
173extern void initialize_dataqueue(void);
174
175/*
176 * データキュー管理領域へのデータの格納
177 */
178extern void enqueue_data(DTQCB *p_dtqcb, intptr_t data);
179
180/*
181 * データキュー管理領域へのデータの強制格納
182 */
183extern void force_enqueue_data(DTQCB *p_dtqcb, intptr_t data);
184
185/*
186 * データキュー管理領域からのデータの取出し
187 */
188extern void dequeue_data(DTQCB *p_dtqcb, intptr_t *p_data);
189
190/*
191 * データキューへのデータ送信
192 */
193extern bool_t send_data(DTQCB *p_dtqcb, intptr_t data);
194
195/*
196 * データキューへのデータ強制送信
197 */
198extern void force_send_data(DTQCB *p_dtqcb, intptr_t data);
199
200/*
201 * データキューからのデータ受信
202 */
203extern bool_t receive_data(DTQCB *p_dtqcb, intptr_t *p_data);
204
205#endif /* TOPPERS_DATAQUEUE_H */
Note: See TracBrowser for help on using the repository browser.