/* * TINET (TCP/IP Protocol Stack) * * Copyright (C) 2001-2009 by Dep. of Computer Science and Engineering * Tomakomai National College of Technology, JAPAN * * 上記著作権者は，以下の (1)～(4) の条件か，Free Software Foundation * によって公表されている GNU General Public License の Version 2 に記 * 述されている条件を満たす場合に限り，本ソフトウェア（本ソフトウェア * を改変したものを含む．以下同じ）を使用・複製・改変・再配布（以下， * 利用と呼ぶ）することを無償で許諾する． * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー * スコード中に含まれていること． * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使 * 用できる形で再配布する場合には，再配布に伴うドキュメント（利用 * 者マニュアルなど）に，上記の著作権表示，この利用条件および下記 * の無保証規定を掲載すること． * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使 * 用できない形で再配布する場合には，次の条件を満たすこと． * (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著 * 作権表示，この利用条件および下記の無保証規定を掲載すること． * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損 * 害からも，上記著作権者およびTOPPERSプロジェクトを免責すること． * * 本ソフトウェアは，無保証で提供されているものである．上記著作権者お * よびTOPPERSプロジェクトは，本ソフトウェアに関して，その適用可能性も * 含めて，いかなる保証も行わない．また，本ソフトウェアの利用により直 * 接的または間接的に生じたいかなる損害に関しても，その責任を負わない． * * @(#) $Id: tcp_timer.c 270 2017-02-09 04:03:47Z coas-nagasima $ */ /* * Copyright (c) 1982, 1986, 1988, 1990, 1993, 1995 * The Regents of the University of California. All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * 3. All advertising materials mentioning features or use of this software * must display the following acknowledgement: * This product includes software developed by the University of * California, Berkeley and its contributors. * 4. Neither the name of the University nor the names of its contributors * may be used to endorse or promote products derived from this software * without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * * @(#)tcp_timer.c 8.2 (Berkeley) 5/24/95 * $FreeBSD: src/sys/netinet/tcp_timer.c,v 1.28.2.1 1999/08/29 16:29:56 peter Exp $ */ #ifdef TARGET_KERNEL_ASP #include #include #include "kernel_cfg.h" #endif /* of #ifdef TARGET_KERNEL_ASP */ #ifdef TARGET_KERNEL_JSP #include #include #include "kernel_id.h" #endif /* of #ifdef TARGET_KERNEL_JSP */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifdef SUPPORT_TCP /* * 局所関数 */ static T_TCP_CEP *tcp_timers (T_TCP_CEP *cep, int_t tix); #if defined(NUM_TCP_TW_CEP_ENTRY) && NUM_TCP_TW_CEP_ENTRY > 0 static void tcp_tw_timo (void); #endif /* of #if defined(NUM_TCP_TW_CEP_ENTRY) && NUM_TCP_TW_CEP_ENTRY > 0 */ /* * バックオフ時間 * * 再送を行うたびに、タイムアウトの時間を延長する。 */ const static uint8_t tcp_back_off[] = { UINT_C(1), UINT_C(2), UINT_C(4), UINT_C(8), UINT_C(16), UINT_C(32), UINT_C(64), UINT_C(64), UINT_C(64), UINT_C(64), UINT_C(64), UINT_C(64), UINT_C(64) }; #define TCP_TOTAL_BACK_OFF 511 /* バックオフ時間の合計 */ /* * tcp_timers -- タイムアウト処理 */ static T_TCP_CEP * tcp_timers (T_TCP_CEP *cep, int_t tix) { uint16_t win; switch (tix) { /* * 再送タイマ */ case TCP_TIM_REXMT: /* * 最大再送回数 (TCP_MAX_REXMT_SHIFT、標準 12 回) になったときは、 * コネクションを切断する。 */ if (++ cep->rxtshift > TCP_MAX_REXMT_SHIFT) { cep->rxtshift = TCP_MAX_REXMT_SHIFT; cep->net_error = EV_REXMTMO; cep = tcp_drop(cep, E_CLS); break; } /* * 再送タイムアウトを計算する。 */ cep->rxtcur = tcp_range_set((T_TCP_TIME)(tcp_rexmt_val(cep) * tcp_back_off[cep->rxtshift]), (T_TCP_TIME)TCP_TVAL_MIN, (T_TCP_TIME)TCP_TVAL_MAX_REXMT); cep->timer[TCP_TIM_REXMT] = cep->rxtcur; /* * srtt: 平滑化された RTT * rttvar: 平滑化された分散 * * 再送回数が最大再送回数の 1/4 になったときは、 * 平滑化された分散 (rttvar) に srtt を加算し、 * 平滑化された RTT を 0 にする。 * */ if (cep->rxtshift > TCP_MAX_REXMT_SHIFT / 4) { cep->rttvar += (cep->srtt >> TCP_SRTT_SHIFT); cep->srtt = 0; } /* * snd_nxt: 次に送信する SEQ、この時点では、前回送信した SEQ * snd_una: 未確認の最小送信 SEQ または、確認された最大送信 SEQ * * 前回送信した SEQ (snd_nxt) を * 確認された最大送信 SEQ (snd_una) まで戻す。 */ cep->snd_nxt = cep->snd_una; cep->flags |= TCP_CEP_FLG_ACK_NOW; /* * rtt: 往復時間の計測を中止する。 */ cep->rtt = 0; /* * 送信ウインドの設定 * * snd_wnd: 相手の受信可能ウィンドサイズ * snd_cwnd: 輻輳ウィンドサイズ * maxseg : 相手の最大受信セグメントサイズ * * 相手の受信可能ウィンドサイズ (snd_wnd) か、 * 輻輳ウィンドサイズ (snd_cwnd) の * どちらか小さいサイズの 1/2 を、更に * 相手の最大受信セグメントサイズ (maxseg) で割った値。 * ただし、2 以上 */ if (cep->snd_wnd < cep->snd_cwnd) win = cep->snd_wnd / 2 / cep->maxseg; else win = cep->snd_cwnd / 2 / cep->maxseg; if (win < 2) win = 2; /* * 輻輳ウィンドサイズ (snd_cwnd) は * 相手の受信可能ウィンドサイズ (snd_wnd) に、 * 輻輳ウィンドサイズのしきい値 (snd_ssthresh) は * 相手の受信可能ウィンドサイズ (snd_wnd) の win 倍に * 設定する。 */ cep->snd_cwnd = cep->maxseg; cep->snd_ssthresh = win * cep->maxseg; cep->dupacks = 0; /* 出力をポストする。*/ cep->flags |= TCP_CEP_FLG_POST_OUTPUT; sig_sem(SEM_TCP_POST_OUTPUT); break; /* * 持続タイマ */ case TCP_TIM_PERSIST: /* * 最大再送回数 (TCP_MAX_REXMT_SHIFT、標準 12 回) を超えていて、 * アイドル時間が、保留タイマの標準値 (TCP_TVAL_KEEP_IDLE、 * 標準 2 * 60 * 60 秒) 以上か、 * 再送タイムアウト値 * バックオフ時間の合計以上なら * コネクションを切断する。 */ if (cep->rxtshift > TCP_MAX_REXMT_SHIFT && (cep->idle >= TCP_TVAL_KEEP_IDLE || cep->idle >= tcp_rexmt_val(cep) * TCP_TOTAL_BACK_OFF)) { cep->net_error = EV_REXMTMO; cep = tcp_drop(cep, E_CLS); break; } /* 持続タイマを再設定し、出力をポストする。*/ tcp_set_persist_timer(cep); cep->flags |= TCP_CEP_FLG_FORCE | TCP_CEP_FLG_FORCE_CLEAR | TCP_CEP_FLG_POST_OUTPUT; sig_sem(SEM_TCP_POST_OUTPUT); break; /* * 保留 (keep alive) タイマ */ case TCP_TIM_KEEP: /* * コネクションが開設されるまでにタイムアウトしたら * コネクションの開設を中止する。 */ if (cep->fsm_state < TCP_FSM_ESTABLISHED) { cep->net_error = EV_REXMTMO; cep = tcp_drop(cep, E_CLS); break; } #ifdef TCP_CFG_ALWAYS_KEEP else if (cep->fsm_state < TCP_FSM_CLOSING) { if (cep->idle >= TCP_TVAL_KEEP_IDLE + TCP_TVAL_KEEP_COUNT * TCP_TVAL_KEEP_INTERVAL) { cep->net_error = EV_REXMTMO; cep = tcp_drop(cep, E_CLS); break; } else tcp_respond(NULL, cep, cep->rcv_nxt, cep->snd_una - 1, cep->rbufsz - cep->rwbuf_count, 0); cep->timer[TCP_TIM_KEEP] = TCP_TVAL_KEEP_INTERVAL; } else cep->timer[TCP_TIM_KEEP] = TCP_TVAL_KEEP_IDLE; #else /* of #ifdef TCP_CFG_ALWAYS_KEEP */ cep->timer[TCP_TIM_KEEP] = TCP_TVAL_KEEP_IDLE; #endif /* of #ifdef TCP_CFG_ALWAYS_KEEP */ break; /* * 2MSL タイマ */ case TCP_TIM_2MSL: if (cep->fsm_state != TCP_FSM_TIME_WAIT && cep->idle <= TCP_TVAL_KEEP_COUNT * TCP_TVAL_KEEP_INTERVAL) cep->timer[TCP_TIM_2MSL] = TCP_TVAL_KEEP_INTERVAL; else cep = tcp_close(cep); break; } return cep; } /* * tcp_cancel_timers -- 全てのタイマをキャンセルする。 */ void tcp_cancel_timers (T_TCP_CEP *cep) { int_t ix; for (ix = NUM_TCP_TIMERS; ix -- > 0; ) cep->timer[ix] = 0; } #if defined(NUM_TCP_TW_CEP_ENTRY) && NUM_TCP_TW_CEP_ENTRY > 0 /* * tcp_tw_timo -- Time Wait 用 TCP 通信端点のタイムアウト処理 */ void tcp_tw_timo (void) { T_TCP_CEP *cep, *lcep; T_TCP_TWCEP* twcep; T_TCP_TIME longer; int_t frees, waits; /* * Time Wait 用 TCP 通信端点でタイムアウトのエントリを探索し、 * 探索したエントリを空きにする。 */ frees = 0; for (twcep = &tcp_twcep[NUM_TCP_TW_CEP_ENTRY]; twcep -- != tcp_twcep; ) if (twcep->fsm_state == TCP_FSM_TIME_WAIT && -- twcep->timer_2msl == 0) { twcep->fsm_state = TCP_FSM_CLOSED; frees ++; } /* * Time Wait 用 TCP 通信端点の空きエントリが発生したら * 標準 TCP 通信端点で Time Wait 中の TCP 通信端点を探索し、 * 必要な情報を Time Wait 用 TCP 通信端点に移して、 * 標準の TCP 通信端点を開放する。 */ if (frees > 0) { waits = 0; for (cep = &tcp_cep[tmax_tcp_cepid]; cep -- != tcp_cep; ) if (cep->fsm_state == TCP_FSM_TIME_WAIT) waits ++; if (waits > frees) waits = frees; /* * もっとも長い間 Time Wait している TCP 通信端点を開放する。 */ while (waits > 0) { longer = TCP_TVAL_MSL * 2; lcep = NULL; for (cep = &tcp_cep[tmax_tcp_cepid]; cep -- != tcp_cep; ) if (cep->fsm_state == TCP_FSM_TIME_WAIT && cep->timer[TCP_TIM_2MSL] < longer) { longer = cep->timer[TCP_TIM_2MSL]; lcep = cep; } if (lcep != NULL) { tcp_move_twcep(lcep); waits --; } else break; } } } #endif /* of #if defined(NUM_TCP_TW_CEP_ENTRY) && NUM_TCP_TW_CEP_ENTRY > 0 */ /* * tcp_slow_timo -- 500 [ms] 毎に呼出される TCP タイムアウト関数 */ void tcp_slow_timo (void *ignore) { T_TCP_CEP *cep; int_t cix, tix; for (cix = tmax_tcp_cepid; cix -- > 0; ) { cep = &tcp_cep[cix]; if (!(cep->fsm_state == TCP_FSM_CLOSED || cep->fsm_state == TCP_FSM_LISTEN)) { for (tix = NUM_TCP_TIMERS; cep != NULL && tix -- > 0; ) { if (cep->timer[tix] != 0 && -- cep->timer[tix] == 0) { cep = tcp_timers(cep, tix); } } if (cep != NULL) { cep->idle ++; if (cep->rtt) { cep->rtt ++; } } } } #if defined(NUM_TCP_TW_CEP_ENTRY) && NUM_TCP_TW_CEP_ENTRY > 0 tcp_tw_timo(); #endif /* of #if defined(NUM_TCP_TW_CEP_ENTRY) && NUM_TCP_TW_CEP_ENTRY > 0 */ if (tcp_iss != 0) { tcp_iss += TCP_ISS_INCR() / TCP_SLOW_HZ; } timeout(tcp_slow_timo, NULL, TCP_SLOW_TMO); } #ifdef TCP_CFG_DELAY_ACK /* * tcp_fast_timo -- 200 [ms] 毎に呼出される TCP タイムアウト関数 */ void tcp_fast_timo (void *ignore) { T_TCP_CEP *cep; int_t cix; for (cix = tmax_tcp_cepid; cix -- > 0; ) { cep = &tcp_cep[cix]; if (cep->flags & TCP_CEP_FLG_DEL_ACK) { cep->flags &= ~TCP_CEP_FLG_DEL_ACK; cep->flags |= TCP_CEP_FLG_ACK_NOW | TCP_CEP_FLG_POST_OUTPUT; sig_sem(SEM_TCP_POST_OUTPUT); } } timeout(tcp_fast_timo, NULL, TCP_FAST_TMO); } #endif/* of #ifdef TCP_CFG_DELAY_ACK */ /* * tcp_range_set -- 時間を指定した範囲に設定する。 */ T_TCP_TIME tcp_range_set (T_TCP_TIME value, T_TCP_TIME tvmin, T_TCP_TIME tvmax) { if ((uint32_t)value < (uint32_t)tvmin) return tvmin; else if ((uint32_t)value > (uint32_t)tvmax) return tvmax; else return value; } /* * tcp_set_persist_timer -- 持続タイマの設定 */ void tcp_set_persist_timer (T_TCP_CEP *cep) { T_TCP_TIME time; /* * srtt: 平滑化された RTT * rttvar: 平滑化された分散 */ time = ((cep->srtt >> 2) + cep->rttvar) >> 1; /* * 再送タイマも設定されていれば回復不能エラー */ if (cep->timer[TCP_TIM_REXMT]) /* %%% panic("tcp_output REXMT"); %%% */; /* * 持続タイマを設定する。 */ cep->timer[TCP_TIM_PERSIST] = tcp_range_set((T_TCP_TIME)(time * tcp_back_off[cep->rxtshift]), (T_TCP_TIME)TCP_TVAL_MIN_PERSIST, (T_TCP_TIME)TCP_TVAL_MAX_PERSIST); /* * 再送回数を更新する。 */ if (cep->rxtshift < TCP_MAX_REXMT_SHIFT) cep->rxtshift ++; } #endif /* of #ifdef SUPPORT_TCP */