source: azure_iot_hub/trunk/asp3_dcre/kernel/wait.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: 10.1 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 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: wait.h 388 2019-05-22 11:25:18Z coas-nagasima $
56 */
57
58/*
59 * 待
60ち状æ…
61‹ç®¡ç†ãƒ¢ã‚¸ãƒ¥ãƒ¼ãƒ«
62 */
63
64#ifndef TOPPERS_WAIT_H
65#define TOPPERS_WAIT_H
66
67#include "kernel_impl.h"
68#include <queue.h>
69#include "task.h"
70#include "time_event.h"
71
72/*
73 * タスクの優å…
74ˆåº¦é †ã®å¾…
75ちキューへの挿å…
76¥
77 *
78 * p_tcbで指定されるタスクを,タスク優å…
79ˆåº¦é †ã®ã‚­ãƒ¥ãƒ¼p_queueに挿å…
80¥ã™ã‚‹ï¼Ž
81 * キューの中に同じ優å…
82ˆåº¦ã®ã‚¿ã‚¹ã‚¯ãŒã‚る場合には,その最後に挿å…
83¥ã™ã‚‹ï¼Ž
84 */
85Inline void
86queue_insert_tpri(QUEUE *p_queue, TCB *p_tcb)
87{
88 QUEUE *p_entry;
89 uint_t pri = p_tcb->priority;
90
91 for (p_entry = p_queue->p_next; p_entry != p_queue;
92 p_entry = p_entry->p_next) {
93 if (pri < ((TCB *) p_entry)->priority) {
94 break;
95 }
96 }
97 queue_insert_prev(p_entry, &(p_tcb->task_queue));
98}
99
100/*
101 * 待
102ち状æ…
103‹ã¸ã®é·ç§»
104 *
105 * 実行中のタスクを待
106ち状æ…
107‹ã«é·ç§»ã•ã›ã‚‹ï¼Žå…
108·ä½“的には,実行中のタスクを
109 * レディキューから削除し,TCBのp_winfoフィールド,WINFOのp_tmevtbフィー
110 * ルドを設定する.
111 */
112Inline void
113make_wait(WINFO *p_winfo)
114{
115 make_non_runnable(p_runtsk);
116 p_runtsk->p_winfo = p_winfo;
117 p_winfo->p_tmevtb = NULL;
118}
119
120/*
121 * 待
122ち状æ…
123‹ã¸ã®é·ç§»ï¼ˆã‚¿ã‚¤ãƒ ã‚¢ã‚¦ãƒˆæŒ‡å®šï¼‰
124 *
125 * 実行中のタスクを,タイムアウト指定付きで待
126ち状æ…
127‹ã«é·ç§»ã•ã›ã‚‹ï¼Žå…
128·ä½“
129 * 的には,実行中のタスクをレディキューから削除し,TCBのp_winfoフィー
130 * ルド,WINFOのp_tmevtbフィールドを設定する.また,タイムイベントブ
131 * ロックを登録する.
132 */
133extern void make_wait_tmout(WINFO *p_winfo, TMEVTB *p_tmevtb, TMO tmout);
134
135/*
136 * 待
137ち解除のためのタスク状æ…
138‹ã®æ›´æ–°
139 *
140 * p_tcbで指定されるタスクを,待
141ち解除するようタスク状æ…
142‹ã‚’更新する.
143 * 待
144ち解除するタスクが実行できる状æ…
145‹ã«ãªã‚‹å ´åˆã¯ï¼Œãƒ¬ãƒ‡ã‚£ã‚­ãƒ¥ãƒ¼ã«ã¤ãª
146 * ぐ.
147 */
148Inline void
149make_non_wait(TCB *p_tcb)
150{
151 assert(TSTAT_WAITING(p_tcb->tstat));
152
153 if (!TSTAT_SUSPENDED(p_tcb->tstat)) {
154 /*
155 * 待
156ち状æ…
157‹ã‹ã‚‰å®Ÿè¡Œã§ãã‚‹çŠ¶æ…
158‹ã¸ã®é·ç§»
159 */
160 p_tcb->tstat = TS_RUNNABLE;
161 LOG_TSKSTAT(p_tcb);
162 make_runnable(p_tcb);
163 }
164 else {
165 /*
166 * 二重待
167ち状æ…
168‹ã‹ã‚‰å¼·åˆ¶å¾…
169ち状æ…
170‹ã¸ã®é·ç§»
171 */
172 p_tcb->tstat = TS_SUSPENDED;
173 LOG_TSKSTAT(p_tcb);
174 }
175}
176
177/*
178 * オブジェクト待
179ちキューからの削除
180 *
181 * p_tcbで指定されるタスクが,同期・通信オブジェクトの待
182ちキューにつ
183 * ながれていれば,待
184ちキューから削除する.
185 */
186Inline void
187wait_dequeue_wobj(TCB *p_tcb)
188{
189 if (TSTAT_WAIT_WOBJ(p_tcb->tstat)) {
190 queue_delete(&(p_tcb->task_queue));
191 }
192}
193
194/*
195 * 時間待
196ちのためのタイムイベントブロックの登録解除
197 *
198 * p_tcbで指定されるタスクに対して,時間待
199ちのためのタイムイベントブ
200 * ロックが登録されていれば,それを登録解除する.
201 */
202Inline void
203wait_dequeue_tmevtb(TCB *p_tcb)
204{
205 if (p_tcb->p_winfo->p_tmevtb != NULL) {
206 tmevtb_dequeue(p_tcb->p_winfo->p_tmevtb);
207 }
208}
209
210/*
211 * 待
212ち解除
213 *
214 * p_tcbで指定されるタスクの待
215ち状æ…
216‹ã‚’解除する.å…
217·ä½“的には,タイムイ
218 * ベントブロックが登録されていれば,それを登録解除する.また,タスク
219 * 状æ…
220‹ã‚’更新し,待
221ち解除したタスクからの返値をE_OKとする.待
222ちキュー
223 * からの削除は行わない.
224 */
225extern void wait_complete(TCB *p_tcb);
226
227/*
228 * タイムアウトに伴う待
229ち解除
230 *
231 * p_tcbで指定されるタスクが,待
232ちキューにつながれていれば待
233ちキュー
234 * から削除し,タスク状æ…
235‹ã‚’更新する.また,待
236ち解除したタスクからの返
237 * 値を,wait_tmoutではE_TMOUT,wait_tmout_okではE_OKとする.
238 *
239 * wait_tmout_okは,dly_tskで使うためのもので,待
240ちキューから削除する
241 * 処理を行わない.
242 *
243 * いずれの関数も,タイムイベントのコールバック関数として用いるための
244 * もので,割込みハンドラから呼び出されることを想定している.
245 */
246extern void wait_tmout(TCB *p_tcb);
247extern void wait_tmout_ok(TCB *p_tcb);
248
249/*
250 * 待
251ちキューのå…
252ˆé ­ã®ã‚¿ã‚¹ã‚¯ID
253 *
254 * p_wait_queueで指定した待
255ちキューのå…
256ˆé ­ã®ã‚¿ã‚¹ã‚¯IDを返す.待
257ちキュー
258 * が空の場合には,TSK_NONEを返す.
259 */
260Inline ID
261wait_tskid(QUEUE *p_wait_queue)
262{
263 if (!queue_empty(p_wait_queue)) {
264 return(TSKID((TCB *) p_wait_queue->p_next));
265 }
266 else {
267 return(TSK_NONE);
268 }
269}
270
271/*
272 * 同期・通信オブジェクトの管理ブロックのå…
273±é€šéƒ¨åˆ†æ“ä½œãƒ«ãƒ¼ãƒãƒ³
274 *
275 * 同期・通信オブジェクトの初期化ブロックと管理ブロックのå…
276ˆé ­éƒ¨åˆ†ã¯å…
277±
278 * 通になっている.以下は,そのå…
279±é€šéƒ¨åˆ†ã‚’扱うための型およびルーチン群
280 * である.
281 *
282 * 複数の待
283ちキューを持つ同期・通信オブジェクトの場合,å…
284ˆé ­ä»¥å¤–の待
285ち
286 * キューを操作する場合には,これらのルーチンは使えない.また,オブジェ
287 * クト属性のTA_TPRIビットを参ç…
288§ã™ã‚‹ã®ã§ï¼Œã“のビットを他の目的に使って
289 * いる場合も,これらのルーチンは使えない.
290 */
291
292/*
293 * 同期・通信オブジェクトの初期化ブロックのå…
294±é€šéƒ¨åˆ†
295 */
296typedef struct wait_object_initialization_block {
297 ATR wobjatr; /* オブジェクト属性 */
298} WOBJINIB;
299
300/*
301 * 同期・通信オブジェクトの管理ブロックのå…
302±é€šéƒ¨åˆ†
303 */
304typedef struct wait_object_control_block {
305 QUEUE wait_queue; /* 待
306ちキュー */
307 const WOBJINIB *p_wobjinib; /* 初期化ブロックへのポインタ */
308} WOBJCB;
309
310/*
311 * 同期・通信オブジェクトの待
312ち情
313報ブロックのå…
314±é€šéƒ¨åˆ†
315 *
316 * この構造体は,待
317ち情
318報ブロック(WINFO)を拡張(オブジェクト指向言
319 * 語の継承に相当)したものであるが,WINFOがå…
320±ç”¨ä½“で定義されているた
321 * めに,1つのフィールドとして含めている.
322 */
323typedef struct wait_object_waiting_information {
324 WINFO winfo; /* 標準の待
325ち情
326報ブロック */
327 WOBJCB *p_wobjcb; /* 待
328ちオブジェクトの管理ブロック */
329} WINFO_WOBJ;
330
331/*
332 * 同期・通信オブジェクトに対する待
333ち状æ…
334‹ã¸ã®é·ç§»
335 *
336 * 実行中のタスクを待
337ち状æ…
338‹ã«é·ç§»ã•ã›ï¼ŒåŒæœŸãƒ»é€šä¿¡ã‚ªãƒ–ジェクトの待
339ちキュー
340 * につなぐ.また,待
341ち情
342報ブロック(WINFO)のp_wobjcbを設定する.
343 * wobj_make_wait_tmoutは,タイムイベントブロックの登録も行う.
344 */
345extern void wobj_make_wait(WOBJCB *p_wobjcb, WINFO_WOBJ *p_winfo);
346extern void wobj_make_wait_tmout(WOBJCB *p_wobjcb, WINFO_WOBJ *p_winfo,
347 TMEVTB *p_tmevtb, TMO tmout);
348
349/*
350 * タスク優å…
351ˆåº¦å¤‰æ›´æ™‚の処理
352 *
353 * 同期・通信オブジェクトに対する待
354ち状æ…
355‹ã«ã‚るタスクの優å…
356ˆåº¦ãŒå¤‰æ›´ã•
357 * れた場合に,待
358ちキューの中でのタスクの位置を修正する.
359 */
360Inline void
361wobj_change_priority(WOBJCB *p_wobjcb, TCB *p_tcb)
362{
363 if ((p_wobjcb->p_wobjinib->wobjatr & TA_TPRI) != 0U) {
364 queue_delete(&(p_tcb->task_queue));
365 queue_insert_tpri(&(p_wobjcb->wait_queue), p_tcb);
366 }
367}
368
369/*
370 * 待
371ちキューの初期化
372 *
373 * 待
374ちキューにつながれているタスクをすべて待
375ち解除する.待
376ち解除した
377 * タスクからの返値は,E_DLTとする.
378 */
379extern void init_wait_queue(QUEUE *p_wait_queue);
380
381#endif /* TOPPERS_WAIT_H */
Note: See TracBrowser for help on using the repository browser.