source: EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/udp_echo_cli.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: 9.6 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_cli.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_var.h>
74#include <net/net_timer.h>
75
76#include <netinet/in.h>
77#include <netinet/in_itron.h>
78
79#include <netapp/netapp.h>
80#include <netapp/netapp_var.h>
81#include <netapp/echo.h>
82
83#ifdef USE_UDP_ECHO_CLI
84
85/* echo サーバのポート番号 */
86
87#define ECHO_SRV_PORTNO UINT_C(7)
88
89/*
90 * å…
91¨åŸŸå¤‰æ•°
92 */
93
94bool_t udp_echo_cli_valid;
95
96/*
97 * 変数
98 */
99
100#define BUF_SIZE 2048
101
102static char udp_buf[BUF_SIZE];
103static T_IPEP dst;
104
105#ifdef USE_UDP_NON_BLOCKING
106
107static ER_UINT nblk_len;
108
109/*
110 * ノンブロッキングコールのコールバック関数
111 */
112
113ER
114callback_nblk_udp_echo_cli (ID cepid, FN fncd, void *p_parblk)
115{
116 nblk_len = *(ER_UINT*)p_parblk;
117 syscall(wup_tsk(UDP_ECHO_CLI_TASK));
118 return E_OK;
119 }
120
121/*
122 * send_udp_echo -- ECHO/UDP サーバにメッセージを送信する (ノンブロッキングコール使用)。
123 */
124
125static ER
126send_udp_echo (ID cepid, T_IN_ADDR *ipaddr, uint16_t portno, char *line)
127{
128 ER_UINT error;
129 uint_t len;
130
131 dst.ipaddr = *ipaddr;
132 dst.portno = portno;
133 len = strlen(line);
134 if ((error = UDP_SND_DAT(cepid, &dst, line, len, TMO_NBLK)) != E_WBLK) {
135 syslog(LOG_NOTICE, "[UEC:%02d SND] error: %s", cepid, itron_strerror(error));
136 return error;
137 }
138 else
139 syslog(LOG_NOTICE, "[UEC:%02d SND] sending: to: %s.%d: %s",
140 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
141
142 syscall(slp_tsk());
143 if (nblk_len < 0) { /* 0 以下の場合は、エラーコード */
144 syslog(LOG_NOTICE, "[UEC:%02d CBR] error: %s", cepid, itron_strerror(nblk_len));
145 return nblk_len;
146 }
147
148 if ((error = UDP_RCV_DAT(cepid, &dst, udp_buf, sizeof(udp_buf), TMO_NBLK)) != E_WBLK) {
149 syslog(LOG_NOTICE, "[UEC:%02d RCV] error: %s", cepid, itron_strerror(error));
150 return error;
151 }
152
153 syscall(slp_tsk());
154 if (nblk_len < 0) { /* 0 以下の場合は、エラーコード */
155 syslog(LOG_NOTICE, "[UEC:%02d RCV] error: %s", cepid, itron_strerror(nblk_len));
156 return nblk_len;
157 }
158 else {
159 udp_buf[nblk_len] = '\0';
160 syslog(LOG_NOTICE, "[UEC:%02d RCV] received: from: %s.%d: %s",
161 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, udp_buf);
162 nblk_len = E_OK;
163 }
164
165 return nblk_len;
166 }
167
168#else /* of #ifdef USE_UDP_NON_BLOCKING */
169
170#ifdef USE_UDP_CALL_BACK
171
172/*
173 * コールバック関数
174 */
175
176ER
177callback_udp_echo_cli (ID cepid, FN fncd, void *p_parblk)
178{
179 ER_UINT len;
180
181 if ((len = UDP_RCV_DAT(cepid, &dst, udp_buf, sizeof(udp_buf), TMO_FEVR)) >= 0) {
182 *(udp_buf + len) = '\0';
183 syslog(LOG_NOTICE, "[UEC:%02d RCV] recv: addr: %s.%d: %s",
184 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, udp_buf);
185 }
186 else
187 syslog(LOG_NOTICE, "[UEC:%02d RCV] recv: error: %s", cepid, itron_strerror(len));
188
189 return E_OK;
190 }
191
192/*
193 * send_udp_echo -- ECHO/UDP サーバにメッセージを送信する (コールバック関数使用)。
194 */
195
196static ER
197send_udp_echo (ID cepid, T_IN_ADDR *ipaddr, uint16_t portno, char *line)
198{
199 ER_UINT len;
200
201 dst.ipaddr = *ipaddr;
202 dst.portno = portno;
203 len = strlen(line);
204 syslog(LOG_NOTICE, "[UEC:%02d SND] sending: to: %s.%d: %s",
205 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
206 if ((len = UDP_SND_DAT(cepid, &dst, line, len, TMO_FEVR)) < 0)
207 syslog(LOG_NOTICE, "[UEC:%02d SND] error: %s", cepid, itron_strerror(len));
208
209 return E_OK;
210 }
211
212#else /* of #ifdef USE_UDP_CALL_BACK */
213
214/*
215 * send_udp_echo -- ECHO/UDP サーバにメッセージを送信する (コールバック関数未使用)。
216 */
217
218static ER
219send_udp_echo (ID cepid, T_IN_ADDR *ipaddr, uint16_t portno, char *line)
220{
221 ER_UINT len;
222
223 dst.ipaddr = *ipaddr;
224 dst.portno = portno;
225 len = strlen(line);
226 syslog(LOG_NOTICE, "[UEC:%02d SND] sending: to: %s.%d: %s",
227 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
228 if ((len = UDP_SND_DAT(cepid, &dst, line, len, TMO_FEVR)) < 0) {
229 syslog(LOG_NOTICE, "[UEC:%02d SND] error: %s", cepid, itron_strerror(len));
230 return len;
231 }
232
233 if ((len = UDP_RCV_DAT(cepid, &dst, udp_buf, sizeof(udp_buf), 10*1000)) >= 0) {
234 *(udp_buf + len) = '\0';
235 syslog(LOG_NOTICE, "[UEC:%02d RCV] received: from: %s.%d: %s",
236 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
237 return E_OK;
238 }
239 else {
240 syslog(LOG_NOTICE, "[UEC:%02d RCV] error: %s", cepid, itron_strerror(len));
241 return len;
242 }
243 }
244
245#endif /* of #ifdef USE_UDP_CALL_BACK */
246
247#endif /* of #ifdef USE_UDP_NON_BLOCKING */
248
249#define MESSAGE_FORMAT "MSG 1000000"
250
251/*
252 * UDP ECHO クライアント送信タスク
253 */
254
255void
256udp_echo_cli_task (intptr_t exinf)
257{
258 static char msg[sizeof(MESSAGE_FORMAT)] = MESSAGE_FORMAT;
259
260 T_IN_ADDR addr;
261 ID tskid, cepid;
262 ER error = E_OK;
263 char *line, *p;
264 int_t rep;
265 uint32_t count, msgno;
266 uint16_t portno;
267
268#ifdef USE_UDP_EXTENTIONS
269
270 T_UDP_CCEP ccep;
271
272#endif /* of #ifdef USE_UDP_EXTENTIONS */
273
274 get_tid(&tskid);
275 syslog(LOG_NOTICE, "[UDP ECHO CLI:%d,%d] started.", tskid, (ID)exinf);
276 while (true) {
277 if (rcv_dtq(DTQ_UDP_ECHO_CLI, (intptr_t*)&line) == E_OK) {
278
279#ifdef USE_UDP_EXTENTIONS
280
281 ccep.cepatr = UINT_C(0);
282 ccep.myaddr.portno = UDP_PORTANY;
283
284#if defined(SUPPORT_INET4)
285 ccep.myaddr.ipaddr = IPV4_ADDRANY;
286#endif
287
288#if defined(SUPPORT_INET6)
289 memcpy(&ccep.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
290#endif
291
292#ifdef USE_UDP_NON_BLOCKING
293 ccep.callback = (FP)callback_nblk_udp_echo_cli;
294#else
295 ccep.callback = NULL;
296#endif
297
298 if ((error = alloc_udp_cep(&cepid, tskid, &ccep)) != E_OK) {
299 syslog(LOG_NOTICE, "[UEC:%02d TSK] CEP create error: %s", cepid, itron_strerror(error));
300 continue;
301 }
302
303#else /* of #ifdef USE_UDP_EXTENTIONS */
304
305 cepid = (ID)exinf;
306
307#endif /* of #ifdef USE_UDP_EXTENTIONS */
308
309 line = skip_blanks(GET_IPADDR(&addr, skip_blanks(line))); /* IP Address */
310
311 if ('0' <= *line && *line <= '9') { /* Port No */
312 line = get_int(&rep, line);
313 portno = (uint16_t)rep;
314 }
315 else {
316 line ++;
317 portno = ECHO_SRV_PORTNO;
318 }
319
320 line = skip_blanks(line);
321 if ('0' <= *line && *line <= '9') { /* Repeat */
322 line = get_int(&rep, line);
323 if (rep > 1000000)
324 rep = 1000000;
325 udp_echo_cli_valid = true;
326 for (count = 0; count ++ < rep; ) {
327 if (!udp_echo_cli_valid) {
328 syslog(LOG_NOTICE, "[UEC:%02d TSK] canceled.", cepid);
329 break;
330 }
331
332 p = &msg[sizeof(MESSAGE_FORMAT)] - 1;
333 for (msgno = count; msgno > 0; msgno /= 10)
334 *(-- p) = msgno % 10 + '0';
335 while (*(p - 2) != 'G')
336 *(-- p) = ' ';
337
338 if ((error = send_udp_echo(cepid, &addr, portno, msg)) != E_OK)
339 break;
340
341 dly_tsk(10 * SYSTIM_HZ + net_rand() % (10 * SYSTIM_HZ));
342 }
343 }
344
345 else /* Single Message */
346 error = send_udp_echo(cepid, &addr, portno, line);
347
348 if (error != E_OK)
349 syslog(LOG_NOTICE, "[UEC:%02d TSK] error: %s", cepid, itron_strerror(error));
350
351#ifdef USE_UDP_EXTENTIONS
352
353 if ((error = free_udp_cep(cepid, !(error == E_NOEXS || error == E_DLT))) != E_OK)
354 syslog(LOG_NOTICE, "[UEC:%02d TSK] CEP delete error: %s", cepid, itron_strerror(error));
355
356#endif /* of #ifdef USE_UDP_EXTENTIONS */
357
358 }
359 }
360 }
361
362#endif /* of #ifdef USE_UDP_ECHO_CLI */
Note: See TracBrowser for help on using the repository browser.