source: EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/udp_echo_srv.c@ 270

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

mruby版ECNLプロトタイピング・ツールを追加
  • Property svn:eol-style set to native
  • Property svn:keywords set to Id
  • Property svn:mime-type set to text/x-csrc
File size: 8.4 KB
Line 
1/*
2 * TINET (TCP/IP Protocol Stack)
3 *
4 * Copyright (C) 2001-2009 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: udp_echo_srv.c 270 2017-02-09 04:03:47Z coas-nagasima $
44 */
45
46/*
47 * UDP ECHO サーバ
48 */
49
50#include <string.h>
51
52#ifdef TARGET_KERNEL_ASP
53
54#include <kernel.h>
55#include <sil.h>
56#include <t_syslog.h>
57#include "kernel_cfg.h"
58
59#endif /* of #ifdef TARGET_KERNEL_ASP */
60
61#ifdef TARGET_KERNEL_JSP
62
63#include <t_services.h>
64#include "kernel_id.h"
65#include "tinet_id.h"
66
67#endif /* of #ifdef TARGET_KERNEL_JSP */
68
69#include <tinet_defs.h>
70#include <tinet_config.h>
71
72#include <net/net.h>
73#include <net/net_timer.h>
74
75#include <netinet/in.h>
76#include <netinet/in_itron.h>
77
78#include <netapp/netapp.h>
79#include <netapp/netapp_var.h>
80#include <netapp/echo.h>
81
82#ifdef USE_UDP_ECHO_SRV
83
84/*
85 * 受信タイムアウト
86 */
87
88#define RCV_TMOUT TMO_FEVR
89//#define RCV_TMOUT (30*ULONG_C(1000))
90
91#define BUF_SIZE 2048
92
93static char echo_rcv_buf[BUF_SIZE];
94static T_IPEP dst;
95
96#ifdef USE_UDP_CALL_BACK
97
98/*
99 * コールバック関数
100 */
101
102ER
103callback_udp_echo_srv (ID cepid, FN fncd, void *p_parblk)
104{
105 ER_UINT len;
106 SYSTIM now;
107
108 if ((len = UDP_RCV_DAT(cepid, &dst, echo_rcv_buf, sizeof(echo_rcv_buf), TMO_FEVR)) >= 0) {
109 echo_rcv_buf[len] = '\0';
110 get_tim(&now);
111 syslog(LOG_NOTICE, "[UES:%02d UCB] received, %6ld, from: %s.%d,\n"
112 " msg: '%s'",
113 cepid, now / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno, echo_rcv_buf);
114 if (len > 0) {
115 len = UDP_SND_DAT(cepid, &dst, echo_rcv_buf, len, TMO_FEVR);
116 get_tim(&now);
117 if (len >= 0)
118 syslog(LOG_NOTICE, "[UES:%02d UCB] sent, %6ld, len: %d",
119 cepid, now / SYSTIM_HZ, len);
120 else
121 syslog(LOG_NOTICE, "[UES:%02d UCB] send error, %6ld: %s",
122 cepid, now / SYSTIM_HZ, itron_strerror(len));
123 }
124 len = E_OK;
125 }
126 else {
127 get_tim(&now);
128 syslog(LOG_NOTICE, "[UES:%02d UCB] recv error, %6ld: %s",
129 cepid, now / SYSTIM_HZ, itron_strerror(len));
130 }
131
132 return len;
133 }
134
135#else /* of #ifdef USE_UDP_CALL_BACK */
136
137#ifdef USE_UDP_NON_BLOCKING
138
139/*
140 * 変数
141 */
142
143static ER_UINT nblk_len;
144
145/*
146 * ノンブロッキングコールのコールバック関数
147 */
148
149ER
150callback_nblk_udp_echo_srv (ID cepid, FN fncd, void *p_parblk)
151{
152 SYSTIM now;
153
154 get_tim(&now);
155 nblk_len = *(ER_UINT*)p_parblk;
156 if (nblk_len < 0) { /* 0 以下の場合は、エラーコード */
157 syslog(LOG_NOTICE, "[UES:%02d CBR] error, %6ld: %s, fncd: %s",
158 cepid, now / SYSTIM_HZ, itron_strerror(nblk_len), in_strtfn(fncd));
159 }
160 else if (fncd == TFN_UDP_RCV_DAT) {
161 echo_rcv_buf[nblk_len] = '\0';
162 syslog(LOG_NOTICE, "[UES:%02d CBR] received, %6ld, from: %s.%d,\n"
163 " msg: '%s'",
164 cepid, now / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno, echo_rcv_buf);
165 }
166 syscall(wup_tsk(UDP_ECHO_SRV_TASK));
167 return E_OK;
168 }
169
170/*
171 * UDP ECHO サーバ
172 */
173
174ER
175udp_echo_srv (ID cepid)
176{
177 ER error;
178 SYSTIM now;
179
180 if ((error = UDP_RCV_DAT(cepid, &dst, echo_rcv_buf, sizeof(echo_rcv_buf), TMO_NBLK)) != E_WBLK) {
181 get_tim(&now);
182 syslog(LOG_NOTICE, "[UES:%02d RCV] recv error, %6ld: %s", cepid, now / SYSTIM_HZ, itron_strerror(error));
183 return error;
184 }
185
186 syscall(slp_tsk());
187 if (nblk_len < 0)
188 error = nblk_len;
189 else {
190 if ((error = UDP_SND_DAT(cepid, &dst, echo_rcv_buf, nblk_len, TMO_NBLK)) != E_WBLK) {
191 get_tim(&now);
192 syslog(LOG_NOTICE, "[UES:%02d SND] send error, %6ld: %s",
193 cepid, now / SYSTIM_HZ, itron_strerror(error));
194 return error;
195 }
196
197 syscall(slp_tsk());
198 if (nblk_len < 0)
199 error = nblk_len;
200 else {
201 get_tim(&now);
202 syslog(LOG_NOTICE, "[UES:%02d SND] sent, %6ld, len: %d", cepid, now / SYSTIM_HZ, nblk_len);
203 error = E_OK;
204 }
205 }
206
207 return error;
208 }
209
210#else /* of #ifdef USE_UDP_NON_BLOCKING */
211
212/*
213 * UDP ECHO サーバ
214 */
215
216ER
217udp_echo_srv (ID cepid)
218{
219 ER_UINT len;
220 SYSTIM now;
221
222 if ((len = UDP_RCV_DAT(cepid, &dst, echo_rcv_buf, sizeof(echo_rcv_buf), RCV_TMOUT)) >= 0) {
223 get_tim(&now);
224 echo_rcv_buf[len] = '\0';
225 syslog(LOG_NOTICE, "[UES:%02d RCV] received, %6ld, from: %s.%d,\n"
226 " msg: '%s'",
227 cepid, now / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno, echo_rcv_buf);
228 if (len > 0) {
229 len = UDP_SND_DAT(cepid, &dst, echo_rcv_buf, len, TMO_FEVR);
230 get_tim(&now);
231 if (len >= 0)
232 syslog(LOG_NOTICE, "[UES:%02d SND] sent, %6ld, len: %d",
233 cepid, now / SYSTIM_HZ, (uint16_t)len);
234 else
235 syslog(LOG_NOTICE, "[UES:%02d SND] send error, %6ld: %s",
236 cepid, now / SYSTIM_HZ, itron_strerror(len));
237 }
238 }
239 else {
240 get_tim(&now);
241 syslog(LOG_NOTICE, "[UES:%02d RCV] recv error, %6ld: %s", cepid, now / SYSTIM_HZ, itron_strerror(len));
242 }
243
244 return len >= 0 || len == E_TMOUT ? E_OK : len;
245 }
246
247#endif /* of #ifdef USE_UDP_NON_BLOCKING */
248
249/*
250 * UDP ECHO サーバタスク
251 */
252
253#ifdef USE_UDP_EXTENTIONS
254
255void
256udp_echo_srv_task (intptr_t exinf)
257{
258 ID tskid, cepid;
259 ER error;
260 T_UDP_CCEP ccep;
261
262 get_tid(&tskid);
263 syslog(LOG_NOTICE, "[UDP ECHO SRV:%d,%d] started.", tskid, (ID)exinf);
264 while (true) {
265
266 syscall(slp_tsk());
267
268 ccep.cepatr = UINT_C(0);
269 ccep.myaddr.portno = UINT_C(7);
270
271#if defined(SUPPORT_INET4)
272 ccep.myaddr.ipaddr = IPV4_ADDRANY;
273#endif
274
275#if defined(SUPPORT_INET6)
276 memcpy(&ccep.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
277#endif
278
279#ifdef USE_UDP_NON_BLOCKING
280 ccep.callback = (FP)callback_nblk_udp_echo_srv;
281#else
282 ccep.callback = NULL;
283#endif
284
285 if ((error = alloc_udp_cep(&cepid, tskid, &ccep)) != E_OK) {
286 syslog(LOG_NOTICE, "[UES:%02d TSK] CEP create error: %s", cepid, itron_strerror(error));
287 continue;
288 }
289
290 while (error == E_OK) {
291 if ((error = udp_echo_srv(cepid)) != E_OK) {
292 if ((error = free_udp_cep(cepid, !(error == E_NOEXS || error == E_DLT))) != E_OK)
293 syslog(LOG_NOTICE, "[UEC:%02d TSK] CEP delete error: %s", cepid, itron_strerror(error));
294 break;
295 }
296 }
297
298 }
299 slp_tsk();
300 }
301
302#else /* of #ifdef USE_UDP_EXTENTIONS */
303
304void
305udp_echo_srv_task (intptr_t exinf)
306{
307 ID tskid;
308 ER error = E_OK;
309
310 get_tid(&tskid);
311 syslog(LOG_NOTICE, "[UDP ECHO SRV:%d,%d] started.", tskid, (ID)exinf);
312 while (error == E_OK) {
313 error = udp_echo_srv((ID)exinf);
314 }
315 slp_tsk();
316 }
317
318#endif /* of #ifdef USE_UDP_EXTENTIONS */
319
320#endif /* of #ifdef USE_UDP_CALL_BACK */
321
322#endif /* of #ifdef USE_UDP_ECHO_SRV */
Note: See TracBrowser for help on using the repository browser.