xnu-517.9.5.tar.gz

[apple/xnu.git] / bsd / netinet / tcp_timer.c

diff --git a/bsd/netinet/tcp_timer.c b/bsd/netinet/tcp_timer.c
index e0c303b4050a390723f648f8cff6878b5560678e..a99efeea70a9d16dec74af6bae94d61e9c440cab 100644 (file)
--- a/bsd/netinet/tcp_timer.c
+++ b/bsd/netinet/tcp_timer.c
@@ -90,6 +90,13 @@
 #define DBG_FNC_TCP_FAST       NETDBG_CODE(DBG_NETTCP, (5 << 8))
 #define DBG_FNC_TCP_SLOW       NETDBG_CODE(DBG_NETTCP, (5 << 8) | 1)
 
 #define DBG_FNC_TCP_FAST       NETDBG_CODE(DBG_NETTCP, (5 << 8))
 #define DBG_FNC_TCP_SLOW       NETDBG_CODE(DBG_NETTCP, (5 << 8) | 1)
 

+/*
+ * NOTE - WARNING
+ *
+ *
+ * 
+ *
+ */

 static int
 sysctl_msec_to_ticks SYSCTL_HANDLER_ARGS
 {
 static int
 sysctl_msec_to_ticks SYSCTL_HANDLER_ARGS
 {


@@ -306,6 +313,10 @@ tpgone:
 #endif
                ipnxt = ip->inp_list.le_next;
                tp = intotcpcb(ip);
 #endif
                ipnxt = ip->inp_list.le_next;
                tp = intotcpcb(ip);

+               if (tp == NULL) { /* tp already closed, remove from list */
+                       LIST_REMOVE(ip, inp_list);
+                       continue; 
+               }

                if (tp->t_timer[TCPT_2MSL] >= N_TIME_WAIT_SLOTS) {
                    tp->t_timer[TCPT_2MSL] -= N_TIME_WAIT_SLOTS;
                    tp->t_rcvtime += N_TIME_WAIT_SLOTS;
                if (tp->t_timer[TCPT_2MSL] >= N_TIME_WAIT_SLOTS) {
                    tp->t_timer[TCPT_2MSL] -= N_TIME_WAIT_SLOTS;
                    tp->t_rcvtime += N_TIME_WAIT_SLOTS;


@@ -357,6 +368,10 @@ tcp_timers(tp, timer)
        struct socket *so_tmp;
        struct tcptemp *t_template;
 
        struct socket *so_tmp;
        struct tcptemp *t_template;
 

+#if TCPDEBUG
+       int ostate;
+#endif
+

 #if INET6
        int isipv6 = (tp->t_inpcb->inp_vflag & INP_IPV4) == 0;
 #endif /* INET6 */
 #if INET6
        int isipv6 = (tp->t_inpcb->inp_vflag & INP_IPV4) == 0;
 #endif /* INET6 */


@@ -534,7 +549,7 @@ tcp_timers(tp, timer)
                if ((always_keepalive ||
                    tp->t_inpcb->inp_socket->so_options & SO_KEEPALIVE) &&
                    tp->t_state <= TCPS_CLOSING) {
                if ((always_keepalive ||
                    tp->t_inpcb->inp_socket->so_options & SO_KEEPALIVE) &&
                    tp->t_state <= TCPS_CLOSING) {

-                       if (tp->t_rcvtime >= tcp_keepidle + tcp_maxidle)
+                       if (tp->t_rcvtime >= TCP_KEEPIDLE(tp) + tcp_maxidle)

                                goto dropit;
                        /*
                         * Send a packet designed to force a response
                                goto dropit;
                        /*
                         * Send a packet designed to force a response


@@ -558,7 +573,7 @@ tcp_timers(tp, timer)
                        }
                        tp->t_timer[TCPT_KEEP] = tcp_keepintvl;
                } else
                        }
                        tp->t_timer[TCPT_KEEP] = tcp_keepintvl;
                } else

-                       tp->t_timer[TCPT_KEEP] = tcp_keepidle;
+                       tp->t_timer[TCPT_KEEP] = TCP_KEEPIDLE(tp);

                break;
 
 #if TCPDEBUG
                break;
 
 #if TCPDEBUG