source: azure_iot_hub/trunk/asp3_dcre/tinet/netinet/tcp_subr_ncs.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: 23.0 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_subr_ncs.c 388 2019-05-22 11:25:18Z coas-nagasima $
44 */
45
46/*
47 * Copyright (c) 1982, 1986, 1988, 1990, 1993, 1995
48 * The Regents of the University of California. All rights reserved.
49 *
50 * Redistribution and use in source and binary forms, with or without
51 * modification, are permitted provided that the following conditions
52 * are met:
53 * 1. Redistributions of source code must retain the above copyright
54 * notice, this list of conditions and the following disclaimer.
55 * 2. Redistributions in binary form must reproduce the above copyright
56 * notice, this list of conditions and the following disclaimer in the
57 * documentation and/or other materials provided with the distribution.
58 * 3. All advertising materials mentioning features or use of this software
59 * must display the following acknowledgement:
60 * This product includes software developed by the University of
61 * California, Berkeley and its contributors.
62 * 4. Neither the name of the University nor the names of its contributors
63 * may be used to endorse or promote products derived from this software
64 * without specific prior written permission.
65 *
66 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
67 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
68 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
69 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
70 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
71 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
72 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
73 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
74 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
75 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
76 * SUCH DAMAGE.
77 *
78 * @(#)tcp_subr.c 8.2 (Berkeley) 5/24/95
79 * $FreeBSD: src/sys/netinet/tcp_subr.c,v 1.49.2.4 1999/08/29 16:29:55 peter Exp $
80 */
81
82#include <string.h>
83
84#ifdef TARGET_KERNEL_ASP
85
86#include <kernel.h>
87#include <sil.h>
88#include <t_syslog.h>
89#include "kernel_cfg.h"
90
91#endif /* of #ifdef TARGET_KERNEL_ASP */
92
93#ifdef TARGET_KERNEL_JSP
94
95#include <s_services.h>
96#include <t_services.h>
97#include "kernel_id.h"
98
99#endif /* of #ifdef TARGET_KERNEL_JSP */
100
101#include <tinet_defs.h>
102#include <tinet_config.h>
103
104#include <net/if.h>
105#include <net/if_ppp.h>
106#include <net/if_loop.h>
107#include <net/ethernet.h>
108#include <net/if_arp.h>
109#include <net/net.h>
110#include <net/net_endian.h>
111#include <net/net_var.h>
112#include <net/net_buf.h>
113#include <net/net_timer.h>
114#include <net/net_count.h>
115
116#include <netinet/in.h>
117#include <netinet/in_var.h>
118#include <netinet/in_itron.h>
119#include <netinet/ip.h>
120#include <netinet/ip_var.h>
121#include <netinet/tcp.h>
122#include <netinet/tcp_var.h>
123#include <netinet/tcp_fsm.h>
124#include <netinet/tcp_seq.h>
125#include <netinet/tcp_timer.h>
126
127#ifdef SUPPORT_TCP
128
129#ifndef TCP_CFG_SWBUF_CSAVE_ONLY
130
131/*
132 * TCP 通信端点の送信ウィンドバッファの省コピー機能が無効
133 */
134
135/*
136 * tcp_read_swbuf -- 送信ウィンドバッファからデータを読み出す。
137 */
138
139void
140tcp_read_swbuf_ncs (T_TCP_CEP *cep, T_NET_BUF *output, uint_t len, uint_t doff)
141{
142 uint8_t *wptr, *rptr;
143 uint_t sdu_size = GET_IP_SDU_SIZE(output);
144 uint_t hdr_offset = IF_IP_TCP_HDR_OFFSET(output);
145
146 /* SDU の大きさをチェックする。*/
147 if (sdu_size < GET_TCP_HDR_SIZE(output, hdr_offset) + len) {
148 syslog(LOG_INFO, "[TCP] shrink SUD len: %d -> %d",
149 (uint16_t)len, (uint16_t)(sdu_size - GET_TCP_HDR_SIZE(output, hdr_offset)));
150 len = sdu_size - GET_TCP_HDR_SIZE(output, hdr_offset);
151 }
152
153 wptr = GET_TCP_SDU(output, hdr_offset);
154
155 /* 通信端点をロックする。*/
156 syscall(wai_sem(cep->semid_lock));
157
158 rptr = cep->sbuf_rptr + doff;
159 if (rptr - (uint8_t*)cep->sbuf > cep->sbufsz) {
160
161 /* 転送開始が送信ウィンドバッファの終わりを超
162えるときの処理　*/
163 rptr = (uint8_t*)cep->sbuf_rptr - (cep->sbufsz - doff);
164 }
165 else if (len + (rptr - (uint8_t*)cep->sbuf) > cep->sbufsz) {
166 uint_t sub;
167
168 /* 転送範囲がラウンドするときの処理 */
169 sub = (uint_t)(cep->sbufsz - (rptr - (uint8_t*)cep->sbuf));
170 memcpy((void*)wptr, rptr, (size_t)sub);
171 len -= sub;
172 wptr += sub;
173 rptr = (uint8_t*)cep->sbuf;
174 }
175 memcpy((void*)wptr, rptr, (size_t)len);
176
177 NET_COUNT_TCP(net_count_tcp[NC_TCP_SEND_DATA_SEGS], 1);
178 NET_COUNT_TCP(net_count_tcp[NC_TCP_SEND_DATA_OCTETS], len);
179
180 /* 通信端点のロックを解除する。*/
181 syscall(sig_sem(cep->semid_lock));
182 }
183
184/*
185 * tcp_drop_swbuf -- 送信ウィンドバッファから指定されたオクテット分削除する。
186 */
187
188void
189tcp_drop_swbuf_ncs (T_TCP_CEP *cep, uint_t len)
190{
191 uint_t last;
192
193 /* 通信端点をロックする。*/
194 syscall(wai_sem(cep->semid_lock));
195
196 last = cep->swbuf_count;
197
198 if (cep->sbuf_rptr + len > (uint8_t*)cep->sbuf + cep->sbufsz)
199 /* ラウンドするときの計算 */
200 cep->sbuf_rptr -= cep->sbufsz - len;
201 else
202 cep->sbuf_rptr += len;
203 cep->swbuf_count -= (uint16_t)len;
204
205 /* 通信端点のロックを解除する。*/
206 syscall(sig_sem(cep->semid_lock));
207
208#ifdef TCP_CFG_NON_BLOCKING
209
210 if (cep->snd_nblk_tfn == TFN_TCP_GET_BUF) { /* ノンブロッキングコール */
211
212 /* 通信端点をロックする。*/
213 syscall(wai_sem(cep->semid_lock));
214
215 /* 送信データ長を計算する。*/
216 if (cep->sbufsz - cep->swbuf_count > cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf))
217 /* 書込みポインタがラウンドするときは、書込みポインタから送信ウィンドバッファの終わりまで */
218 len = (uint_t)(cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf));
219 else
220 len = cep->sbufsz - cep->swbuf_count;
221
222 /* 通信端点のロックを解除する。*/
223 syscall(sig_sem(cep->semid_lock));
224
225 if (len > 0) {
226
227 /* tcp_get_buf の割当て長を設定する。*/
228 cep->get_buf_len = len;
229
230 /* 送信ウィンドバッファのアドレスを返す。*/
231 *cep->snd_p_buf = cep->sbuf_wptr;
232
233 if (IS_PTR_DEFINED(cep->callback))
234
235#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
236 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)(uint32_t)len);
237#else
238 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)&len);
239#endif
240 else
241 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
242
243 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
244 cep->snd_tskid = TA_NULL;
245 cep->snd_tfn = cep->snd_nblk_tfn = TFN_TCP_UNDEF;
246 }
247 }
248
249#ifdef TCP_CFG_EXTENTIONS
250
251 else if (cep->snd_nblk_tfn == TFN_TCP_SND_DAT ||
252 cep->snd_nblk_tfn == TFN_TCP_SND_OOB) { /* ノンブロッキングコール */
253
254#else /* of #ifdef TCP_CFG_EXTENTIONS */
255
256 else if (cep->snd_nblk_tfn == TFN_TCP_SND_DAT) { /* ノンブロッキングコール */
257
258#endif /* of #ifdef TCP_CFG_EXTENTIONS */
259
260 ER_UINT error;
261
262 /* 送信ウィンドバッファにデータを書き込む。*/
263 error = TCP_WRITE_SWBUF(cep, cep->snd_data, (uint_t)cep->snd_len);
264
265#ifdef TCP_CFG_EXTENTIONS
266
267 /* 送信緊急ポインタを設定する。*/
268 if (cep->snd_nblk_tfn == TFN_TCP_SND_OOB)
269 cep->snd_up = cep->snd_una + error;
270
271#endif /* of #ifdef TCP_CFG_EXTENTIONS */
272
273 if (IS_PTR_DEFINED(cep->callback))
274
275#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
276 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)error);
277#else
278 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)&error);
279#endif
280 else
281 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
282
283 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
284 cep->snd_tskid = TA_NULL;
285 cep->snd_tfn = cep->snd_nblk_tfn = TFN_TCP_UNDEF;
286 }
287 else {
288
289#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
290
291 /* 送信ウィンドバッファに空きが出来たら出力タスクを起床する。*/
292 if (last == cep->sbufsz && cep->swbuf_count < cep->sbufsz)
293 syscall(set_flg(cep->snd_flgid, TCP_CEP_EVT_SWBUF_READY));
294
295#ifdef TCP_CFG_NON_BLOCKING
296
297 }
298
299#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
300
301 if (cep->swbuf_count > 0) {
302 /* 送信ウィンドバッファにデータがあれば出力をポストする。*/
303 cep->flags |= TCP_CEP_FLG_POST_OUTPUT;
304 sig_sem(SEM_TCP_POST_OUTPUT);
305 }
306 }
307
308/*
309 * tcp_write_swbuf -- 送信ウィンドバッファにデータを書き込む。
310 */
311
312ER_UINT
313tcp_write_swbuf_ncs (T_TCP_CEP *cep, void *data, uint_t len)
314{
315 uint_t offset;
316
317 /* 通信端点をロックする。*/
318 syscall(wai_sem(cep->semid_lock));
319
320 /* len と送信ウィンドバッファの空きの小さい方を移すデータ数にする。*/
321 if (len > (cep->sbufsz - cep->swbuf_count))
322 len = cep->sbufsz - cep->swbuf_count;
323
324 /* 書き込みポインタがラウンドするときの処理 */
325 if (len > cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf)) {
326 offset = (uint_t)(cep->sbufsz - (cep->sbuf_wptr -(uint8_t*)cep->sbuf));
327 memcpy(cep->sbuf_wptr, data, (size_t)offset);
328 cep->sbuf_wptr = (uint8_t*)cep->sbuf;
329 cep->swbuf_count += offset;
330 }
331 else
332 offset = 0;
333
334 memcpy(cep->sbuf_wptr, (void*)((uint8_t*)data + offset), (size_t)(len - offset));
335 cep->sbuf_wptr += len - offset;
336 cep->swbuf_count += len - offset;
337
338 /* 通信端点のロックを解除する。*/
339 syscall(sig_sem(cep->semid_lock));
340
341 return (ER_UINT)len;
342 }
343
344/*
345 * tcp_wait_swbuf -- 送信ウィンドバッファが空くのを待
346つ。
347 */
348
349ER
350tcp_wait_swbuf_ncs (T_TCP_CEP *cep, TMO tmout)
351{
352 ER error;
353 FLGPTN flag;
354
355 while (cep->swbuf_count >= cep->sbufsz) {
356 /*
357 * 送信ウィンドバッファの空きがなければ、出力をポストして、
358 * 送信ウィンドバッファが空くまで待
359つ。
360 */
361 cep->flags |= TCP_CEP_FLG_POST_OUTPUT;
362 sig_sem(SEM_TCP_POST_OUTPUT);
363
364 if ((error = twai_flg(cep->snd_flgid, TCP_CEP_EVT_SWBUF_READY, TWF_ORW, &flag, tmout)) != E_OK) {
365 return error;
366 }
367 syscall(clr_flg(cep->snd_flgid, (FLGPTN)(~TCP_CEP_EVT_SWBUF_READY)));
368
369 /*
370 * 送信できるか、CEP の FSM 状æ…
371‹ã‚’見る。
372 * 送信ウィンドバッファが空くまで待
373つ間に、送信不能になった場合は、
374 * コネクションが切断されたことを意味している。
375 */
376 if (!TCP_FSM_CAN_SEND_MORE(cep->fsm_state)) {
377 return E_CLS;
378 }
379 }
380
381 return E_OK;
382 }
383/*
384 * tcp_get_swbuf_addr -- 送信ウィンドバッファの空きアドレスを獲得する。
385 */
386
387ER_UINT
388tcp_get_swbuf_addr_ncs (T_TCP_CEP *cep, void **p_buf)
389{
390 uint_t len;
391
392 /* 通信端点をロックする。*/
393 syscall(wai_sem(cep->semid_lock));
394
395 /* 送信ウィンドバッファの空きアドレスのå…
396ˆé ­ã‚’設定する。*/
397 *p_buf = cep->sbuf_wptr;
398
399 /* 送信ウィンドバッファの空きサイズを計算する。*/
400 if (cep->sbufsz - cep->swbuf_count > cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf))
401 /* 書込みポインタがラウンドするときは、書込みポインタから送信ウィンドバッファの終わりまで */
402 len = (uint_t)(cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf));
403 else
404 len = cep->sbufsz - cep->swbuf_count;
405
406 /* 通信端点のロックを解除する。*/
407 syscall(sig_sem(cep->semid_lock));
408
409 /* 送信ウィンドバッファの空きデータ長を設定し、その値を返す。*/
410 cep->get_buf_len = len;
411 return (ER_UINT)len;
412 }
413
414/*
415 * tcp_send_swbuf -- 送信ウィンドバッファのデータを送信可能にする。
416 */
417
418void
419tcp_send_swbuf_ncs (T_TCP_CEP *cep, uint_t len)
420{
421 /* 通信端点をロックする。*/
422 syscall(wai_sem(cep->semid_lock));
423
424 cep->sbuf_wptr += len;
425 cep->swbuf_count += len;
426
427 /* 書込みポインタがラウンドするときの処理 */
428 if (cep->sbuf_wptr >= (uint8_t*)cep->sbuf + cep->sbufsz)
429 cep->sbuf_wptr = (uint8_t*)cep->sbuf;
430
431 /* tcp_get_buf の割当て長をリセットする。*/
432 cep->get_buf_len = 0;
433
434 /* 通信端点のロックを解除する。*/
435 syscall(sig_sem(cep->semid_lock));
436
437 /* 送信ウィンドバッファがフルのときは強制的に送信する。*/
438 if (cep->swbuf_count >= cep->sbufsz)
439 cep->flags |= TCP_CEP_FLG_FORCE | TCP_CEP_FLG_FORCE_CLEAR;
440 }
441
442/*
443 * tcp_is_swbuf_full -- 送信ウィンドバッファが満杯かチェックする。
444 */
445
446bool_t
447tcp_is_swbuf_full_ncs (T_TCP_CEP *cep)
448{
449 return cep->swbuf_count >= cep->sbufsz;
450 }
451
452#endif /* of #ifndef TCP_CFG_SWBUF_CSAVE_ONLY */
453
454#ifndef TCP_CFG_RWBUF_CSAVE_ONLY
455
456/*
457 * TCP 通信端点の受信ウィンドバッファの省コピー機能が無効
458 */
459
460/*
461 * tcp_drop_rwbuf -- 受信ウィンドバッファから指定されたオクテット分削除する。
462 */
463
464void
465tcp_drop_rwbuf_ncs (T_TCP_CEP *cep, uint_t len)
466{
467 cep->rwbuf_count -= len;
468 cep->rbuf_rptr += len;
469
470 /* 読み出しポインタがラウンドするときの処理 */
471 if (cep->rbuf_rptr >= (uint8_t*)cep->rbuf + cep->rbufsz)
472 cep->rbuf_rptr = (uint8_t*)cep->rbuf;
473 }
474
475/*
476 * tcp_read_rwbuf -- 受信ウィンドバッファから指定されたオクテット分読み出す。
477 */
478
479uint_t
480tcp_read_rwbuf_ncs (T_TCP_CEP *cep, void *data, uint_t len)
481{
482 uint_t offset;
483
484 /* 通信端点をロックする。*/
485 syscall(wai_sem(cep->semid_lock));
486
487 /* len と受信ウィンドバッファのデータ数の小さい方を取り出すデータ数にする。*/
488 if (len > cep->rwbuf_count)
489 len = cep->rwbuf_count;
490
491 /* 読み出しポインタがラウンドするときの処理 */
492 if (len > cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf)) {
493 offset = (uint_t)(cep->rbufsz - (cep->rbuf_rptr -(uint8_t*)cep->rbuf));
494 memcpy(data, cep->rbuf_rptr, (size_t)offset);
495 cep->rwbuf_count -= offset;
496 cep->rbuf_rptr = (uint8_t*)cep->rbuf;
497 }
498 else
499 offset = 0;
500
501 memcpy((void*)((uint8_t*)data + offset), cep->rbuf_rptr, (size_t)(len - offset));
502 cep->rwbuf_count -= len - offset;
503 cep->rbuf_rptr += len - offset;
504
505 /* 通信端点のロックを解除する。*/
506 syscall(sig_sem(cep->semid_lock));
507
508 return len;
509 }
510
511/*
512 * tcp_get_rwbuf_addr -- 受信ウィンドバッファの空きアドレスを獲得する。
513 */
514
515uint_t
516tcp_get_rwbuf_addr_ncs (T_TCP_CEP *cep, void **p_buf)
517{
518 uint_t len;
519
520 /* 通信端点をロックする。*/
521 syscall(wai_sem(cep->semid_lock));
522
523 /* 受信ウィンドバッファのデータ長を計算する。*/
524 if (cep->rwbuf_count > cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf))
525 /* ポインタがラウンドするときは受信ウィンドバッファの終わりまで */
526 len = (uint_t)(cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf));
527 else
528 len = cep->rwbuf_count;
529
530 /* 受信ウィンドバッファのデータのアドレスのå…
531ˆé ­ã‚’設定する。*/
532 *p_buf = cep->rbuf_rptr;
533
534 /* 通信端点のロックを解除する。*/
535 syscall(sig_sem(cep->semid_lock));
536
537 /* 受信ウィンドバッファのデータ長を設定し、その値を返す。*/
538 cep->rcv_buf_len = len;
539 return len;
540 }
541
542/*
543 * tcp_write_rwbuf -- 受信ウィンドバッファにデータを書き込む。
544 *
545 * 注意:
546 * å…
547¥åŠ› input は、T_TCP_Q_HDR によりリンクされ、
548 * 並べ替えが終了していなければならない。また、
549 * 追加するデータは、受信ウィンドバッファに収まること。
550 */
551
552void
553tcp_write_rwbuf_ncs (T_TCP_CEP *cep, T_NET_BUF *input, uint_t thoff)
554{
555 T_TCP_Q_HDR *qhdr;
556 uint_t offset, inlen, last;
557
558 /* 通信端点をロックする。*/
559 syscall(wai_sem(cep->semid_lock));
560
561 qhdr = (T_TCP_Q_HDR*)GET_TCP_HDR(input, thoff);
562
563 /* 受信済みシーケンス番号を更新する。*/
564 cep->rcv_nxt += qhdr->slen;
565
566 last = cep->rwbuf_count;
567 inlen = qhdr->slen;
568
569 /* 緊急データの SDU 補正を行う。*/
570 if (qhdr->urp > 0 && inlen > 0) {
571 inlen -= qhdr->urp;
572 qhdr->slen -= qhdr->urp;
573 qhdr->urp = 0;
574 }
575
576 /*
577 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
578 * これは、アプリケーションに、相手からこれ以上データが送られて
579 * こないことを知らせるためである。
580 */
581 if (inlen > 0) {
582
583 /* 書き込みポインタがラウンドするときの処理 */
584 if (inlen > cep->rbufsz - (cep->rbuf_wptr - (uint8_t*)cep->rbuf)) {
585 offset = (uint_t)(cep->rbufsz - (cep->rbuf_wptr - (uint8_t*)cep->rbuf));
586 memcpy(cep->rbuf_wptr, (void*)(GET_TCP_SDU(input, thoff) + qhdr->soff), (size_t)offset);
587 cep->rbuf_wptr = (uint8_t*)cep->rbuf;
588 cep->rwbuf_count += offset;
589 inlen -= offset;
590 }
591 else
592 offset = 0;
593
594 memcpy(cep->rbuf_wptr, (void*)(GET_TCP_SDU(input, thoff) + qhdr->soff + offset), (size_t)inlen);
595 cep->rbuf_wptr += inlen;
596 cep->rwbuf_count += inlen;
597
598 NET_COUNT_TCP(net_count_tcp[NC_TCP_RECV_DATA_SEGS], 1);
599 NET_COUNT_TCP(net_count_tcp[NC_TCP_RECV_DATA_OCTETS], inlen);
600 }
601
602 syscall(rel_net_buf(input));
603
604#ifdef TCP_CFG_NON_BLOCKING
605
606 if (cep->rcv_nblk_tfn == TFN_TCP_RCV_BUF) { /* ノンブロッキングコール */
607
608 int_t len;
609
610 /* 受信ウィンドバッファの空きデータ長を計算する。*/
611 if (cep->rwbuf_count > cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf)) {
612 /* ポインタがラウンドするときは受信ウィンドバッファの終わりまで */
613 len = (uint_t)(cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf));
614 }
615 else
616 len = cep->rwbuf_count;
617
618 /* 通信端点のロックを解除する。*/
619 syscall(sig_sem(cep->semid_lock));
620
621 /*
622 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
623 * これは、アプリケーションに、相手からこれ以上データが送られて
624 * こないことを知らせるためである。
625 */
626 if (len > 0 || inlen == 0) {
627
628 /* tcp_rcv_buf の割当て長を設定する。*/
629 cep->rcv_buf_len = len;
630
631 /* 受信ウィンドバッファのアドレスを返す。*/
632 *cep->rcv_p_buf = cep->rbuf_rptr;
633
634
635 if (IS_PTR_DEFINED(cep->callback))
636
637#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
638 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)(uint32_t)len);
639#else
640 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)&len);
641#endif
642 else
643 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
644
645 if (len == 0) {
646
647 /*
648 * 通信端点をロックして、
649 * 受信ウィンドバッファキューのネットワークバッファを解放する。
650 */
651 syscall(wai_sem(cep->semid_lock));
652 TCP_FREE_RWBUFQ(cep);
653 syscall(sig_sem(cep->semid_lock));
654 }
655 }
656
657 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
658 cep->rcv_tskid = TA_NULL;
659 cep->rcv_tfn = cep->rcv_nblk_tfn = TFN_TCP_UNDEF;
660 }
661
662 else if (cep->rcv_nblk_tfn == TFN_TCP_RCV_DAT) { /* ノンブロッキングコール */
663 ER_UINT len;
664
665 /* 通信端点のロックを解除する。*/
666 syscall(sig_sem(cep->semid_lock));
667
668 /* 受信ウィンドバッファからデータを取り出す。*/
669 if ((len = TCP_READ_RWBUF(cep, cep->rcv_data, (uint_t)cep->rcv_len)) > 0) {
670 /* 相手にウィンドウサイズが変わったことを知らせるため出力をポストする。*/
671 cep->flags |= TCP_CEP_FLG_POST_OUTPUT;
672 sig_sem(SEM_TCP_POST_OUTPUT);
673 }
674
675 /*
676 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
677 * これは、アプリケーションに、相手からこれ以上データが送られて
678 * こないことを知らせるためである。
679 */
680 if (len > 0 || inlen == 0) {
681
682 if (IS_PTR_DEFINED(cep->callback))
683
684#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
685 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)(uint32_t)len);
686#else
687 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)&len);
688#endif
689 else
690 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
691 }
692
693 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
694 cep->rcv_tskid = TA_NULL;
695 cep->rcv_tfn = cep->rcv_nblk_tfn = TFN_TCP_UNDEF;
696
697 }
698 else {
699
700#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
701
702 /* 通信端点のロックを解除する。*/
703 syscall(sig_sem(cep->semid_lock));
704
705 if (inlen == 0 && cep->rwbuf_count == 0) {
706 /*
707 * 受信ウィンドバッファ内
708のデータ数が 0 で、
709 * 相手から FIN フラグが付いたセグメントを受信したときは、
710 * 通信端点をロックして、
711 * 受信ウィンドバッファキューのネットワークバッファを解放する。
712 */
713 syscall(wai_sem(cep->semid_lock));
714 TCP_FREE_RWBUFQ(cep);
715 syscall(sig_sem(cep->semid_lock));
716 }
717
718 /*
719 * 受信ウィンドバッファにデータがå…
720¥ã‚‹ã‹ã€ inlen == 0 の時、å…
721¥åŠ›ã‚¿ã‚¹ã‚¯ã‚’起床する。
722 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
723 * これは、アプリケーションに、相手からこれ以上データが送られて
724 * こないことを知らせるためである。
725 */
726 if ((last == 0 && cep->rwbuf_count > 0) || inlen == 0)
727 syscall(set_flg(cep->rcv_flgid, TCP_CEP_EVT_RWBUF_READY));
728
729#ifdef TCP_CFG_NON_BLOCKING
730
731 }
732
733#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
734
735 }
736
737#endif /* of #ifndef TCP_CFG_RWBUF_CSAVE_ONLY */
738
739#endif /* of #ifdef SUPPORT_TCP */
Note: See TracBrowser for help on using the repository browser.