source: EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/udp4_echo_srv.c@ 331

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

prototoolに関連するプロジェクトをnewlibからmuslを使うよう変更・更新
ntshellをnewlibの下位の実装から、muslのsyscallの実装に変更・更新
以下のOSSをアップデート
・mruby-1.3.0
・musl-1.1.18
・onigmo-6.1.3
・tcc-0.9.27
以下のOSSを追加
・openssl-1.1.0e
・curl-7.57.0
・zlib-1.2.11
以下のmrbgemsを追加
・iij/mruby-digest
・iij/mruby-env
・iij/mruby-errno
・iij/mruby-iijson
・iij/mruby-ipaddr
・iij/mruby-mock
・iij/mruby-require
・iij/mruby-tls-openssl
  • Property svn:eol-style set to native
  • Property svn:mime-type set to text/x-csrc
File size: 8.3 KB
Line 
1/*
2 * TINET (TCP/IP Protocol Stack)
3 *
4 * Copyright (C) 2001-2017 by Dep. of Computer Science and Engineering
5 * Tomakomai National College of Technology, JAPAN
6 *
7 * 上記著作権者
8は，以下の (1)～(4) の条件か，Free Software Foundation
9 * によってå…
10¬è¡¨ã•ã‚Œã¦ã„ã‚‹ GNU General Public License の Version 2 に記
11 * 述されている条件を満たす場合に限り，本ソフトウェア（本ソフトウェア
12 * を改変したものを含む．以下同じ）を使用・複製・改変・再é…
13å¸ƒï¼ˆä»¥ä¸‹ï¼Œ
14 * 利用と呼ぶ）することを無償で許諾する．
15 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
16 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー
17 * スコード中に含まれていること．
18 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
19 * 用できる形で再é…
20å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œå†é…
21å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨
22 * 者
23マニュアルなど）に，上記の著作権表示，この利用条件および下記
24 * の無保証規定を掲載すること．
25 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
26 * 用できない形で再é…
27å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œæ¬¡ã®æ¡ä»¶ã‚’満たすこと．
28 * (a) 再é…
29å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨è€…
30マニュアルなど）に，上記の著
31 * 作権表示，この利用条件および下記の無保証規定を掲載すること．
32 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
33 * 害からも，上記著作権者
34およびTOPPERSプロジェクトをå…
35è²¬ã™ã‚‹ã“と．
36 *
37 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者
38お
39 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，その適用可能性も
40 * 含めて，いかなる保証も行わない．また，本ソフトウェアの利用により直
41 * 接的または間接的に生じたいかなる損害に関しても，その責任を負わない．
42 *
43 * @(#) $Id$
44 */
45
46/*
47 * UDP ECHO サーバ
48 *
49 * IPv4
50 */
51
52#include <string.h>
53
54#ifdef TARGET_KERNEL_ASP
55
56#include <kernel.h>
57#include <sil.h>
58#include <t_syslog.h>
59#include "kernel_cfg.h"
60
61#endif /* of #ifdef TARGET_KERNEL_ASP */
62
63#ifdef TARGET_KERNEL_JSP
64
65#include <t_services.h>
66#include "kernel_id.h"
67#include "tinet_id.h"
68
69#endif /* of #ifdef TARGET_KERNEL_JSP */
70
71#include <netinet/in.h>
72#include <netinet/in_itron.h>
73
74#include <netapp/netapp.h>
75#include <netapp/netapp_var.h>
76#include <netapp/udp4_echo_srv.h>
77
78#ifdef USE_UDP4_ECHO_SRV_TSK
79
80/*
81 * 受信タイムアウト
82 */
83
84#define RCV_TMOUT TMO_FEVR
85//#define RCV_TMOUT (30*ULONG_C(1000))
86
87#define BUF_SIZE 2048
88
89static char echo_rcv_buf[BUF_SIZE];
90static T_IPV4EP dst;
91
92#ifdef USE_UDP_CALL_BACK
93
94/*
95 * コールバック関数
96 */
97
98ER
99callback_udp4_echo_srv (ID cepid, FN fncd, void *p_parblk)
100{
101 ER_UINT len;
102 SYSTIM now;
103
104 if ((len = udp_rcv_dat(cepid, &dst, echo_rcv_buf, sizeof(echo_rcv_buf), TMO_FEVR)) >= 0) {
105 echo_rcv_buf[len] = '\0';
106 get_tim(&now);
107 syslog(LOG_NOTICE, "[UES4:%02u UCB] recv: %7lu,from: %s.%d\n"
108 " msg: %s",
109 cepid, now / SYSTIM_HZ, ip2str(NULL, &dst.ipaddr), dst.portno, echo_rcv_buf);
110 if (len > 0) {
111 len = udp_snd_dat(cepid, &dst, echo_rcv_buf, len, TMO_FEVR);
112 get_tim(&now);
113 if (len >= 0)
114 syslog(LOG_NOTICE, "[UES4:%02u UCB] send: %7lu, len: %d",
115 cepid, now / SYSTIM_HZ, len);
116 else
117 syslog(LOG_NOTICE, "[UES4:%02u UCB] error: %7lu,%s",
118 cepid, now / SYSTIM_HZ, itron_strerror(len));
119 }
120 len = E_OK;
121 }
122 else {
123 get_tim(&now);
124 syslog(LOG_NOTICE, "[UES4:%02u UCB] error: %7lu,%s",
125 cepid, now / SYSTIM_HZ, itron_strerror(len));
126 }
127
128 return len;
129 }
130
131#else /* of #ifdef USE_UDP_CALL_BACK */
132
133#ifdef USE_UDP_NON_BLOCKING
134
135/*
136 * 変数
137 */
138
139static ER_UINT nblk_len;
140
141/*
142 * ノンブロッキングコールのコールバック関数
143 */
144
145ER
146callback_nblk_udp4_echo_srv (ID cepid, FN fncd, void *p_parblk)
147{
148 SYSTIM now;
149
150 get_tim(&now);
151 nblk_len = *(ER_UINT*)p_parblk;
152 if (nblk_len < 0) { /* 0 以下の場合は、エラーコード */
153 syslog(LOG_NOTICE, "[UES4:%02u CBR] error, %7lu,%s, fncd: %s",
154 cepid, now / SYSTIM_HZ, itron_strerror(nblk_len), in_strtfn(fncd));
155 }
156 else if (fncd == TFN_UDP_RCV_DAT) {
157 echo_rcv_buf[nblk_len] = '\0';
158 syslog(LOG_NOTICE, "[UES4:%02u CBR] recv: %7lu,from: %s.%d\n"
159 " msg: %s",
160 cepid, now / SYSTIM_HZ, ip2str(NULL, &dst.ipaddr), dst.portno, echo_rcv_buf);
161 }
162 syscall(wup_tsk(UDP4_ECHO_SRV_TASK));
163 return E_OK;
164 }
165
166/*
167 * UDP ECHO サーバ
168 */
169
170ER
171udp4_echo_srv (ID cepid)
172{
173 ER error;
174 SYSTIM now;
175
176 if ((error = udp_rcv_dat(cepid, &dst, echo_rcv_buf, sizeof(echo_rcv_buf), TMO_NBLK)) != E_WBLK) {
177 get_tim(&now);
178 syslog(LOG_NOTICE, "[UES4:%02u RCV] error: %7lu,%s",
179 cepid, now / SYSTIM_HZ, itron_strerror(error));
180 return error;
181 }
182
183 syscall(slp_tsk());
184 if (nblk_len < 0)
185 error = nblk_len;
186 else {
187 if ((error = udp_snd_dat(cepid, &dst, echo_rcv_buf, nblk_len, TMO_NBLK)) != E_WBLK) {
188 get_tim(&now);
189 syslog(LOG_NOTICE, "[UES4:%02u SND] error: %7lu,%s",
190 cepid, now / SYSTIM_HZ, itron_strerror(error));
191 return error;
192 }
193
194 syscall(slp_tsk());
195 if (nblk_len < 0)
196 error = nblk_len;
197 else {
198 get_tim(&now);
199 syslog(LOG_NOTICE, "[UES4:%02u SND] send: %7lu, len: %d",
200 cepid, now / SYSTIM_HZ, nblk_len);
201 error = E_OK;
202 }
203 }
204
205 return error;
206 }
207
208#else /* of #ifdef USE_UDP_NON_BLOCKING */
209
210/*
211 * UDP ECHO サーバ
212 */
213
214ER
215udp4_echo_srv (ID cepid)
216{
217 ER_UINT len;
218 SYSTIM now;
219
220 if ((len = udp_rcv_dat(cepid, &dst, echo_rcv_buf, sizeof(echo_rcv_buf), RCV_TMOUT)) >= 0) {
221 get_tim(&now);
222 echo_rcv_buf[len] = '\0';
223 syslog(LOG_NOTICE, "[UES4:%02u RCV] recv: %7lu,from: %s.%d\n"
224 " msg: %s",
225 cepid, now / SYSTIM_HZ, ip2str(NULL, &dst.ipaddr), dst.portno, echo_rcv_buf);
226 if (len > 0) {
227 len = udp_snd_dat(cepid, &dst, echo_rcv_buf, len, TMO_FEVR);
228 get_tim(&now);
229 if (len >= 0)
230 syslog(LOG_NOTICE, "[UES4:%02u SND] send: %7lu, len: %d",
231 cepid, now / SYSTIM_HZ, (uint16_t)len);
232 else
233 syslog(LOG_NOTICE, "[UES4:%02u SND] error: %7lu,%s",
234 cepid, now / SYSTIM_HZ, itron_strerror(len));
235 }
236 }
237 else {
238 get_tim(&now);
239 syslog(LOG_NOTICE, "[UES4:%02u RCV] error: %7lu,%s",
240 cepid, now / SYSTIM_HZ, itron_strerror(len));
241 }
242
243 return len >= 0 || len == E_TMOUT ? E_OK : len;
244 }
245
246#endif /* of #ifdef USE_UDP_NON_BLOCKING */
247
248/*
249 * UDP ECHO サーバタスク
250 */
251
252#ifdef USE_UDP_EXTENTIONS
253
254void
255udp4_echo_srv_task (intptr_t exinf)
256{
257 ID tskid, cepid;
258 ER error;
259 T_UDP_CCEP ccep;
260
261 get_tid(&tskid);
262 syslog(LOG_NOTICE, "[UDP4 ECHO SRV(EXT):%d] started.", tskid);
263 while (true) {
264
265 syscall(slp_tsk());
266 syslog(LOG_NOTICE, "[UDP4 ECHO SRV(EXT):%d] wake up.", tskid);
267
268 ccep.cepatr = UINT_C(0);
269 ccep.myaddr.portno = UINT_C(7);
270 ccep.myaddr.ipaddr = IPV4_ADDRANY;
271
272#ifdef USE_UDP_NON_BLOCKING
273 ccep.callback = (FP)callback_nblk_udp4_echo_srv;
274#else
275 ccep.callback = NULL;
276#endif
277
278 if ((error = alloc_udp4_cep(&cepid, tskid, &ccep)) != E_OK) {
279 syslog(LOG_NOTICE, "[UES4:%02u TSK] CEP create error:%s", cepid, itron_strerror(error));
280 continue;
281 }
282
283 while (error == E_OK) {
284 if ((error = udp4_echo_srv(cepid)) != E_OK) {
285 if ((error = free_udp4_cep(cepid, !(error == E_NOEXS || error == E_DLT))) != E_OK)
286 syslog(LOG_NOTICE, "[UES4:%02u TSK] CEP delete error:%s", cepid, itron_strerror(error));
287 break;
288 }
289 }
290
291 }
292 slp_tsk();
293 }
294
295#else /* of #ifdef USE_UDP_EXTENTIONS */
296
297void
298udp4_echo_srv_task (intptr_t exinf)
299{
300 ID tskid;
301 ER error = E_OK;
302
303 get_tid(&tskid);
304 syslog(LOG_NOTICE, "[UDP4 ECHO SRV:%d,%d] started.", tskid, (ID)exinf);
305 while (error == E_OK) {
306 error = udp4_echo_srv((ID)exinf);
307 }
308 slp_tsk();
309 }
310
311#endif /* of #ifdef USE_UDP_EXTENTIONS */
312
313#endif /* of #ifdef USE_UDP_CALL_BACK */
314
315#endif /* of #ifdef USE_UDP4_ECHO_SRV_TSK */
Note: See TracBrowser for help on using the repository browser.