/titanic_50/usr/src/uts/common/inet/tcp/ |
H A D | tcp_fusion.c | 129 if (peer_connp == NULL || peer_connp->conn_sqp != connp->conn_sqp || in tcp_fuse() 142 ASSERT(peer_connp->conn_sqp == connp->conn_sqp); in tcp_fuse() 280 ASSERT(tcp->tcp_connp->conn_sqp == peer_tcp->tcp_connp->conn_sqp); in tcp_unfuse() 458 ASSERT(connp->conn_sqp == peer_connp->conn_sqp); in tcp_fuse_output() 873 ASSERT(tcp->tcp_connp->conn_sqp == in tcp_fuse_backenable() 874 peer_tcp->tcp_connp->conn_sqp); in tcp_fuse_backenable()
|
H A D | tcp_input.c | 773 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, in tcp_drop_q0() 1011 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, tcp_eager_kill, in tcp_eager_blowoff() 1039 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, in tcp_eager_cleanup() 1055 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, mp, in tcp_eager_cleanup() 1413 econnp->conn_sqp = new_sqp; in tcp_input_listener() 1769 if (econnp->conn_sqp == lconnp->conn_sqp) { in tcp_input_listener() 1777 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp1, tcp_send_synack, in tcp_input_listener() 1786 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp1, tcp_eager_kill, in tcp_input_listener() 1810 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp, tcp_input_data, in tcp_input_listener() 1889 if (connp->conn_sqp != new_sqp) { in tcp_input_listener_unbound() [all …]
|
H A D | tcp_time_wait.c | 65 squeue_getprivate(tcp->tcp_connp->conn_sqp, SQPRIVATE_TCP)); in tcp_time_wait_remove() 137 squeue_t *sqp = tcp->tcp_connp->conn_sqp; in tcp_time_wait_append() 429 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, in tcp_time_wait_collector() 457 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, in tcp_time_wait_collector()
|
H A D | tcp_timers.c | 142 ASSERT(connp->conn_sqp != NULL); in tcp_timeout() 184 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_timer_handler, connp, in tcp_timer_callback() 198 ASSERT((squeue_t *)arg2 == connp->conn_sqp); in tcp_timer_handler()
|
H A D | tcp_socket.c | 545 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output_urgent, in tcp_sendmsg() 548 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output, in tcp_sendmsg() 586 SQUEUE_ENTER_ONE(connp->conn_sqp, bp, tcp_shutdown_output, in tcp_shutdown()
|
H A D | tcp_tpi.c | 1675 SQUEUE_ENTER_ONE(eager->tcp_connp->conn_sqp, discon_mp, in tcp_tli_accept() 1798 SQUEUE_ENTER_ONE(listener->tcp_connp->conn_sqp, in tcp_tpi_accept() 1812 SQUEUE_ENTER_ONE(econnp->conn_sqp, discon_mp, tcp_accept_finish, in tcp_tpi_accept()
|
H A D | tcp.c | 1096 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_close_output, connp, in tcp_close_common() 1131 SQUEUE_ENTER_ONE(connp->conn_sqp, bp, in tcp_close_common() 2658 connp->conn_sqp = sqp; in tcp_create_common() 2659 connp->conn_initial_sqp = connp->conn_sqp; in tcp_create_common() 2660 connp->conn_ixa->ixa_sqp = connp->conn_sqp; in tcp_create_common()
|
H A D | tcp_misc.c | 337 SQUEUE_ENTER_ONE(tcp->tcp_connp->conn_sqp, mp, in tcp_ioctl_abort_bucket()
|
H A D | tcp_output.c | 111 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output, connp, in tcp_wput() 196 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, output_proc, connp, in tcp_wput()
|
/titanic_50/usr/src/uts/common/inet/ |
H A D | squeue.c | 478 if (connp->conn_sqp == sqp) { in squeue_enter() 491 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc, in squeue_enter() 605 if (connp->conn_sqp == sqp) { in squeue_enter() 615 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc, in squeue_enter() 810 if (connp->conn_sqp == sqp) { in squeue_drain() 822 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, proc, connp, ira, in squeue_drain() 1381 squeue_t *sqp = connp->conn_sqp; in squeue_wakeup_conn() 1414 sqp = connp->conn_sqp; in squeue_synch_enter() 1437 if (sqp != connp->conn_sqp) { in squeue_synch_enter() 1489 squeue_t *sqp = connp->conn_sqp; in squeue_synch_exit()
|
H A D | ipclassifier.h | 265 squeue_t *conn_sqp; /* Squeue for processing */ member
|
/titanic_50/usr/src/uts/common/sys/ |
H A D | squeue.h | 67 (connp)->conn_sqp = new_sqp;
|
/titanic_50/usr/src/uts/common/inet/ip/ |
H A D | ip_attr.c | 1313 if (connp->conn_sqp->sq_run == curthread) { in conn_ixa_cleanup() 1318 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_ixa_cleanup, in conn_ixa_cleanup()
|
H A D | ip6_input.c | 2190 if (ira->ira_target_sqp == connp->conn_sqp) { in ip_fanout_v6() 2213 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, in ip_fanout_v6() 2218 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, connp->conn_recv, in ip_fanout_v6()
|
H A D | ip_input.c | 2531 if (ira->ira_target_sqp == connp->conn_sqp) { in ip_fanout_v4() 2554 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, in ip_fanout_v4() 2559 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, connp->conn_recv, in ip_fanout_v4()
|
H A D | ip6.c | 843 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, in icmp_inbound_error_fanout_v6()
|
H A D | ip.c | 2150 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, in icmp_inbound_error_fanout_v4()
|