source: EcnlProtoTool/trunk/asp3_dcre/tinet/netinet/tcp_subr_ncs.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: 23.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: tcp_subr_ncs.c 270 2017-02-09 04:03:47Z 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/ppp_ipcp.h>
110#include <net/net.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 <netinet6/in6.h>
118#include <netinet6/in6_var.h>
119#include <netinet/in_var.h>
120#include <netinet/ip.h>
121#include <netinet/ip_var.h>
122#include <netinet/ip6.h>
123#include <netinet6/ip6_var.h>
124#include <netinet6/nd6.h>
125#include <netinet/tcp.h>
126#include <netinet/tcp_timer.h>
127#include <netinet/tcp_var.h>
128#include <netinet/tcp_fsm.h>
129#include <netinet/tcp_seq.h>
130#include <netinet/in_itron.h>
131
132#ifdef SUPPORT_TCP
133
134#ifndef TCP_CFG_SWBUF_CSAVE_ONLY
135
136/*
137 * TCP 通信端点の送信ウィンドバッファの省コピー機能が無効
138 */
139
140/*
141 * tcp_read_swbuf -- 送信ウィンドバッファからデータを読み出す。
142 */
143
144void
145tcp_read_swbuf_ncs (T_TCP_CEP *cep, T_NET_BUF *output, uint_t len, uint_t doff)
146{
147 uint8_t *wptr, *rptr;
148
149 /* SDU の大きさをチェックする。*/
150 if (GET_IP_SDU_SIZE(GET_IP_HDR(output)) < GET_TCP_HDR_SIZE2(output, IF_IP_TCP_HDR_OFFSET) + len) {
151 syslog(LOG_INFO, "[TCP] shrink SUD len: %d -> %d",
152 (uint16_t)len, (uint16_t)(GET_IP_SDU_SIZE(GET_IP_HDR(output)) - GET_TCP_HDR_SIZE2(output, IF_IP_TCP_HDR_OFFSET)));
153 len = GET_IP_SDU_SIZE(GET_IP_HDR(output)) - GET_TCP_HDR_SIZE2(output, IF_IP_TCP_HDR_OFFSET);
154 }
155
156 wptr = GET_TCP_SDU(output, IF_IP_TCP_HDR_OFFSET);
157
158 /* 通信端点をロックする。*/
159 syscall(wai_sem(cep->semid_lock));
160
161 rptr = cep->sbuf_rptr + doff;
162 if (rptr - (uint8_t*)cep->sbuf > cep->sbufsz) {
163
164 /* 転送開始が送信ウィンドバッファの終わりを超
165えるときの処理　*/
166 rptr = (uint8_t*)cep->sbuf_rptr - (cep->sbufsz - doff);
167 }
168 else if (len + (rptr - (uint8_t*)cep->sbuf) > cep->sbufsz) {
169 uint_t sub;
170
171 /* 転送範囲がラウンドするときの処理 */
172 sub = (uint_t)(cep->sbufsz - (rptr - (uint8_t*)cep->sbuf));
173 memcpy((void*)wptr, rptr, (size_t)sub);
174 len -= sub;
175 wptr += sub;
176 rptr = (uint8_t*)cep->sbuf;
177 }
178 memcpy((void*)wptr, rptr, (size_t)len);
179
180 NET_COUNT_TCP(net_count_tcp[NC_TCP_SEND_DATA_SEGS], 1);
181 NET_COUNT_TCP(net_count_tcp[NC_TCP_SEND_DATA_OCTETS], len);
182
183 /* 通信端点のロックを解除する。*/
184 syscall(sig_sem(cep->semid_lock));
185 }
186
187/*
188 * tcp_drop_swbuf -- 送信ウィンドバッファから指定されたオクテット分削除する。
189 */
190
191void
192tcp_drop_swbuf_ncs (T_TCP_CEP *cep, uint_t len)
193{
194 uint_t last;
195
196 /* 通信端点をロックする。*/
197 syscall(wai_sem(cep->semid_lock));
198
199 last = cep->swbuf_count;
200
201 if (cep->sbuf_rptr + len > (uint8_t*)cep->sbuf + cep->sbufsz)
202 /* ラウンドするときの計算 */
203 cep->sbuf_rptr -= cep->sbufsz - len;
204 else
205 cep->sbuf_rptr += len;
206 cep->swbuf_count -= (uint16_t)len;
207
208 /* 通信端点のロックを解除する。*/
209 syscall(sig_sem(cep->semid_lock));
210
211#ifdef TCP_CFG_NON_BLOCKING
212
213 if (cep->snd_nblk_tfn == TFN_TCP_GET_BUF) { /* ノンブロッキングコール */
214
215 /* 通信端点をロックする。*/
216 syscall(wai_sem(cep->semid_lock));
217
218 /* 送信データ長を計算する。*/
219 if (cep->sbufsz - cep->swbuf_count > cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf))
220 /* 書込みポインタがラウンドするときは、書込みポインタから送信ウィンドバッファの終わりまで */
221 len = (uint_t)(cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf));
222 else
223 len = cep->sbufsz - cep->swbuf_count;
224
225 /* 通信端点のロックを解除する。*/
226 syscall(sig_sem(cep->semid_lock));
227
228 if (len > 0) {
229
230 /* tcp_get_buf の割当て長を設定する。*/
231 cep->get_buf_len = len;
232
233 /* 送信ウィンドバッファのアドレスを返す。*/
234 *cep->snd_p_buf = cep->sbuf_wptr;
235
236 if (IS_PTR_DEFINED(cep->callback))
237#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
238
239 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)(uint32_t)len);
240
241#else /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
242
243 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)&len);
244
245#endif /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
246
247 else
248 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
249
250 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
251 cep->snd_tskid = TA_NULL;
252 cep->snd_tfn = cep->snd_nblk_tfn = TFN_TCP_UNDEF;
253 }
254 }
255
256#ifdef TCP_CFG_EXTENTIONS
257
258 else if (cep->snd_nblk_tfn == TFN_TCP_SND_DAT ||
259 cep->snd_nblk_tfn == TFN_TCP_SND_OOB) { /* ノンブロッキングコール */
260
261#else /* of #ifdef TCP_CFG_EXTENTIONS */
262
263 else if (cep->snd_nblk_tfn == TFN_TCP_SND_DAT) { /* ノンブロッキングコール */
264
265#endif /* of #ifdef TCP_CFG_EXTENTIONS */
266
267 ER_UINT error;
268
269 /* 送信ウィンドバッファにデータを書き込む。*/
270 error = TCP_WRITE_SWBUF(cep, cep->snd_data, (uint_t)cep->snd_len);
271
272#ifdef TCP_CFG_EXTENTIONS
273
274 /* 送信緊急ポインタを設定する。*/
275 if (cep->snd_nblk_tfn == TFN_TCP_SND_OOB)
276 cep->snd_up = cep->snd_una + error;
277
278#endif /* of #ifdef TCP_CFG_EXTENTIONS */
279
280 if (IS_PTR_DEFINED(cep->callback))
281
282#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
283
284 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)error);
285
286#else /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
287
288 (*cep->callback)(GET_TCP_CEPID(cep), cep->snd_nblk_tfn, (void*)&error);
289
290#endif /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
291
292 else
293 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
294
295 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
296 cep->snd_tskid = TA_NULL;
297 cep->snd_tfn = cep->snd_nblk_tfn = TFN_TCP_UNDEF;
298 }
299 else {
300
301#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
302
303 /* 送信ウィンドバッファに空きが出来たら出力タスクを起床する。*/
304 if (last == cep->sbufsz && cep->swbuf_count < cep->sbufsz)
305 syscall(set_flg(cep->snd_flgid, TCP_CEP_EVT_SWBUF_READY));
306
307#ifdef TCP_CFG_NON_BLOCKING
308
309 }
310
311#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
312
313 if (cep->swbuf_count > 0) {
314 /* 送信ウィンドバッファにデータがあれば出力をポストする。*/
315 cep->flags |= TCP_CEP_FLG_POST_OUTPUT;
316 sig_sem(SEM_TCP_POST_OUTPUT);
317 }
318 }
319
320/*
321 * tcp_write_swbuf -- 送信ウィンドバッファにデータを書き込む。
322 */
323
324ER_UINT
325tcp_write_swbuf_ncs (T_TCP_CEP *cep, void *data, uint_t len)
326{
327 uint_t offset;
328
329 /* 通信端点をロックする。*/
330 syscall(wai_sem(cep->semid_lock));
331
332 /* len と送信ウィンドバッファの空きの小さい方を移すデータ数にする。*/
333 if (len > (cep->sbufsz - cep->swbuf_count))
334 len = cep->sbufsz - cep->swbuf_count;
335
336 /* 書き込みポインタがラウンドするときの処理 */
337 if (len > cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf)) {
338 offset = (uint_t)(cep->sbufsz - (cep->sbuf_wptr -(uint8_t*)cep->sbuf));
339 memcpy(cep->sbuf_wptr, data, (size_t)offset);
340 cep->sbuf_wptr = (uint8_t*)cep->sbuf;
341 cep->swbuf_count += offset;
342 }
343 else
344 offset = 0;
345
346 memcpy(cep->sbuf_wptr, (void*)((uint8_t*)data + offset), (size_t)(len - offset));
347 cep->sbuf_wptr += len - offset;
348 cep->swbuf_count += len - offset;
349
350 /* 通信端点のロックを解除する。*/
351 syscall(sig_sem(cep->semid_lock));
352
353 return (ER_UINT)len;
354 }
355
356/*
357 * tcp_wait_swbuf -- 送信ウィンドバッファが空くのを待
358つ。
359 */
360
361ER
362tcp_wait_swbuf_ncs (T_TCP_CEP *cep, TMO tmout)
363{
364 ER error;
365 FLGPTN flag;
366
367 while (cep->swbuf_count >= cep->sbufsz) {
368 /*
369 * 送信ウィンドバッファの空きがなければ、出力をポストして、
370 * 送信ウィンドバッファが空くまで待
371つ。
372 */
373 cep->flags |= TCP_CEP_FLG_POST_OUTPUT;
374 sig_sem(SEM_TCP_POST_OUTPUT);
375
376 if ((error = twai_flg(cep->snd_flgid, TCP_CEP_EVT_SWBUF_READY, TWF_ORW, &flag, tmout)) != E_OK) {
377 return error;
378 }
379 syscall(clr_flg(cep->snd_flgid, (FLGPTN)(~TCP_CEP_EVT_SWBUF_READY)));
380
381 /*
382 * 送信できるか、CEP の FSM 状æ…
383‹ã‚’見る。
384 * 送信ウィンドバッファが空くまで待
385つ間に、送信不能になった場合は、
386 * コネクションが切断されたことを意味している。
387 */
388 if (!TCP_FSM_CAN_SEND_MORE(cep->fsm_state)) {
389 return E_CLS;
390 }
391 }
392
393 return E_OK;
394 }
395/*
396 * tcp_get_swbuf_addr -- 送信ウィンドバッファの空きアドレスを獲得する。
397 */
398
399ER_UINT
400tcp_get_swbuf_addr_ncs (T_TCP_CEP *cep, void **p_buf)
401{
402 uint_t len;
403
404 /* 通信端点をロックする。*/
405 syscall(wai_sem(cep->semid_lock));
406
407 /* 送信ウィンドバッファの空きアドレスのå…
408ˆé ­ã‚’設定する。*/
409 *p_buf = cep->sbuf_wptr;
410
411 /* 送信ウィンドバッファの空きサイズを計算する。*/
412 if (cep->sbufsz - cep->swbuf_count > cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf))
413 /* 書込みポインタがラウンドするときは、書込みポインタから送信ウィンドバッファの終わりまで */
414 len = (uint_t)(cep->sbufsz - (cep->sbuf_wptr - (uint8_t*)cep->sbuf));
415 else
416 len = cep->sbufsz - cep->swbuf_count;
417
418 /* 通信端点のロックを解除する。*/
419 syscall(sig_sem(cep->semid_lock));
420
421 /* 送信ウィンドバッファの空きデータ長を設定し、その値を返す。*/
422 cep->get_buf_len = len;
423 return (ER_UINT)len;
424 }
425
426/*
427 * tcp_send_swbuf -- 送信ウィンドバッファのデータを送信可能にする。
428 */
429
430void
431tcp_send_swbuf_ncs (T_TCP_CEP *cep, uint_t len)
432{
433 /* 通信端点をロックする。*/
434 syscall(wai_sem(cep->semid_lock));
435
436 cep->sbuf_wptr += len;
437 cep->swbuf_count += len;
438
439 /* 書込みポインタがラウンドするときの処理 */
440 if (cep->sbuf_wptr >= (uint8_t*)cep->sbuf + cep->sbufsz)
441 cep->sbuf_wptr = (uint8_t*)cep->sbuf;
442
443 /* tcp_get_buf の割当て長をリセットする。*/
444 cep->get_buf_len = 0;
445
446 /* 通信端点のロックを解除する。*/
447 syscall(sig_sem(cep->semid_lock));
448
449 /* 送信ウィンドバッファがフルのときは強制的に送信する。*/
450 if (cep->swbuf_count >= cep->sbufsz)
451 cep->flags |= TCP_CEP_FLG_FORCE | TCP_CEP_FLG_FORCE_CLEAR;
452 }
453
454/*
455 * tcp_is_swbuf_full -- 送信ウィンドバッファが満杯かチェックする。
456 */
457
458bool_t
459tcp_is_swbuf_full_ncs (T_TCP_CEP *cep)
460{
461 return cep->swbuf_count >= cep->sbufsz;
462 }
463
464#endif /* of #ifndef TCP_CFG_SWBUF_CSAVE_ONLY */
465
466#ifndef TCP_CFG_RWBUF_CSAVE_ONLY
467
468/*
469 * TCP 通信端点の受信ウィンドバッファの省コピー機能が無効
470 */
471
472/*
473 * tcp_drop_rwbuf -- 受信ウィンドバッファから指定されたオクテット分削除する。
474 */
475
476void
477tcp_drop_rwbuf_ncs (T_TCP_CEP *cep, uint_t len)
478{
479 cep->rwbuf_count -= len;
480 cep->rbuf_rptr += len;
481
482 /* 読み出しポインタがラウンドするときの処理 */
483 if (cep->rbuf_rptr >= (uint8_t*)cep->rbuf + cep->rbufsz)
484 cep->rbuf_rptr = (uint8_t*)cep->rbuf;
485 }
486
487/*
488 * tcp_read_rwbuf -- 受信ウィンドバッファから指定されたオクテット分読み出す。
489 */
490
491uint_t
492tcp_read_rwbuf_ncs (T_TCP_CEP *cep, void *data, uint_t len)
493{
494 uint_t offset;
495
496 /* 通信端点をロックする。*/
497 syscall(wai_sem(cep->semid_lock));
498
499 /* len と受信ウィンドバッファのデータ数の小さい方を取り出すデータ数にする。*/
500 if (len > cep->rwbuf_count)
501 len = cep->rwbuf_count;
502
503 /* 読み出しポインタがラウンドするときの処理 */
504 if (len > cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf)) {
505 offset = (uint_t)(cep->rbufsz - (cep->rbuf_rptr -(uint8_t*)cep->rbuf));
506 memcpy(data, cep->rbuf_rptr, (size_t)offset);
507 cep->rwbuf_count -= offset;
508 cep->rbuf_rptr = (uint8_t*)cep->rbuf;
509 }
510 else
511 offset = 0;
512
513 memcpy((void*)((uint8_t*)data + offset), cep->rbuf_rptr, (size_t)(len - offset));
514 cep->rwbuf_count -= len - offset;
515 cep->rbuf_rptr += len - offset;
516
517 /* 通信端点のロックを解除する。*/
518 syscall(sig_sem(cep->semid_lock));
519
520 return len;
521 }
522
523/*
524 * tcp_get_rwbuf_addr -- 受信ウィンドバッファの空きアドレスを獲得する。
525 */
526
527uint_t
528tcp_get_rwbuf_addr_ncs (T_TCP_CEP *cep, void **p_buf)
529{
530 uint_t len;
531
532 /* 通信端点をロックする。*/
533 syscall(wai_sem(cep->semid_lock));
534
535 /* 受信ウィンドバッファのデータ長を計算する。*/
536 if (cep->rwbuf_count > cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf))
537 /* ポインタがラウンドするときは受信ウィンドバッファの終わりまで */
538 len = (uint_t)(cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf));
539 else
540 len = cep->rwbuf_count;
541
542 /* 受信ウィンドバッファのデータのアドレスのå…
543ˆé ­ã‚’設定する。*/
544 *p_buf = cep->rbuf_rptr;
545
546 /* 通信端点のロックを解除する。*/
547 syscall(sig_sem(cep->semid_lock));
548
549 /* 受信ウィンドバッファのデータ長を設定し、その値を返す。*/
550 cep->rcv_buf_len = len;
551 return len;
552 }
553
554/*
555 * tcp_write_rwbuf -- 受信ウィンドバッファにデータを書き込む。
556 *
557 * 注意:
558 * å…
559¥åŠ› input は、T_TCP_Q_HDR によりリンクされ、
560 * 並べ替えが終了していなければならない。また、
561 * 追加するデータは、受信ウィンドバッファに収まること。
562 */
563
564void
565tcp_write_rwbuf_ncs (T_TCP_CEP *cep, T_NET_BUF *input, uint_t thoff)
566{
567 T_TCP_Q_HDR *qhdr;
568 uint_t offset, inlen, last;
569
570 /* 通信端点をロックする。*/
571 syscall(wai_sem(cep->semid_lock));
572
573 qhdr = (T_TCP_Q_HDR*)GET_TCP_HDR(input, thoff);
574
575 /* 受信済みシーケンス番号を更新する。*/
576 cep->rcv_nxt += qhdr->slen;
577
578 last = cep->rwbuf_count;
579 inlen = qhdr->slen;
580
581 /* 緊急データの SDU 補正を行う。*/
582 if (qhdr->urp > 0 && inlen > 0) {
583 inlen -= qhdr->urp;
584 qhdr->slen -= qhdr->urp;
585 qhdr->urp = 0;
586 }
587
588 /*
589 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
590 * これは、アプリケーションに、相手からこれ以上データが送られて
591 * こないことを知らせるためである。
592 */
593 if (inlen > 0) {
594
595 /* 書き込みポインタがラウンドするときの処理 */
596 if (inlen > cep->rbufsz - (cep->rbuf_wptr - (uint8_t*)cep->rbuf)) {
597 offset = (uint_t)(cep->rbufsz - (cep->rbuf_wptr - (uint8_t*)cep->rbuf));
598 memcpy(cep->rbuf_wptr, (void*)(GET_TCP_SDU(input, thoff) + qhdr->soff), (size_t)offset);
599 cep->rbuf_wptr = (uint8_t*)cep->rbuf;
600 cep->rwbuf_count += offset;
601 inlen -= offset;
602 }
603 else
604 offset = 0;
605
606 memcpy(cep->rbuf_wptr, (void*)(GET_TCP_SDU(input, thoff) + qhdr->soff + offset), (size_t)inlen);
607 cep->rbuf_wptr += inlen;
608 cep->rwbuf_count += inlen;
609
610 NET_COUNT_TCP(net_count_tcp[NC_TCP_RECV_DATA_SEGS], 1);
611 NET_COUNT_TCP(net_count_tcp[NC_TCP_RECV_DATA_OCTETS], inlen);
612 }
613
614 syscall(rel_net_buf(input));
615
616#ifdef TCP_CFG_NON_BLOCKING
617
618 if (cep->rcv_nblk_tfn == TFN_TCP_RCV_BUF) { /* ノンブロッキングコール */
619
620 int_t len;
621
622 /* 受信ウィンドバッファの空きデータ長を計算する。*/
623 if (cep->rwbuf_count > cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf)) {
624 /* ポインタがラウンドするときは受信ウィンドバッファの終わりまで */
625 len = (uint_t)(cep->rbufsz - (cep->rbuf_rptr - (uint8_t*)cep->rbuf));
626 }
627 else
628 len = cep->rwbuf_count;
629
630 /* 通信端点のロックを解除する。*/
631 syscall(sig_sem(cep->semid_lock));
632
633 /*
634 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
635 * これは、アプリケーションに、相手からこれ以上データが送られて
636 * こないことを知らせるためである。
637 */
638 if (len > 0 || inlen == 0) {
639
640 /* tcp_rcv_buf の割当て長を設定する。*/
641 cep->rcv_buf_len = len;
642
643 /* 受信ウィンドバッファのアドレスを返す。*/
644 *cep->rcv_p_buf = cep->rbuf_rptr;
645
646
647 if (IS_PTR_DEFINED(cep->callback))
648
649#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
650
651 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)(uint32_t)len);
652
653#else /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
654
655 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)&len);
656
657#endif /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
658
659 else
660 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
661
662 if (len == 0) {
663
664 /*
665 * 通信端点をロックして、
666 * 受信ウィンドバッファキューのネットワークバッファを解放する。
667 */
668 syscall(wai_sem(cep->semid_lock));
669 TCP_FREE_RWBUFQ(cep);
670 syscall(sig_sem(cep->semid_lock));
671 }
672 }
673
674 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
675 cep->rcv_tskid = TA_NULL;
676 cep->rcv_tfn = cep->rcv_nblk_tfn = TFN_TCP_UNDEF;
677 }
678
679 else if (cep->rcv_nblk_tfn == TFN_TCP_RCV_DAT) { /* ノンブロッキングコール */
680 ER_UINT len;
681
682 /* 通信端点のロックを解除する。*/
683 syscall(sig_sem(cep->semid_lock));
684
685 /* 受信ウィンドバッファからデータを取り出す。*/
686 if ((len = TCP_READ_RWBUF(cep, cep->rcv_data, (uint_t)cep->rcv_len)) > 0) {
687 /* 相手にウィンドウサイズが変わったことを知らせるため出力をポストする。*/
688 cep->flags |= TCP_CEP_FLG_POST_OUTPUT;
689 sig_sem(SEM_TCP_POST_OUTPUT);
690 }
691
692 /*
693 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
694 * これは、アプリケーションに、相手からこれ以上データが送られて
695 * こないことを知らせるためである。
696 */
697 if (len > 0 || inlen == 0) {
698
699 if (IS_PTR_DEFINED(cep->callback))
700
701#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
702
703 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)(uint32_t)len);
704
705#else /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
706
707 (*cep->callback)(GET_TCP_CEPID(cep), cep->rcv_nblk_tfn, (void*)&len);
708
709#endif /* of #ifdef TCP_CFG_NON_BLOCKING_COMPAT14 */
710
711 else
712 syslog(LOG_WARNING, "[TCP] no call back, CEP: %d.", GET_TCP_CEPID(cep));
713 }
714
715 /* 記憶されているタスク ID と API 機能コードをクリアーする。*/
716 cep->rcv_tskid = TA_NULL;
717 cep->rcv_tfn = cep->rcv_nblk_tfn = TFN_TCP_UNDEF;
718
719 }
720 else {
721
722#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
723
724 /* 通信端点のロックを解除する。*/
725 syscall(sig_sem(cep->semid_lock));
726
727 if (inlen == 0 && cep->rwbuf_count == 0) {
728 /*
729 * 受信ウィンドバッファ内
730のデータ数が 0 で、
731 * 相手から FIN フラグが付いたセグメントを受信したときは、
732 * 通信端点をロックして、
733 * 受信ウィンドバッファキューのネットワークバッファを解放する。
734 */
735 syscall(wai_sem(cep->semid_lock));
736 TCP_FREE_RWBUFQ(cep);
737 syscall(sig_sem(cep->semid_lock));
738 }
739
740 /*
741 * 受信ウィンドバッファにデータがå…
742¥ã‚‹ã‹ã€ inlen == 0 の時、å…
743¥åŠ›ã‚¿ã‚¹ã‚¯ã‚’起床する。
744 * FIN フラグが付いたセグメントは inlen == 0 になることもある。
745 * これは、アプリケーションに、相手からこれ以上データが送られて
746 * こないことを知らせるためである。
747 */
748 if ((last == 0 && cep->rwbuf_count > 0) || inlen == 0)
749 syscall(set_flg(cep->rcv_flgid, TCP_CEP_EVT_RWBUF_READY));
750
751#ifdef TCP_CFG_NON_BLOCKING
752
753 }
754
755#endif /* of #ifdef TCP_CFG_NON_BLOCKING */
756
757 }
758
759#endif /* of #ifndef TCP_CFG_RWBUF_CSAVE_ONLY */
760
761#endif /* of #ifdef SUPPORT_TCP */
Note: See TracBrowser for help on using the repository browser.