Lines Matching refs:eager
911 tcp_t *eager; in tcp_drop_q0() local
919 eager = tcp->tcp_eager_prev_drop_q0; in tcp_drop_q0()
922 if (eager == tcp) { in tcp_drop_q0()
934 MAKE_UNDROPPABLE(eager); in tcp_drop_q0()
947 CONN_INC_REF(eager->tcp_connp); in tcp_drop_q0()
949 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, in tcp_drop_q0()
950 tcp_clean_death_wrapper, eager->tcp_connp, NULL, in tcp_drop_q0()
1114 tcp_t *eager = econnp->conn_tcp; in tcp_eager_kill() local
1115 tcp_t *listener = eager->tcp_listener; in tcp_eager_kill()
1122 ASSERT(eager->tcp_detached); in tcp_eager_kill()
1131 if (econnp->conn_fanout != NULL && eager->tcp_state > TCPS_LISTEN) { in tcp_eager_kill()
1133 eager, eager->tcp_snxt, 0, TH_RST); in tcp_eager_kill()
1139 tcp_eager_unlink(eager); in tcp_eager_kill()
1140 if (eager->tcp_tconnind_started) { in tcp_eager_kill()
1154 if (eager->tcp_state != TCPS_CLOSED) in tcp_eager_kill()
1155 tcp_close_detached(eager); in tcp_eager_kill()
1165 tcp_t *eager; in tcp_eager_blowoff() local
1168 eager = listener; in tcp_eager_blowoff()
1171 eager = eager->tcp_eager_next_q; in tcp_eager_blowoff()
1172 if (eager == NULL) { in tcp_eager_blowoff()
1176 } while (eager->tcp_conn_req_seqnum != seqnum); in tcp_eager_blowoff()
1178 if (eager->tcp_closemp_used) { in tcp_eager_blowoff()
1182 eager->tcp_closemp_used = B_TRUE; in tcp_eager_blowoff()
1183 TCP_DEBUG_GETPCSTACK(eager->tcmp_stk, 15); in tcp_eager_blowoff()
1184 CONN_INC_REF(eager->tcp_connp); in tcp_eager_blowoff()
1186 mp = &eager->tcp_closemp; in tcp_eager_blowoff()
1187 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, tcp_eager_kill, in tcp_eager_blowoff()
1188 eager->tcp_connp, NULL, SQ_FILL, SQTAG_TCP_EAGER_BLOWOFF); in tcp_eager_blowoff()
1199 tcp_t *eager; in tcp_eager_cleanup() local
1208 eager = listener->tcp_eager_next_q; in tcp_eager_cleanup()
1209 while (eager != NULL) { in tcp_eager_cleanup()
1210 if (!eager->tcp_closemp_used) { in tcp_eager_cleanup()
1211 eager->tcp_closemp_used = B_TRUE; in tcp_eager_cleanup()
1212 TCP_DEBUG_GETPCSTACK(eager->tcmp_stk, 15); in tcp_eager_cleanup()
1213 CONN_INC_REF(eager->tcp_connp); in tcp_eager_cleanup()
1214 mp = &eager->tcp_closemp; in tcp_eager_cleanup()
1215 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, in tcp_eager_cleanup()
1216 tcp_eager_kill, eager->tcp_connp, NULL, in tcp_eager_cleanup()
1219 eager = eager->tcp_eager_next_q; in tcp_eager_cleanup()
1224 eager = listener->tcp_eager_next_q0; in tcp_eager_cleanup()
1225 while (eager != listener) { in tcp_eager_cleanup()
1226 if (!eager->tcp_closemp_used) { in tcp_eager_cleanup()
1227 eager->tcp_closemp_used = B_TRUE; in tcp_eager_cleanup()
1228 TCP_DEBUG_GETPCSTACK(eager->tcmp_stk, 15); in tcp_eager_cleanup()
1229 CONN_INC_REF(eager->tcp_connp); in tcp_eager_cleanup()
1230 mp = &eager->tcp_closemp; in tcp_eager_cleanup()
1231 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, in tcp_eager_cleanup()
1232 tcp_eager_kill, eager->tcp_connp, NULL, SQ_FILL, in tcp_eager_cleanup()
1235 eager = eager->tcp_eager_next_q0; in tcp_eager_cleanup()
1442 tcp_t *eager; in tcp_input_listener() local
1617 eager = econnp->conn_tcp; in tcp_input_listener()
1618 eager->tcp_detached = B_TRUE; in tcp_input_listener()
1619 SOCK_CONNID_INIT(eager->tcp_connid); in tcp_input_listener()
1625 tcp_init_values(eager, listener); in tcp_input_listener()
1637 eager->tcp_recvifindex = 0; in tcp_input_listener()
1638 eager->tcp_recvhops = 0xffffffffU; in tcp_input_listener()
1664 ASSERT(eager->tcp_conn.tcp_eager_conn_ind == NULL); in tcp_input_listener()
1665 ASSERT(!eager->tcp_tconnind_started); in tcp_input_listener()
1673 eager->tcp_conn.tcp_eager_conn_ind = tpi_mp; in tcp_input_listener()
1674 ASSERT(eager->tcp_ordrel_mp == NULL); in tcp_input_listener()
1680 eager->tcp_issocket = B_TRUE; in tcp_input_listener()
1688 if ((eager->tcp_ordrel_mp = mi_tpi_ordrel_ind()) == NULL) in tcp_input_listener()
1714 eager->tcp_rwnd = 0; in tcp_input_listener()
1766 eager->tcp_hard_binding = B_TRUE; in tcp_input_listener()
1769 TCP_BIND_HASH(econnp->conn_lport)], eager, 0); in tcp_input_listener()
1773 tcp_bind_hash_remove(eager); in tcp_input_listener()
1777 SOCK_CONNID_BUMP(eager->tcp_connid); in tcp_input_listener()
1783 if (tcp_set_destination(eager) != 0) { in tcp_input_listener()
1786 tcp_bind_hash_remove(eager); in tcp_input_listener()
1791 if (!tcp_process_options(mp, eager, tcpha, ira, B_TRUE)) { in tcp_input_listener()
1792 tcp_bind_hash_remove(eager); in tcp_input_listener()
1799 eager->tcp_ecn_ok = B_TRUE; in tcp_input_listener()
1812 eager->tcp_rwnd = MSS_ROUNDUP( in tcp_input_listener()
1813 (eager->tcp_rwnd == 0 ? econnp->conn_rcvbuf : in tcp_input_listener()
1814 eager->tcp_rwnd), eager->tcp_mss); in tcp_input_listener()
1815 if (eager->tcp_snd_ws_ok) in tcp_input_listener()
1816 tcp_set_ws_value(eager); in tcp_input_listener()
1823 (void) tcp_rwnd_set(eager, eager->tcp_rwnd); in tcp_input_listener()
1825 ASSERT(eager->tcp_connp->conn_rcvbuf != 0 && in tcp_input_listener()
1826 eager->tcp_connp->conn_rcvbuf == eager->tcp_rwnd); in tcp_input_listener()
1829 econnp->conn_rcvbuf == eager->tcp_rwnd); in tcp_input_listener()
1834 listener->tcp_eager_next_q0->tcp_eager_prev_q0 = eager; in tcp_input_listener()
1835 eager->tcp_eager_next_q0 = listener->tcp_eager_next_q0; in tcp_input_listener()
1836 listener->tcp_eager_next_q0 = eager; in tcp_input_listener()
1837 eager->tcp_eager_prev_q0 = listener; in tcp_input_listener()
1840 eager->tcp_listener = listener; in tcp_input_listener()
1841 eager->tcp_saved_listener = listener; in tcp_input_listener()
1847 eager->tcp_listen_cnt = listener->tcp_listen_cnt; in tcp_input_listener()
1853 eager->tcp_conn_req_seqnum = listener->tcp_conn_req_seqnum; in tcp_input_listener()
1871 eager->tcp_dontdrop = B_TRUE; in tcp_input_listener()
1884 eager->tcp_irs = seg_seq; in tcp_input_listener()
1885 eager->tcp_rack = seg_seq; in tcp_input_listener()
1886 eager->tcp_rnxt = seg_seq + 1; in tcp_input_listener()
1887 eager->tcp_tcpha->tha_ack = htonl(eager->tcp_rnxt); in tcp_input_listener()
1889 eager->tcp_state = TCPS_SYN_RCVD; in tcp_input_listener()
1891 econnp->conn_ixa, void, NULL, tcp_t *, eager, void, NULL, in tcp_input_listener()
1894 mp1 = tcp_xmit_mp(eager, eager->tcp_xmit_head, eager->tcp_mss, in tcp_input_listener()
1895 NULL, NULL, eager->tcp_iss, B_FALSE, NULL, B_FALSE); in tcp_input_listener()
1933 TCP_TIMER_RESTART(eager, eager->tcp_rto); in tcp_input_listener()
1951 tcp_t *, eager, __dtrace_tcp_tcph_t *, in tcp_input_listener()
1962 eager->tcp_closemp_used = B_TRUE; in tcp_input_listener()
1963 TCP_DEBUG_GETPCSTACK(eager->tcmp_stk, 15); in tcp_input_listener()
1964 mp1 = &eager->tcp_closemp; in tcp_input_listener()