Lines Matching defs:tp
127 tcp_reass_flush(struct tcpcb *tp)
131 INP_WLOCK_ASSERT(tp->t_inpcb);
133 while ((qe = LIST_FIRST(&tp->t_segq)) != NULL) {
137 tp->t_segqlen--;
140 KASSERT((tp->t_segqlen == 0),
142 tp, tp->t_segqlen));
155 tcp_reass(struct tcpcb *tp, struct tcphdr *th, int *tlenp, struct mbuf *m)
161 struct socket *so = tp->t_inpcb->inp_socket;
166 INP_WLOCK_ASSERT(tp->t_inpcb);
196 if ((th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) &&
197 tp->t_segqlen >= (so->so_rcv.sb_hiwat / tp->t_maxseg) + 1) {
202 if ((s = tcp_log_addrs(&tp->t_inpcb->inp_inc, th, NULL, NULL))) {
219 if (th->th_seq != tp->rcv_nxt || !TCPS_HAVEESTABLISHED(tp->t_state)) {
223 if ((s = tcp_log_addrs(&tp->t_inpcb->inp_inc, th, NULL,
233 if ((s = tcp_log_addrs(&tp->t_inpcb->inp_inc, th, NULL,
242 tp->t_segqlen++;
247 LIST_FOREACH(q, &tp->t_segq, tqe_q) {
269 tp->t_segqlen--;
283 tp->t_rcvoopack++;
306 tp->t_segqlen--;
316 LIST_INSERT_HEAD(&tp->t_segq, te, tqe_q);
328 if (!TCPS_HAVEESTABLISHED(tp->t_state))
330 q = LIST_FIRST(&tp->t_segq);
331 if (!q || q->tqe_th->th_seq != tp->rcv_nxt)
335 tp->rcv_nxt += q->tqe_len;
345 tp->t_segqlen--;
347 } while (q && q->tqe_th->th_seq == tp->rcv_nxt);
348 ND6_HINT(tp);