source: azure_iot_hub/trunk/asp3_dcre/tinet/netapp/tcp_discard_srv.c@ 388

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

Azure IoT Hub Device C SDK を使ったサンプルの追加
  • 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.4 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: tcp_discard_srv.c 388 2019-05-22 11:25:18Z coas-nagasima $
44 */
45
46/*
47 * DISCARD サーバ
48 *
49 * ・省コピー API
50 * ・IPv4
51 * ・IPv6
52 */
53
54#include <string.h>
55
56#ifdef TARGET_KERNEL_ASP
57
58#include <kernel.h>
59#include <sil.h>
60#include <t_syslog.h>
61#include "tinet_cfg.h"
62
63#endif /* of #ifdef TARGET_KERNEL_ASP */
64
65#ifdef TARGET_KERNEL_JSP
66
67#include <t_services.h>
68#include "tinet_id.h"
69
70#endif /* of #ifdef TARGET_KERNEL_JSP */
71
72#include <netinet/in.h>
73#include <netinet/in_itron.h>
74
75#include <netapp/netapp.h>
76#include <netapp/netapp_var.h>
77#include <netapp/tcp_discard_srv.h>
78
79#ifdef USE_TCP_DISCARD_SRV
80
81/*
82 * 表示
83 */
84
85//#define SHOW_RCV_RANGE
86//#define SHOW_RCV_DATA
87
88/*
89 * å…
90¨åŸŸå¤‰æ•°
91 */
92
93/* TCP 送受信ウィンドバッファ */
94
95#ifndef TCP_CFG_RWBUF_CSAVE_ONLY
96uint8_t tcp_discard_srv_rwbuf[TCP_DISCARD_SRV_RWBUF_SIZE];
97#endif
98
99/*
100 * TCP DISCARD サーバタスク
101 */
102
103#define BUF_SIZE TCP_DISCARD_SRV_RWBUF_SIZE
104
105#ifdef USE_COPYSAVE_API
106
107static ER
108tcp_discard_srv (ID cepid, ID repid)
109{
110 T_IPEP dst;
111 ER_UINT rlen;
112 ER error;
113 SYSTIM time;
114 uint32_t total;
115 uint16_t count;
116 uint8_t *buf;
117
118#ifdef SHOW_RCV_DATA
119 uint_t ix;
120#endif /* of #ifdef SHOW_RCV_DATA */
121
122 if ((error = TCP_ACP_CEP(cepid, repid, &dst, TMO_FEVR)) != E_OK) {
123 syslog(LOG_NOTICE, "[TDSn:%02u ACP] accept error: %s", cepid, itron_strerror(error));
124 return error;
125 }
126
127#ifdef USE_TCP_EXTENTIONS
128 if ((error = FREE_TCP_REP(repid, true)) != E_OK) {
129 syslog(LOG_NOTICE, "[TDSn:%02u DEL] REP delete error: %s", cepid, itron_strerror(error));
130 return error;
131 }
132#endif /* of #ifdef USE_TCP_EXTENTIONS */
133
134 count = total = 0;
135 get_tim(&time);
136 syslog(LOG_NOTICE, "[TDSn:%02u RCV] conct: %7lu, from: %s.%d",
137 cepid, time / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno);
138 while ((rlen = tcp_rcv_buf(cepid, (void*)&buf, TMO_FEVR)) > 0) {
139 count ++;
140
141#ifdef SHOW_RCV_RANGE
142 syslog(LOG_NOTICE, "[TDSn:%02u RCV] count: %6lu, len: %4u, data: %02x -> %02x",
143 cepid, count, (uint16_t)rlen, *buf, *(buf + rlen - 1));
144#endif /* of #ifdef SHOW_RCV_RANGE */
145
146#ifdef SHOW_RCV_DATA
147 for (ix = 0; ix < rlen; ix ++)
148 cons_putchar(CONSOLE_PORTID, *(buf + ix));
149#endif /* of #ifdef SHOW_RCV_DATA */
150
151 if ((error = tcp_rel_buf(cepid, rlen)) != E_OK) {
152 syslog(LOG_NOTICE, "[TDSn:%02u RCV] rel buf error: %s",
153 cepid, itron_strerror(error));
154 rlen = 0;
155 break;
156 }
157 total += rlen;
158 }
159
160 if (rlen != 0)
161 syslog(LOG_NOTICE, "[TDSn:%02u RCV] recv buf error: %s", cepid, itron_strerror(rlen));
162
163 if ((error = tcp_sht_cep(cepid)) != E_OK)
164 syslog(LOG_NOTICE, "[TDSn:%02u RCV] shutdown error: %s", cepid, itron_strerror(error));
165
166 if ((error = tcp_cls_cep(cepid, TMO_FEVR)) != E_OK)
167 syslog(LOG_NOTICE, "[TDSn:%02u RCV] close error: %s", cepid, itron_strerror(error));
168
169 get_tim(&time);
170 syslog(LOG_NOTICE, "[TDSn:%02u RCV] finsh: %7lu, ttl: %lu",
171 cepid, time / SYSTIM_HZ, count, total);
172
173 return error;
174 }
175
176#else /* of #ifdef USE_COPYSAVE_API */
177
178static ER
179tcp_discard_srv (ID cepid, ID repid)
180{
181 static char buffer[BUF_SIZE];
182
183 T_IPEP dst;
184 ER_UINT rlen;
185 ER error;
186 SYSTIM time;
187 uint32_t total;
188 uint16_t count;
189 uint8_t *buf = buffer;
190
191 if ((error = TCP_ACP_CEP(cepid, repid, &dst, TMO_FEVR)) != E_OK) {
192 syslog(LOG_NOTICE, "[TDSn:%02u RCV] accept error: %s", cepid, itron_strerror(error));
193 return error;
194 }
195
196#ifdef USE_TCP_EXTENTIONS
197 if ((error = FREE_TCP_REP(repid, true)) != E_OK) {
198 syslog(LOG_NOTICE, "[TDSn:%02u DEL] REP delete error: %s", cepid, itron_strerror(error));
199 return error;
200 }
201#endif /* of #ifdef USE_TCP_EXTENTIONS */
202
203 count = total = 0;
204 get_tim(&time);
205 syslog(LOG_NOTICE, "[TDSn:%02u RCV] conct: %7lu, from: %s.%d",
206 cepid, time / SYSTIM_HZ, IP2STR(NULL, &dst.ipaddr), dst.portno);
207 while ((rlen = tcp_rcv_dat(cepid, buf, BUF_SIZE - 1, TMO_FEVR)) > 0) {
208 count ++;
209
210#ifdef SHOW_RCV_RANGE
211 syslog(LOG_NOTICE, "[TDSn:%02u RCV] count: %6lu, len: %4u, data: %02x -> %02x",
212 cepid, count, (uint16_t)rlen, *buf, *(buf + rlen - 1));
213#endif /* of #ifdef SHOW_RCV_RANGE */
214
215 total += rlen;
216 }
217 if (rlen != 0)
218 syslog(LOG_NOTICE, "[TDSn:%02u RCV] recv error: %s", cepid, itron_strerror(rlen));
219
220 if ((error = tcp_sht_cep(cepid)) != E_OK)
221 syslog(LOG_NOTICE, "[TDSn:%02u RCV] shutdown error: %s", cepid, itron_strerror(error));
222
223 if ((error = tcp_cls_cep(cepid, TMO_FEVR)) != E_OK)
224 syslog(LOG_NOTICE, "[TDSn:%02u RCV] close error: %s", cepid, itron_strerror(error));
225
226 get_tim(&time);
227 syslog(LOG_NOTICE, "[TDSn:%02u RCV] finsh: %7lu, ttl: %lu",
228 cepid, time / SYSTIM_HZ, count, total);
229
230 return error;
231 }
232
233#endif /* of #ifdef USE_COPYSAVE_API */
234
235#ifdef USE_TCP_EXTENTIONS
236
237/*
238 * get_tcp_rep -- TCP 受付口を獲得する。
239 */
240
241static ER
242get_tcp_rep (ID *repid)
243{
244 ID tskid;
245 T_TCPN_CREP crep;
246
247 get_tid(&tskid);
248
249 crep.repatr = UINT_C(0);
250 crep.myaddr.portno = UINT_C(9);
251
252#if defined(SUPPORT_INET6)
253
254 memcpy(&crep.myaddr.ipaddr, &ipv6_addrany, sizeof(T_IN6_ADDR));
255
256#else /* #if defined(SUPPORT_INET6) */
257
258#if defined(SUPPORT_INET4)
259 crep.myaddr.ipaddr = IPV4_ADDRANY;
260#endif
261
262#endif /* #if defined(SUPPORT_INET6) */
263
264 return ALLOC_TCP_REP(repid, tskid, &crep);
265 }
266
267/*
268 * get_tcp_cep -- TCP 通信端点とを獲得する。
269 */
270
271static ER
272get_tcp_cep (ID *cepid)
273{
274 ID tskid;
275 T_TCP_CCEP ccep;
276
277 get_tid(&tskid);
278
279 ccep.cepatr = UINT_C(0);
280 ccep.sbuf = NADR;
281 ccep.sbufsz = 0;
282 ccep.rbufsz = TCP_DISCARD_SRV_RWBUF_SIZE;
283 ccep.callback = NULL;
284
285#ifdef TCP_CFG_RWBUF_CSAVE
286 ccep.rbuf = NADR;
287#else
288 ccep.rbuf = tcp_discard_srv_rwbuf;
289#endif
290
291 return ALLOC_TCP_CEP(cepid, tskid, &ccep);
292 }
293
294/*
295 * tcp_discard_srv_task -- TCP エコーサーバタスク
296 */
297
298void
299tcp_discard_srv_task (intptr_t exinf)
300{
301 ID tskid, cepid, repid;
302 ER error = E_OK;
303
304 syscall(get_tid(&tskid));
305
306#if defined(SUPPORT_INET6)
307#if defined(SUPPORT_INET4)
308 syslog(LOG_NOTICE, "[TCPn DISCARD SRV:%d] started.", tskid);
309#else
310 syslog(LOG_NOTICE, "[TCP6 DISCARD SRV:%d] started.", tskid);
311#endif
312#else
313 syslog(LOG_NOTICE, "[TCP4 DISCARD SRV:%d] started.", tskid);
314#endif
315
316 while (true) {
317
318 syscall(slp_tsk());
319 if ((error = get_tcp_cep (&cepid)) != E_OK) {
320 syslog(LOG_NOTICE, "[TDSn:00 EXT] CEP create error: %s", itron_strerror(error));
321 continue;
322 }
323
324 while (true) {
325
326 if ((error = get_tcp_rep (&repid)) != E_OK) {
327 syslog(LOG_NOTICE, "[TDSn:00 EXT] REP create error: %s", itron_strerror(error));
328 break;
329 }
330 else if ((error = tcp_discard_srv(cepid, repid)) != E_OK) {
331 error = FREE_TCP_REP(repid, error != E_DLT);
332 break;
333 }
334 }
335
336 if ((error = FREE_TCP_CEP(cepid)) != E_OK)
337 syslog(LOG_NOTICE, "[TDSn:%02u EXT] CEP delete error: %s", cepid, itron_strerror(error));
338
339 }
340 }
341
342#else /* of #ifdef USE_TCP_EXTENTIONS */
343
344void
345tcp_discard_srv_task(intptr_t exinf)
346{
347 ID tskid;
348
349 get_tid(&tskid);
350
351#if defined(SUPPORT_INET6)
352#if defined(SUPPORT_INET4)
353 syslog(LOG_NOTICE, "[TCPn DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
354#else
355 syslog(LOG_NOTICE, "[TCP6 DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
356#endif
357#else
358 syslog(LOG_NOTICE, "[TCP4 DISCARD SRV:%d,%d] started.", tskid, (ID)exinf);
359#endif
360
361 while (true) {
362 while (tcp_discard_srv((ID)exinf, TCP_DISCARD_SRV_REPID) == E_OK)
363 ;
364 }
365 }
366
367#endif /* of #ifdef USE_TCP_EXTENTIONS */
368
369#endif /* of #ifdef USE_TCP_DISCARD_SRV */
Note: See TracBrowser for help on using the repository browser.