source: asp_wo_cfg/trunk/syssvc/logtask.c@ 49

Last change on this file since 49 was 49, checked in by ertl-hiro, 12 years ago

asp_wo_kernelをコミット。
  • Property svn:keywords set to Id
File size: 5.5 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-2012 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: logtask.c 49 2012-09-06 04:41:53Z ertl-hiro $
41 */
42
43/*
44 * システムログタスク
45 */
46
47#include <kernel.h>
48#include <t_syslog.h>
49#include <log_output.h>
50#include "syssvc/serial.h"
51#include "syssvc/syslog.h"
52#include "logtask.h"
53
54/*
55 * オブジェクトのID
56 */
57#include "kernel_id.h"
58
59/*
60 * システムログタスクの出力先のポートID
61 */
62static ID logtask_portid;
63
64/*
65 * システムログタスクの初期化
66 */
67void
68logtask_initialize(intptr_t exinf)
69{
70 T_CTSK ctsk;
71 ER ercd;
72
73 /*
74 * システムログタスクの初期化処理（logtask.cfg相当の処理）
75 *
76 * CRE_TSK(LOGTASK, { TA_ACT, LOGTASK_PORTID, logtask_main,
77 * LOGTASK_PRIORITY, LOGTASK_STACK_SIZE, NULL });
78 */
79 ctsk.tskatr = TA_ACT;
80 ctsk.exinf = LOGTASK_PORTID;
81 ctsk.task = logtask_main;
82 ctsk.itskpri = LOGTASK_PRIORITY;
83 ctsk.stksz = LOGTASK_STACK_SIZE;
84 ctsk.stk = NULL;
85 ercd = cre_tsk(LOGTASK, &ctsk);
86 assert(ercd == E_OK);
87}
88
89/*
90 * シリアルインタフェースへの1文字出力
91 */
92static void
93logtask_putc(char c)
94{
95 (void) serial_wri_dat(logtask_portid, &c, 1);
96}
97
98/*
99 * システムログ出力の待ち合わせ
100 */
101ER
102logtask_flush(uint_t count)
103{
104 T_SYSLOG_RLOG rlog;
105 T_SERIAL_RPOR rpor;
106 ER ercd, rercd;
107
108 if (sns_dpn()) {
109 ercd = E_CTX;
110 }
111 else {
112 for (;;) {
113 if (syslog_ref_log(&rlog) < 0) {
114 ercd = E_SYS;
115 goto error_exit;
116 }
117 if (rlog.count <= count) {
118 if (count == 0U) {
119 /*
120 * countが0の場合には，シリアルバッファが空かを確
121 * 認する．
122 */
123 if (serial_ref_por(logtask_portid, &rpor) < 0) {
124 ercd = E_SYS;
125 goto error_exit;
126 }
127 if (rpor.wricnt == 0U) {
128 ercd = E_OK;
129 goto error_exit;
130 }
131 }
132 else {
133 ercd = E_OK;
134 goto error_exit;
135 }
136 }
137
138 /*
139 * LOGTASK_FLUSH_WAITミリ秒待つ．
140 */
141 rercd = dly_tsk(LOGTASK_FLUSH_WAIT);
142 if (rercd < 0) {
143 ercd = (rercd == E_RLWAI) ? rercd : E_SYS;
144 goto error_exit;
145 }
146 }
147 }
148
149 error_exit:
150 return(ercd);
151}
152
153/*
154 * システムログタスクの本体
155 */
156void
157logtask_main(intptr_t exinf)
158{
159 SYSLOG logbuf;
160 uint_t lostlog;
161 ER_UINT rercd;
162
163 logtask_portid = (ID) exinf;
164 (void) serial_opn_por(logtask_portid);
165 (void) syslog_msk_log(LOG_UPTO(LOG_NOTICE), LOG_UPTO(LOG_EMERG));
166 syslog_1(LOG_NOTICE, "System logging task is started on port %d.",
167 logtask_portid);
168 for (;;) {
169 lostlog = 0U;
170 while ((rercd = syslog_rea_log(&logbuf)) >= 0) {
171 lostlog += (uint_t) rercd;
172 if (logbuf.logtype >= LOG_TYPE_COMMENT) {
173 if (lostlog > 0U) {
174 syslog_lostmsg(lostlog, logtask_putc);
175 lostlog = 0U;
176 }
177 syslog_print(&logbuf, logtask_putc);
178 logtask_putc('\n');
179 }
180 }
181 if (lostlog > 0U) {
182 syslog_lostmsg(lostlog, logtask_putc);
183 }
184 (void) dly_tsk(LOGTASK_INTERVAL);
185 }
186}
187
188/*
189 * システムログタスクの終了処理
190 */
191void
192logtask_terminate(intptr_t exinf)
193{
194 char c;
195 SYSLOG logbuf;
196 bool_t msgflg = false;
197 ER_UINT rercd;
198
199 /*
200 * シリアルインタフェースドライバの送信バッファに蓄積されたデータ
201 * を，低レベル出力機能を用いて出力する．
202 */
203 while (serial_get_chr(logtask_portid, &c)) {
204 target_fput_log(c);
205 }
206
207 /*
208 * ログバッファに記録されたログ情報を，低レベル出力機能を用いて出
209 * 力する．
210 */
211 while ((rercd = syslog_rea_log(&logbuf)) >= 0) {
212 if (!msgflg) {
213 /*
214 * ログバッファに残ったログ情報であることを示す文字列を出
215 * 力する．
216 */
217 syslog_printf("-- buffered messages --\n", NULL, target_fput_log);
218 msgflg = true;
219 }
220 if (rercd > 0) {
221 syslog_lostmsg((uint_t) rercd, target_fput_log);
222 }
223 if (logbuf.logtype >= LOG_TYPE_COMMENT) {
224 syslog_print(&logbuf, target_fput_log);
225 target_fput_log('\n');
226 }
227 }
228}
Note: See TracBrowser for help on using the repository browser.