Home
last modified time | relevance | path

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

/titanic_44/usr/src/uts/common/inet/ip/
H A Dip_mroute.c565 (void) mi_strlog(connp->conn_rq, 1, SL_TRACE, in ip_mrouter_init()
625 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in ip_mrouter_done()
890 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in add_vif()
1021 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in add_vif()
1050 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in del_vifp()
1204 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in add_mfc()
1241 (void) mi_strlog(mrouter->conn_rq, 1, in add_mfc()
1302 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in add_mfc()
1447 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in del_mfc()
1545 (void) mi_strlog(mrouter->conn_rq, 1, SL_TRACE, in ip_mforward()
[all …]
H A Dip_helper_stream.c82 connp->conn_rq = RD(q); in ip_helper_share_conn()
H A Dicmp.c710 putnext(connp->conn_rq, mp); in icmp_tpi_connect()
711 putnext(connp->conn_rq, mp1); in icmp_tpi_connect()
955 qprocsoff(connp->conn_rq); in rawip_do_close()
1258 putnext(connp->conn_rq, mp1); in icmp_icmp_input()
1428 putnext(connp->conn_rq, mp1); in icmp_icmp_error_ipv6()
1625 connp->conn_rq = q; in icmp_tpi_open()
1635 (void) proto_set_rx_hiwat(connp->conn_rq, connp, connp->conn_rcvbuf); in icmp_tpi_open()
2329 (void) proto_set_rx_hiwat(connp->conn_rq, connp, in icmp_opt_set()
2344 (void) proto_set_tx_wroff(connp->conn_rq, connp, wroff); in icmp_opt_set()
2541 putnext(connp->conn_rq, mp); in icmp_ulp_recv()
[all …]
H A Drts.c288 connp->conn_rq = q; in rts_stream_open()
1162 qenable(connp->conn_rq); in rts_input()
1208 putnext(connp->conn_rq, mp); in rts_input()
H A Dconn_opt.c2840 econnp->conn_rq = lconnp->conn_rq; in conn_inherit_parent()
H A Dip.c4289 putnext(connp->conn_rq, mp); in ip_conn_input()
4936 rq = connp->conn_rq; in ip_fanout_proto_conn()
5049 ASSERT(IPCL_IS_NONSTR(connp) || connp->conn_rq != NULL); in ip_fanout_proto_v4()
5215 !canputnext(connp->conn_rq)) { in ip_fanout_udp_conn()
5419 ASSERT(IPCL_IS_NONSTR(connp) || connp->conn_rq != NULL); in ip_fanout_udp_multi_v4()
6022 connp->conn_rq = q; in ip_open()
6088 connp->conn_rq = q; in ip_open()
14325 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.c2318 !canputnext(connp->conn_rq)) { in ip_fanout_v6()
H A Dip_input.c2661 !canputnext(connp->conn_rq)) { in ip_fanout_v4()
H A Dipclassifier.c2197 ASSERT(connp->conn_rq == NULL); in ipcl_conn_cleanup()
H A Dip6.c2331 ASSERT(IPCL_IS_NONSTR(connp) || connp->conn_rq != NULL); in ip_fanout_proto_v6()
/titanic_44/usr/src/uts/common/inet/tcp/
H A Dtcp_tpi.c56 tcp->tcp_acceptor_id = (t_uscalar_t)connp->conn_rq; in tcp_use_pure_tpi()
75 putnext(tcp->tcp_connp->conn_rq, mp); in tcp_err_ack()
91 putnext(tcp->tcp_connp->conn_rq, mp); in tcp_err_ack_prim()
309 putnext(connp->conn_rq, mp); in tcp_tpi_bind()
327 (void) putnextctl1(connp->conn_rq, M_FLUSH, FLUSHRW); in tcp_tpi_unbind()
331 putnext(connp->conn_rq, mp); in tcp_tpi_unbind()
491 putnext(connp->conn_rq, mp); in tcp_conn_con()
733 putnext(connp->conn_rq, mp); in tcp_tpi_connect()
869 putnext(tcp->tcp_connp->conn_rq, mp); in tcp_capability_req()
887 putnext(tcp->tcp_connp->conn_rq, mp); in tcp_info_req()
[all …]
H A Dtcp_fusion.c163 queue_t *peer_rq = peer_connp->conn_rq; in tcp_fuse()
305 (void) tcp_fuse_rcv_drain(tcp->tcp_connp->conn_rq, tcp, in tcp_unfuse()
309 (void) tcp_fuse_rcv_drain(peer_tcp->tcp_connp->conn_rq, in tcp_unfuse()
618 !IPCL_IS_NONSTR(peer_connp) && !canputnext(peer_connp->conn_rq))) { in tcp_fuse_output()
682 (void) tcp_fuse_rcv_drain(peer_connp->conn_rq, peer_tcp, in tcp_fuse_output()
877 (void) tcp_fuse_rcv_drain(tcp->tcp_connp->conn_rq, tcp, NULL); in tcp_fuse_backenable()
H A Dtcp.c887 q = connp->conn_rq; in tcp_clean_death()
994 connp->conn_rq = NULL; in tcp_stop_lingering()
1018 connp->conn_rq = NULL; in tcp_stop_lingering()
1286 connp->conn_rq = NULL; in tcp_closei_local()
1362 connp->conn_rq = NULL; in tcp_free()
1884 (void) putnextctl1(connp->conn_rq, M_FLUSH, FLUSHRW); in tcp_disconnect()
1888 putnext(connp->conn_rq, mp); in tcp_disconnect()
2082 PRESERVE(connp->conn_rq);
2540 queue_t *q = connp->conn_rq; in tcp_maxpsz_set()
2808 connp->conn_rq = q; in tcp_open()
[all …]
H A Dtcp_socket.c831 connp->conn_rq = RD(q); in tcp_fallback_noneager()
959 connp->conn_rq = listener->tcp_connp->conn_rq; in tcp_fallback_eager()
985 putnext(listener->tcp_connp->conn_rq, mp); in tcp_fallback_eager()
H A Dtcp_input.c999 econnp->conn_rq = NULL; in tcp_eager_kill()
1987 queue_t *q = tcp->tcp_connp->conn_rq; in tcp_rcv_drain()
2602 (void) proto_set_tx_wroff(connp->conn_rq, connp, in tcp_input_data()
2724 putnext(connp->conn_rq, mp1); in tcp_input_data()
2751 putnext(connp->conn_rq, mp1); in tcp_input_data()
3138 !putnextctl1(connp->conn_rq, in tcp_input_data()
3428 !putnextctl1(connp->conn_rq, M_PCSIG, in tcp_input_data()
4784 putnext(connp->conn_rq, mp); in tcp_input_data()
4785 if (!canputnext(connp->conn_rq)) in tcp_input_data()
4810 putnext(connp->conn_rq, mp); in tcp_input_data()
[all …]
H A Dtcp_opt_data.c1080 (void) proto_set_tx_wroff(connp->conn_rq, connp, in tcp_opt_set()
H A Dtcp_output.c1659 connp->conn_rq = NULL; in tcp_close_output()
/titanic_44/usr/src/uts/common/inet/udp/
H A Dudp.c716 putnext(connp->conn_rq, mp); in udp_tpi_connect()
717 putnext(connp->conn_rq, mp1); in udp_tpi_connect()
1014 putnext(connp->conn_rq, mp1); in udp_icmp_input()
1042 putnext(connp->conn_rq, mp1); in udp_icmp_input()
1221 putnext(connp->conn_rq, mp1); in udp_icmp_error_ipv6()
1443 connp->conn_rq = q; in udp_open()
1949 (void) proto_set_rx_hiwat(connp->conn_rq, connp, in udp_opt_set()
1966 (void) proto_set_tx_wroff(connp->conn_rq, connp, wroff); in udp_opt_set()
2165 putnext(connp->conn_rq, mp); in udp_ulp_recv()
2179 putnext(connp->conn_rq, mp); in udp_ulp_recv()
[all …]
/titanic_44/usr/src/uts/common/inet/
H A Dipclassifier.h307 queue_t *conn_rq; /* Read queue */ member
H A Dip.h225 #define CONNP_TO_RQ(connp) ((connp)->conn_rq)
/titanic_44/usr/src/uts/common/inet/sctp/
H A Dsctp.c2101 connp->conn_rq = connp->conn_wq = NULL; in sctp_conn_init()