Home
last modified time | relevance | path

Searched refs:conn_rq (Results 1 – 22 of 22) sorted by relevance

/illumos-gate/usr/src/uts/common/inet/ip/
H A Dip_mroute.c570 (void) mi_strlog(connp->conn_rq, 1, SL_TRACE, in ip_mrouter_init()
895 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in add_vif()
1246 (void) mi_strlog(mrouter->conn_rq, 1, in add_mfc()
1587 (void) mi_strlog(mrouter->conn_rq, 1, in ip_mforward()
1592 (void) mi_strlog(mrouter->conn_rq, 1, in ip_mforward()
1709 (void) mi_strlog(mrouter->conn_rq, 1, in ip_mforward()
1811 (void) mi_strlog(mrouter->conn_rq, 1, in ip_mforward()
2278 !canputnext(mrouter->conn_rq)) { in register_send()
2683 (void) mi_strlog(mrouter->conn_rq, in ip_mroute_decap()
2789 (void) mi_strlog(mrouter->conn_rq, 1, in reset_mrt_ill()
[all …]
H A Dip_helper_stream.c82 connp->conn_rq = RD(q); in ip_helper_share_conn()
H A Dicmp.c711 putnext(connp->conn_rq, mp); in icmp_tpi_connect()
712 putnext(connp->conn_rq, mp1); in icmp_tpi_connect()
961 qprocsoff(connp->conn_rq); in rawip_do_close()
1265 putnext(connp->conn_rq, mp1); in icmp_icmp_input()
1435 putnext(connp->conn_rq, mp1); in icmp_icmp_error_ipv6()
1632 connp->conn_rq = q; in icmp_tpi_open()
2336 (void) proto_set_rx_hiwat(connp->conn_rq, connp, in icmp_opt_set()
2351 (void) proto_set_tx_wroff(connp->conn_rq, connp, wroff); in icmp_opt_set()
2548 putnext(connp->conn_rq, mp); in icmp_ulp_recv()
2553 putnext(connp->conn_rq, mp); in icmp_ulp_recv()
[all …]
H A Drts.c290 connp->conn_rq = q; in rts_stream_open()
1167 qenable(connp->conn_rq); in rts_input()
1213 putnext(connp->conn_rq, mp); in rts_input()
H A Dipclassifier.c2200 ASSERT(connp->conn_rq == NULL); in ipcl_conn_cleanup()
2770 } else if (!IPCL_IS_NONSTR(connp) && connp->conn_rq != NULL) { in conn_get_socket_info()
2771 vn = STREAM(connp->conn_rq)->sd_pvnode; in conn_get_socket_info()
H A Dconn_opt.c2899 econnp->conn_rq = lconnp->conn_rq; in conn_inherit_parent()
H A Dip.c4319 putnext(connp->conn_rq, mp); in ip_conn_input()
4966 rq = connp->conn_rq; in ip_fanout_proto_conn()
5086 ASSERT(IPCL_IS_NONSTR(connp) || connp->conn_rq != NULL); in ip_fanout_proto_v4()
5259 !canputnext(connp->conn_rq)) { in ip_fanout_udp_conn()
5464 ASSERT(IPCL_IS_NONSTR(connp) || connp->conn_rq != NULL); in ip_fanout_udp_multi_v4()
6068 connp->conn_rq = q; in ip_open()
6134 connp->conn_rq = q; in ip_open()
14406 rq = connp->conn_rq; in ip_fanout_sctp_raw()
H A Dip_rts.c163 canputnext(connp->conn_rq)) { in rts_queue_input()
H A Dip6_input.c2329 !canputnext(connp->conn_rq)) { in ip_fanout_v6()
H A Dip_input.c2678 !canputnext(connp->conn_rq)) { in ip_fanout_v4()
H A Dip6.c2321 ASSERT(IPCL_IS_NONSTR(connp) || connp->conn_rq != NULL); in ip_fanout_proto_v6()
/illumos-gate/usr/src/uts/common/inet/tcp/
H A Dtcp_tpi.c313 putnext(connp->conn_rq, mp); in tcp_tpi_bind()
335 putnext(connp->conn_rq, mp); in tcp_tpi_unbind()
497 putnext(connp->conn_rq, mp); in tcp_conn_con()
739 putnext(connp->conn_rq, mp); in tcp_tpi_connect()
970 ASSERT(eager->tcp_connp->conn_rq == listener->tcp_connp->conn_rq); in tcp_accept_swap()
1002 econnp->conn_rq = aconnp->conn_rq; in tcp_accept_swap()
1004 econnp->conn_rq->q_ptr = econnp; in tcp_accept_swap()
1059 queue_t *q = connp->conn_rq; in tcp_accept_finish()
1754 econnp->conn_rq = rq; in tcp_tpi_accept()
1898 putnext(lconnp->conn_rq, mp); in tcp_send_pending()
[all …]
H A Dtcp_fusion.c175 queue_t *peer_rq = peer_connp->conn_rq; in tcp_fuse()
317 (void) tcp_fuse_rcv_drain(tcp->tcp_connp->conn_rq, tcp, in tcp_unfuse()
321 (void) tcp_fuse_rcv_drain(peer_tcp->tcp_connp->conn_rq, in tcp_unfuse()
640 !IPCL_IS_NONSTR(peer_connp) && !canputnext(peer_connp->conn_rq))) { in tcp_fuse_output()
706 (void) tcp_fuse_rcv_drain(peer_connp->conn_rq, peer_tcp, in tcp_fuse_output()
901 (void) tcp_fuse_rcv_drain(tcp->tcp_connp->conn_rq, tcp, NULL); in tcp_fuse_backenable()
H A Dtcp.c882 q = connp->conn_rq; in tcp_clean_death()
989 connp->conn_rq = NULL; in tcp_stop_lingering()
1013 connp->conn_rq = NULL; in tcp_stop_lingering()
1289 connp->conn_rq = NULL; in tcp_closei_local()
1365 connp->conn_rq = NULL; in tcp_free()
1917 putnext(connp->conn_rq, mp); in tcp_disconnect()
2096 PRESERVE(connp->conn_rq); in tcp_reinit_values()
2576 queue_t *q = connp->conn_rq; in tcp_maxpsz_set()
2844 connp->conn_rq = q; in tcp_open()
2963 (void) proto_set_tx_wroff(connp->conn_rq, connp, in tcp_build_hdrs()
[all …]
H A Dtcp_socket.c838 connp->conn_rq = RD(q); in tcp_fallback_noneager()
966 connp->conn_rq = listener->tcp_connp->conn_rq; in tcp_fallback_eager()
992 putnext(listener->tcp_connp->conn_rq, mp); in tcp_fallback_eager()
H A Dtcp_input.c1105 econnp->conn_rq = NULL; in tcp_eager_kill()
2839 putnext(connp->conn_rq, mp1); in tcp_input_data()
2866 putnext(connp->conn_rq, mp1); in tcp_input_data()
3302 !putnextctl1(connp->conn_rq, in tcp_input_data()
4925 putnext(connp->conn_rq, mp); in tcp_input_data()
4926 if (!canputnext(connp->conn_rq)) in tcp_input_data()
4951 putnext(connp->conn_rq, mp); in tcp_input_data()
4952 if (!canputnext(connp->conn_rq)) in tcp_input_data()
5068 putnext(connp->conn_rq, mp1); in tcp_input_data()
5137 putnext(connp->conn_rq, mp1); in tcp_input_data()
[all …]
H A Dtcp_opt_data.c1183 (void) proto_set_tx_wroff(connp->conn_rq, connp, in tcp_opt_set()
H A Dtcp_output.c1679 connp->conn_rq = NULL; in tcp_close_output()
/illumos-gate/usr/src/uts/common/inet/udp/
H A Dudp.c798 putnext(connp->conn_rq, mp); in udp_tpi_connect()
799 putnext(connp->conn_rq, mp1); in udp_tpi_connect()
1097 putnext(connp->conn_rq, mp1); in udp_icmp_input()
1125 putnext(connp->conn_rq, mp1); in udp_icmp_input()
1304 putnext(connp->conn_rq, mp1); in udp_icmp_error_ipv6()
1526 connp->conn_rq = q; in udp_open()
2303 putnext(connp->conn_rq, mp); in udp_ulp_recv()
3492 putnext(connp->conn_rq, mp1); in udp_ud_err_connected()
3557 if (connp->conn_rq != NULL) in udp_wput()
4914 qprocsoff(connp->conn_rq); in udp_do_close()
[all …]
/illumos-gate/usr/src/uts/common/inet/
H A Dipclassifier.h313 queue_t *conn_rq; /* Read queue */ member
H A Dip.h226 #define CONNP_TO_RQ(connp) ((connp)->conn_rq)
/illumos-gate/usr/src/uts/common/inet/sctp/
H A Dsctp.c2102 connp->conn_rq = connp->conn_wq = NULL; in sctp_conn_init()