source: rtos_arduino/trunk/asp_1.9.2/kernel/wait.h@ 136

Last change on this file since 136 was 136, checked in by ertl-honda, 8 years ago

ライブラリとOS及びベーシックなサンプルの追加.

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