source: EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/udp_echo_cli.c@ 321

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

文字コードを設定
  • Property svn:eol-style set to native
  • Property svn:mime-type set to text/x-csrc;charset=UTF-8
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 * 上記著作権者は，以下の (1)～(4) の条件か，Free Software Foundation
8 * によって公表されている GNU General Public License の Version 2 に記
9 * 述されている条件を満たす場合に限り，本ソフトウェア（本ソフトウェア
10 * を改変したものを含む．以下同じ）を使用・複製・改変・再配布（以下，
11 * 利用と呼ぶ）することを無償で許諾する．
12 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
13 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー
14 * スコード中に含まれていること．
15 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
16 * 用できる形で再配布する場合には，再配布に伴うドキュメント（利用
17 * 者マニュアルなど）に，上記の著作権表示，この利用条件および下記
18 * の無保証規定を掲載すること．
19 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
20 * 用できない形で再配布する場合には，次の条件を満たすこと．
21 * (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著
22 * 作権表示，この利用条件および下記の無保証規定を掲載すること．
23 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
24 * 害からも，上記著作権者およびTOPPERSプロジェクトを免責すること．
25 *
26 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者お
27 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，その適用可能性も
28 * 含めて，いかなる保証も行わない．また，本ソフトウェアの利用により直
29 * 接的または間接的に生じたいかなる損害に関しても，その責任を負わない．
30 *
31 * @(#) $Id$
32 */
33
34/*
35 * UDP ECHO クライアント
36 */
37
38#include <string.h>
39
40#ifdef TARGET_KERNEL_ASP
41
42#include <kernel.h>
43#include <sil.h>
44#include <t_syslog.h>
45#include "kernel_cfg.h"
46
47#endif /* of #ifdef TARGET_KERNEL_ASP */
48
49#ifdef TARGET_KERNEL_JSP
50
51#include <t_services.h>
52#include "kernel_id.h"
53#include "tinet_id.h"
54
55#endif /* of #ifdef TARGET_KERNEL_JSP */
56
57#include <tinet_defs.h>
58#include <tinet_config.h>
59
60#include <net/net.h>
61#include <net/net_var.h>
62#include <net/net_timer.h>
63
64#include <netinet/in.h>
65#include <netinet/in_itron.h>
66
67#include <netapp/netapp.h>
68#include <netapp/netapp_var.h>
69#include <netapp/echo.h>
70
71#ifdef USE_UDP_ECHO_CLI
72
73/* echo サーバのポート番号 */
74
75#define ECHO_SRV_PORTNO UINT_C(7)
76
77/*
78 * 全域変数
79 */
80
81bool_t udp_echo_cli_valid;
82
83/*
84 * 変数
85 */
86
87#define BUF_SIZE 2048
88
89static char udp_buf[BUF_SIZE];
90static T_IPEP dst;
91
92#ifdef USE_UDP_NON_BLOCKING
93
94static ER_UINT nblk_len;
95
96/*
97 * ノンブロッキングコールのコールバック関数
98 */
99
100ER
101callback_nblk_udp_echo_cli (ID cepid, FN fncd, void *p_parblk)
102{
103 nblk_len = *(ER_UINT*)p_parblk;
104 syscall(wup_tsk(UDP_ECHO_CLI_TASK));
105 return E_OK;
106 }
107
108/*
109 * send_udp_echo -- ECHO/UDP サーバにメッセージを送信する (ノンブロッキングコール使用)。
110 */
111
112static ER
113send_udp_echo (ID cepid, T_IN_ADDR *ipaddr, uint16_t portno, char *line)
114{
115 ER_UINT error;
116 uint_t len;
117
118 dst.ipaddr = *ipaddr;
119 dst.portno = portno;
120 len = strlen(line);
121 if ((error = UDP_SND_DAT(cepid, &dst, line, len, TMO_NBLK)) != E_WBLK) {
122 syslog(LOG_NOTICE, "[UEC:%02d SND] error: %s", cepid, itron_strerror(error));
123 return error;
124 }
125 else
126 syslog(LOG_NOTICE, "[UEC:%02d SND] sending: to: %s.%d: %s",
127 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
128
129 syscall(slp_tsk());
130 if (nblk_len < 0) { /* 0 以下の場合は、エラーコード */
131 syslog(LOG_NOTICE, "[UEC:%02d CBR] error: %s", cepid, itron_strerror(nblk_len));
132 return nblk_len;
133 }
134
135 if ((error = UDP_RCV_DAT(cepid, &dst, udp_buf, sizeof(udp_buf), TMO_NBLK)) != E_WBLK) {
136 syslog(LOG_NOTICE, "[UEC:%02d RCV] error: %s", cepid, itron_strerror(error));
137 return error;
138 }
139
140 syscall(slp_tsk());
141 if (nblk_len < 0) { /* 0 以下の場合は、エラーコード */
142 syslog(LOG_NOTICE, "[UEC:%02d RCV] error: %s", cepid, itron_strerror(nblk_len));
143 return nblk_len;
144 }
145 else {
146 udp_buf[nblk_len] = '\0';
147 syslog(LOG_NOTICE, "[UEC:%02d RCV] received: from: %s.%d: %s",
148 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, udp_buf);
149 nblk_len = E_OK;
150 }
151
152 return nblk_len;
153 }
154
155#else /* of #ifdef USE_UDP_NON_BLOCKING */
156
157#ifdef USE_UDP_CALL_BACK
158
159/*
160 * コールバック関数
161 */
162
163ER
164callback_udp_echo_cli (ID cepid, FN fncd, void *p_parblk)
165{
166 ER_UINT len;
167
168 if ((len = UDP_RCV_DAT(cepid, &dst, udp_buf, sizeof(udp_buf), TMO_FEVR)) >= 0) {
169 *(udp_buf + len) = '\0';
170 syslog(LOG_NOTICE, "[UEC:%02d RCV] recv: addr: %s.%d: %s",
171 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, udp_buf);
172 }
173 else
174 syslog(LOG_NOTICE, "[UEC:%02d RCV] recv: error: %s", cepid, itron_strerror(len));
175
176 return E_OK;
177 }
178
179/*
180 * send_udp_echo -- ECHO/UDP サーバにメッセージを送信する (コールバック関数使用)。
181 */
182
183static ER
184send_udp_echo (ID cepid, T_IN_ADDR *ipaddr, uint16_t portno, char *line)
185{
186 ER_UINT len;
187
188 dst.ipaddr = *ipaddr;
189 dst.portno = portno;
190 len = strlen(line);
191 syslog(LOG_NOTICE, "[UEC:%02d SND] sending: to: %s.%d: %s",
192 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
193 if ((len = UDP_SND_DAT(cepid, &dst, line, len, TMO_FEVR)) < 0)
194 syslog(LOG_NOTICE, "[UEC:%02d SND] error: %s", cepid, itron_strerror(len));
195
196 return E_OK;
197 }
198
199#else /* of #ifdef USE_UDP_CALL_BACK */
200
201/*
202 * send_udp_echo -- ECHO/UDP サーバにメッセージを送信する (コールバック関数未使用)。
203 */
204
205static ER
206send_udp_echo (ID cepid, T_IN_ADDR *ipaddr, uint16_t portno, char *line)
207{
208 ER_UINT len;
209
210 dst.ipaddr = *ipaddr;
211 dst.portno = portno;
212 len = strlen(line);
213 syslog(LOG_NOTICE, "[UEC:%02d SND] sending: to: %s.%d: %s",
214 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
215 if ((len = UDP_SND_DAT(cepid, &dst, line, len, TMO_FEVR)) < 0) {
216 syslog(LOG_NOTICE, "[UEC:%02d SND] error: %s", cepid, itron_strerror(len));
217 return len;
218 }
219
220 if ((len = UDP_RCV_DAT(cepid, &dst, udp_buf, sizeof(udp_buf), 10*1000)) >= 0) {
221 *(udp_buf + len) = '\0';
222 syslog(LOG_NOTICE, "[UEC:%02d RCV] received: from: %s.%d: %s",
223 cepid, IP2STR(NULL, &dst.ipaddr), dst.portno, line);
224 return E_OK;
225 }
226 else {
227 syslog(LOG_NOTICE, "[UEC:%02d RCV] error: %s", cepid, itron_strerror(len));
228 return len;
229 }
230 }
231
232#endif /* of #ifdef USE_UDP_CALL_BACK */
233
234#endif /* of #ifdef USE_UDP_NON_BLOCKING */
235
236#define MESSAGE_FORMAT "MSG 1000000"
237
238/*
239 * UDP ECHO クライアント送信タスク
240 */
241
242void
243udp_echo_cli_task (intptr_t exinf)
244{
245 static char msg[sizeof(MESSAGE_FORMAT)] = MESSAGE_FORMAT;
246
247 T_IN_ADDR addr;
248 ID tskid, cepid;
249 ER error = E_OK;
250 char *line, *p;
251 int_t rep;
252 uint32_t count, msgno;
253 uint16_t portno;
254
255#ifdef USE_UDP_EXTENTIONS
256
257 T_UDP_CCEP ccep;
258
259#endif /* of #ifdef USE_UDP_EXTENTIONS */
260
261 get_tid(&tskid);
262 syslog(LOG_NOTICE, "[UDP ECHO CLI:%d,%d] started.", tskid, (ID)exinf);
263 while (true) {
264 if (rcv_dtq(DTQ_UDP_ECHO_CLI, (intptr_t*)&line) == E_OK) {
265
266#ifdef USE_UDP_EXTENTIONS
267
268 ccep.cepatr = UINT_C(0);
269 ccep.myaddr.portno = UDP_PORTANY;
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_cli;
281#else
282 ccep.callback = NULL;
283#endif
284
285 if ((error = alloc_udp_cep(&cepid, tskid, &ccep)) != E_OK) {
286 syslog(LOG_NOTICE, "[UEC:%02d TSK] CEP create error: %s", cepid, itron_strerror(error));
287 continue;
288 }
289
290#else /* of #ifdef USE_UDP_EXTENTIONS */
291
292 cepid = (ID)exinf;
293
294#endif /* of #ifdef USE_UDP_EXTENTIONS */
295
296 line = skip_blanks(GET_IPADDR(&addr, skip_blanks(line))); /* IP Address */
297
298 if ('0' <= *line && *line <= '9') { /* Port No */
299 line = get_int(&rep, line);
300 portno = (uint16_t)rep;
301 }
302 else {
303 line ++;
304 portno = ECHO_SRV_PORTNO;
305 }
306
307 line = skip_blanks(line);
308 if ('0' <= *line && *line <= '9') { /* Repeat */
309 line = get_int(&rep, line);
310 if (rep > 1000000)
311 rep = 1000000;
312 udp_echo_cli_valid = true;
313 for (count = 0; count ++ < rep; ) {
314 if (!udp_echo_cli_valid) {
315 syslog(LOG_NOTICE, "[UEC:%02d TSK] canceled.", cepid);
316 break;
317 }
318
319 p = &msg[sizeof(MESSAGE_FORMAT)] - 1;
320 for (msgno = count; msgno > 0; msgno /= 10)
321 *(-- p) = msgno % 10 + '0';
322 while (*(p - 2) != 'G')
323 *(-- p) = ' ';
324
325 if ((error = send_udp_echo(cepid, &addr, portno, msg)) != E_OK)
326 break;
327
328 dly_tsk(10 * SYSTIM_HZ + net_rand() % (10 * SYSTIM_HZ));
329 }
330 }
331
332 else /* Single Message */
333 error = send_udp_echo(cepid, &addr, portno, line);
334
335 if (error != E_OK)
336 syslog(LOG_NOTICE, "[UEC:%02d TSK] error: %s", cepid, itron_strerror(error));
337
338#ifdef USE_UDP_EXTENTIONS
339
340 if ((error = free_udp_cep(cepid, !(error == E_NOEXS || error == E_DLT))) != E_OK)
341 syslog(LOG_NOTICE, "[UEC:%02d TSK] CEP delete error: %s", cepid, itron_strerror(error));
342
343#endif /* of #ifdef USE_UDP_EXTENTIONS */
344
345 }
346 }
347 }
348
349#endif /* of #ifdef USE_UDP_ECHO_CLI */
Note: See TracBrowser for help on using the repository browser.