source: EcnlProtoTool/trunk/asp3_dcre/tinet/netapp/tcp_echo_srv1_ext.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: 9.8 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 * TCP ECHO サーバ #1
48 *
49 * ・送受信タスク同一型
50 * ・ノンブロッキングコール
51 * ・省コピー API
52 * ・IPv4/IPv6
53 * ・緊急データの受信
54 */
55
56#include <string.h>
57
58#ifdef TARGET_KERNEL_ASP
59
60#include <kernel.h>
61#include <sil.h>
62#include <t_syslog.h>
63#include "kernel_cfg.h"
64#include "tinet_cfg.h"
65
66#endif /* of #ifdef TARGET_KERNEL_ASP */
67
68#ifdef TARGET_KERNEL_JSP
69
70#include <t_services.h>
71#include "kernel_id.h"
72#include "tinet_id.h"
73
74#endif /* of #ifdef TARGET_KERNEL_JSP */
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/tcp_echo_srv1.h>
82#include <netapp/tcp_echo_srv1_var.h>
83
84#ifdef USE_TCP_ECHO_SRV1
85
86/*
87 * 表示
88 */
89
90//#define SHOW_RCV_RANGE
91
92/*
93 * コネクション切断方法の指定
94 */
95
96#define USE_TCP_SHT_CEP
97
98/*
99 * タイムアウト
100 */
101
102#ifdef TOPPERS_S810_CLG3_85
103
104#define CLS_TMO TMO_FEVR /* Close Wait は標準で 60秒 */
105//#define RCV_TMO TMO_FEVR
106#define RCV_TMO (30*SYSTIM_HZ)
107//#define SND_TMO TMO_FEVR
108#define SND_TMO (30*SYSTIM_HZ)
109
110#else /* of #ifdef TOPPERS_S810_CLG3_85 */
111
112//#define CLS_TMO TMO_FEVR /* Close Wait は標準で 60秒 */
113#define CLS_TMO (70*SYSTIM_HZ+(netapp_rand()%SYSTIM_HZ)*10)
114//#define RCV_TMO TMO_FEVR
115#define RCV_TMO (30*SYSTIM_HZ+(netapp_rand()%SYSTIM_HZ)*30)
116//#define SND_TMO TMO_FEVR
117#define SND_TMO (40*SYSTIM_HZ+(netapp_rand()%SYSTIM_HZ)*20)
118
119#endif /* of #ifdef TOPPERS_S810_CLG3_85 */
120
121#ifdef USE_TCP_EXTENTIONS
122
123/*
124 * 変数
125 */
126
127typedef struct t_tcp_echo_srv_task_info {
128 ID taskid; /* タスク ID */
129 bool_t active; /* 動作状æ…
130‹ */
131 char apip; /* API IPプロトコル */
132 } T_TCP_ECHO_SRV_TASK_INFO;
133
134static T_TCP_ECHO_SRV_TASK_INFO tcp_echo_srv_task_info[NUM_TCP_ECHO_SRV_TASKS] = {
135
136 { TCP_ECHO_SRV_TASK1, false },
137
138#if NUM_TCP_ECHO_SRV_TASKS >= 2
139 { TCP_ECHO_SRV_TASK2, false },
140#endif
141#if NUM_TCP_ECHO_SRV_TASKS >= 3
142 { TCP_ECHO_SRV_TASK3, false },
143#endif
144#if NUM_TCP_ECHO_SRV_TASKS >= 4
145 { TCP_ECHO_SRV_TASK4, false },
146#endif
147#if NUM_TCP_ECHO_SRV_TASKS >= 5
148 { TCP_ECHO_SRV_TASK5, false },
149#endif
150#if NUM_TCP_ECHO_SRV_TASKS >= 6
151 { TCP_ECHO_SRV_TASK6, false },
152#endif
153#if NUM_TCP_ECHO_SRV_TASKS >= 7
154 { TCP_ECHO_SRV_TASK7, false },
155#endif
156#if NUM_TCP_ECHO_SRV_TASKS >= 8
157 { TCP_ECHO_SRV_TASK8, false },
158#endif
159
160 };
161
162/*
163 * get_tcp_rep -- TCP 受付口を獲得する。
164 */
165
166#if defined(SUPPORT_INET6) && defined(SUPPORT_INET4)
167
168static ER
169get_tcp_rep (ID *repid, char apip)
170{
171 ID tskid;
172 T_TCP6_CREP crep6;
173 T_TCP_CREP crep4;
174
175 get_tid(&tskid);
176 if (apip == API_PROTO_IPV6) {
177 crep6.repatr = UINT_C(0);
178 crep6.myaddr.portno = UINT_C(7);
179 memcpy(&crep6.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
180 return alloc_tcp6_rep(repid, tskid, &crep6);
181 }
182 else {
183 crep4.repatr = UINT_C(0);
184 crep4.myaddr.portno = UINT_C(7);
185 crep4.myaddr.ipaddr = IPV4_ADDRANY;
186 return alloc_tcp4_rep(repid, tskid, &crep4);
187 }
188 }
189
190#else /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
191
192static ER
193get_tcp_rep (ID *repid, char apip)
194{
195 ID tskid;
196 T_TCPN_CREP crep;
197
198 get_tid(&tskid);
199
200 crep.repatr = UINT_C(0);
201 crep.myaddr.portno = UINT_C(7);
202
203#if defined(SUPPORT_INET6)
204
205 memcpy(&crep.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
206
207#else /* #if defined(SUPPORT_INET6) */
208
209#if defined(SUPPORT_INET4)
210 crep.myaddr.ipaddr = IPV4_ADDRANY;
211#endif
212
213#endif /* #if defined(SUPPORT_INET6) */
214
215 return ALLOC_TCP_REP(repid, tskid, &crep);
216 }
217
218#endif /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
219
220/*
221 * get_tcp_cep -- TCP 通信端点を獲得する。
222 */
223
224static ER
225get_tcp_cep (ID *cepid, char apip)
226{
227 ID tskid;
228 T_TCP_CCEP ccep;
229
230 get_tid(&tskid);
231
232 ccep.cepatr = UINT_C(0);
233 ccep.sbufsz = TCP_ECHO_SRV_SWBUF_SIZE;
234 ccep.rbufsz = TCP_ECHO_SRV_RWBUF_SIZE;
235
236#ifdef TCP_CFG_SWBUF_CSAVE
237 ccep.sbuf = NADR;
238#else
239 ccep.sbuf = tcp_echo_srv_swbuf;
240#endif
241#ifdef TCP_CFG_RWBUF_CSAVE
242 ccep.rbuf = NADR;
243#else
244 ccep.rbuf = tcp_echo_srv_rwbuf;
245#endif
246#ifdef USE_TCP_NON_BLOCKING
247 ccep.callback = (FP)callback_nblk_tcp_echo_srv;
248#else
249 ccep.callback = NULL;
250#endif
251
252#if defined(SUPPORT_INET6) && defined(SUPPORT_INET4)
253
254 if (apip == API_PROTO_IPV6)
255 return alloc_tcp6_cep(cepid, tskid, &ccep);
256 else
257 return alloc_tcp4_cep(cepid, tskid, &ccep);
258
259#else /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
260
261 return ALLOC_TCP_CEP(cepid, tskid, &ccep);
262
263#endif /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
264
265 }
266
267/*
268 * wakeup_tcp_echo_srv -- TCP エコーサーバタスクの休止解除
269 */
270
271ER
272wakeup_tcp_echo_srv (char apip)
273{
274 int ix;
275
276 for (ix = NUM_TCP_ECHO_SRV_TASKS; -- ix >= 0; )
277 if (!tcp_echo_srv_task_info[ix].active) {
278 syslog(LOG_NOTICE, "[TCP%c ECHO SRV(EXT):%d] wake up.",
279 apip, tcp_echo_srv_task_info[ix].taskid);
280 tcp_echo_srv_task_info[ix].apip = apip;
281 tcp_echo_srv_task_info[ix].active = true;
282 return syscall(wup_tsk(tcp_echo_srv_task_info[ix].taskid));
283 }
284 syslog(LOG_NOTICE, "[TCP%c ECHO SRV(EXT):%d] wake up error: %s.",
285 apip, tcp_echo_srv_task_info[ix].taskid, itron_strerror(E_ID));
286 return E_ID;
287 }
288
289/*
290 * tcp_echo_srv_task -- TCP エコーサーバタスク
291 */
292
293void
294tcp_echo_srv_task (intptr_t exinf)
295{
296 ID tskid;
297 ER error = E_OK;
298 int ix;
299 char apip;
300
301 syscall(get_tid(&tskid));
302 syslog(LOG_NOTICE, "[TCPn ECHO SRV(EXT):%d] started.", tskid);
303 while (true) {
304 syslog(LOG_NOTICE, "[TCPn ECHO SRV(EXT):%d] goto sleep.", tskid);
305 syscall(slp_tsk());
306
307 for (ix = NUM_TCP_ECHO_SRV_TASKS; -- ix >= 0; ) {
308 if (tcp_echo_srv_task_info[ix].taskid == tskid) {
309 break;
310 }
311 }
312
313 apip = tcp_echo_srv_task_info[ix].apip;
314 if ((error = get_tcp_cep(&tcp_echo_srv_info[ix].cepid, apip)) != E_OK) {
315 syslog(LOG_NOTICE, "[TCP%c ECHO SRV(EXT):%d] create CEP error: %s",
316 apip, tskid, itron_strerror(error));
317 continue;
318 }
319
320 while (true) {
321
322 if ((error = get_tcp_rep(&tcp_echo_srv_info[ix].repid, apip)) != E_OK) {
323 syslog(LOG_NOTICE, "[TCP%c ECHO SRV(EXT):%d] create REP error: %s",
324 apip, tskid, itron_strerror(error));
325 break;
326 }
327 else if ((error = tcp_echo_srv(ix, apip)) != E_OK) {
328
329#if defined(SUPPORT_INET6) && defined(SUPPORT_INET4)
330
331 if (apip == API_PROTO_IPV6)
332 error = free_tcp6_rep(tcp_echo_srv_info[ix].repid, error != E_DLT);
333 else
334 error = free_tcp4_rep(tcp_echo_srv_info[ix].repid, error != E_DLT);
335
336#else /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
337
338 error = FREE_TCP_REP(tcp_echo_srv_info[ix].repid, error != E_DLT);
339
340#endif /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
341
342 if (error != E_OK) {
343 syslog(LOG_NOTICE, "[TCP%c ECHO SRV(EXT):%d] delete REP error: %s",
344 apip, tskid, itron_strerror(error));
345 }
346
347 break;
348 }
349 }
350
351#if defined(SUPPORT_INET6) && defined(SUPPORT_INET4)
352
353 if (apip == API_PROTO_IPV6)
354 error = free_tcp6_cep(tcp_echo_srv_info[ix].cepid);
355 else
356 error = free_tcp4_cep(tcp_echo_srv_info[ix].cepid);
357
358#else /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
359
360 error = FREE_TCP_CEP(tcp_echo_srv_info[ix].cepid);
361
362#endif /* of #if defined(SUPPORT_INET6) && defined(SUPPORT_INET4) */
363
364 if (error != E_OK) {
365 syslog(LOG_NOTICE, "[TCP%c ECHO SRV(EXT):%d] delete CEP error: %s",
366 apip, tskid, itron_strerror(error));
367 }
368
369 for (ix = NUM_TCP_ECHO_SRV_TASKS; -- ix >= 0; ) {
370 if (tcp_echo_srv_task_info[ix].taskid == tskid) {
371 tcp_echo_srv_task_info[ix].active = false;
372 break;
373 }
374 }
375
376 }
377 }
378
379#endif /* of #ifdef USE_TCP_EXTENTIONS */
380
381#endif /* of #ifdef USE_TCP_ECHO_SRV1 */
Note: See TracBrowser for help on using the repository browser.