/illumos-gate/usr/src/uts/common/rpc/ |
H A D | clnt_clts.c | 124 queue_t *e_wq; /* write queue */ 179 static int clnt_clts_dispatch_send(queue_t *q, mblk_t *, struct netbuf *addr, 2028 clnt_clts_dispatch_send(queue_t *q, mblk_t *mp, struct netbuf *addr, in clnt_clts_dispatch_send()
|
H A D | clnt_cots.c | 222 queue_t *x_wq; /* send queue */ 496 void (*clnt_stop_idle)(queue_t *wq); 793 queue_t *wq; in clnt_cots_kcallit() 1820 queue_t *wq; in connmgr_get() 2592 connmgr_setbufsz(calllist_t *e, queue_t *wq, cred_t *cr) in connmgr_setbufsz() 2630 queue_t *wq, in connmgr_connect() 2859 connmgr_getopt_int(queue_t *wq, int level, int name, int *val, in connmgr_getopt_int() 2948 connmgr_setopt_int(queue_t *wq, int level, int name, int val, in connmgr_setopt_int() 3048 queue_t *q = cm_entry->x_wq; in connmgr_sndrel() 3078 queue_t *q = cm_entry->x_wq; in connmgr_snddis() [all …]
|
/illumos-gate/usr/src/uts/common/inet/ |
H A D | tcp_impl.h | 680 extern int tcp_rsrv(queue_t *); 711 extern boolean_t tcp_fuse_rcv_drain(queue_t *, tcp_t *, mblk_t **); 730 extern int tcp_wput(queue_t *, mblk_t *); 732 extern int tcp_wput_sock(queue_t *, mblk_t *); 733 extern int tcp_wput_fallback(queue_t *, mblk_t *); 758 extern int tcp_fallback(sock_lower_handle_t, queue_t *, boolean_t, 789 extern int tcp_tpi_accept(queue_t *, mblk_t *); 791 extern int tcp_tpi_close(queue_t *, int, cred_t *); 792 extern int tcp_tpi_close_accept(queue_t *, int, cred_t *); 794 extern int tcp_tpi_opt_get(queue_t *, t_scalar_t, t_scalar_t, uchar_t *); [all …]
|
H A D | keysock.h | 109 queue_t *keysock_rq; /* Read queue - putnext() to userland */ 110 queue_t *keysock_wq; /* Write queue */ 142 queue_t *kc_rq; /* Read queue, requests from AH, ESP. */ 143 queue_t *kc_wq; /* Write queue, putnext down */ 156 extern int keysock_opt_get(queue_t *, int, int, uchar_t *); 157 extern int keysock_opt_set(queue_t *, uint_t, int, int, uint_t,
|
H A D | tcp.h | 526 extern mblk_t *tcp_snmp_get(queue_t *, mblk_t *, boolean_t); 527 extern int tcp_snmp_set(queue_t *, int, int, uchar_t *, int len);
|
H A D | ipclassifier.h | 149 queue_t *iphs_rq; 150 queue_t *iphs_wq; 313 queue_t *conn_rq; /* Read queue */ 314 queue_t *conn_wq; /* Write queue */ 737 extern int ip_helper_stream_setup(queue_t *, dev_t *, int, int,
|
H A D | ip.h | 1610 queue_t *ill_rq; /* Read queue. */ 1611 queue_t *ill_wq; /* Write queue. */ 1789 queue_t *ill_lmod_rq; /* read queue pointer of module below */ 3219 extern int ip_lwput(queue_t *, mblk_t *); 3235 extern int ip_close(queue_t *, int, cred_t *); 3256 extern int ip_rput(queue_t *, mblk_t *); 3305 extern void ip_rput_other(ipsq_t *, queue_t *, mblk_t *, void *); 3377 extern int ip_wput_nondata(queue_t *, mblk_t *); 3378 extern int ip_wsrv(queue_t *); 3472 extern int ip_snmp_set(queue_t *q, int, int, uchar_t *, int); [all …]
|
/illumos-gate/usr/src/uts/common/inet/tcp/ |
H A D | tcp_output.c | 59 static void tcp_wput_cmdblk(queue_t *, mblk_t *); 99 tcp_wput(queue_t *q, mblk_t *mp) in tcp_wput() 591 tcp_wput_sock(queue_t *wq, mblk_t *mp) in tcp_wput_sock() 616 tcp_wput_fallback(queue_t *wq, mblk_t *mp) in tcp_wput_fallback() 672 queue_t *q = connp->conn_wq; in tcp_wput_flush() 738 queue_t *q = connp->conn_wq; in tcp_wput_iocdata() 841 queue_t *q = connp->conn_wq; in tcp_wput_ioctl() 1055 tcp_wput_cmdblk(queue_t *q, mblk_t *mp) in tcp_wput_cmdblk()
|
H A D | tcp_stats.c | 144 tcp_snmp_get(queue_t *q, mblk_t *mpctl, boolean_t legacy_req) in tcp_snmp_get() 488 tcp_snmp_set(queue_t *q, int level, int name, uchar_t *ptr, int len) in tcp_snmp_set()
|
H A D | tcp_input.c | 2096 queue_t *q = tcp->tcp_connp->conn_rq; in tcp_rcv_drain() 5625 queue_t *q = connp->conn_rq; in tcp_rsrv_input() 5667 tcp_rsrv(queue_t *q) in tcp_rsrv()
|
H A D | tcp_opt_data.c | 50 static int tcp_opt_default(queue_t *, int, int, uchar_t *); 327 tcp_opt_default(queue_t *q, int level, int name, uchar_t *ptr) in tcp_opt_default()
|
H A D | tcp.c | 290 static int tcp_wsrv(queue_t *q); 300 static int tcp_open(queue_t *, dev_t *, int, int, cred_t *, boolean_t); 301 static int tcp_openv4(queue_t *, dev_t *, int, int, cred_t *); 302 static int tcp_openv6(queue_t *, dev_t *, int, int, cred_t *); 814 queue_t *q; in tcp_clean_death() 2576 queue_t *q = connp->conn_rq; in tcp_maxpsz_set() 2620 tcp_openv4(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp) in tcp_openv4() 2627 tcp_openv6(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp) in tcp_openv6() 2777 tcp_open(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp, in tcp_open() 3457 tcp_wsrv(queue_t *q) in tcp_wsrv()
|
H A D | tcp_fusion.c | 175 queue_t *peer_rq = peer_connp->conn_rq; in tcp_fuse() 723 tcp_fuse_rcv_drain(queue_t *q, tcp_t *tcp, mblk_t **sigurg_mpp) in tcp_fuse_rcv_drain()
|
/illumos-gate/usr/src/uts/common/inet/ip/ |
H A D | keysock.c | 151 static int keysock_wput(queue_t *, mblk_t *); 152 static int keysock_rput(queue_t *, mblk_t *); 153 static int keysock_rsrv(queue_t *); 742 keysock_capability_req(queue_t *q, mblk_t *mp) in keysock_capability_req() 773 keysock_info_req(queue_t *q, mblk_t *mp) in keysock_info_req() 962 keysock_wput_other(queue_t *q, mblk_t *mp) in keysock_wput_other() 1374 keysock_do_flushdump(queue_t *q, mblk_t *mp) in keysock_do_flushdump() 1697 keysock_parse(queue_t *q, mblk_t *mp) in keysock_parse() 1954 keysock_wput(queue_t *q, mblk_t *mp) in keysock_wput() 2368 keysock_rsrv(queue_t *q) in keysock_rsrv() [all …]
|
H A D | ip.c | 676 int ip_rput(queue_t *, mblk_t *); 4024 queue_t *q = ill->ill_rq; in ip_modclose() 4962 queue_t *rq; in ip_fanout_proto_conn() 5723 ip_lrput(queue_t *q, mblk_t *mp) in ip_lrput() 8055 ip_rput(queue_t *q, mblk_t *mp) in ip_rput() 8149 queue_t *q = ill->ill_rq; in ip_rput_dlpi() 13416 ip_wsrv(queue_t *q) in ip_wsrv() 13544 queue_t *q = connp->conn_wq; in conn_setqfull() 13573 queue_t *q = connp->conn_wq; in conn_clrqfull() 14368 queue_t *rq; in ip_fanout_sctp_raw() [all …]
|
H A D | ip_mroute.c | 415 mrt_ioctl(ipif_t *ipif, sin_t *sin, queue_t *q, mblk_t *mp, in mrt_ioctl()
|
H A D | ip_helper_stream.c | 43 int ip_helper_wput(queue_t *q, mblk_t *mp); 45 static int ip_helper_stream_close(queue_t *, int, cred_t *); 65 ip_helper_share_conn(queue_t *q, mblk_t *mp, cred_t *crp) in ip_helper_share_conn() 88 ip_helper_wput(queue_t *q, mblk_t *mp) in ip_helper_wput() 104 ip_helper_stream_setup(queue_t *q, dev_t *devp, int flag, int sflag, in ip_helper_stream_setup() 158 ip_helper_stream_close(queue_t *q, int flag __unused, cred_t *credp __unused) in ip_helper_stream_close()
|
/illumos-gate/usr/src/cmd/mdb/common/modules/ip/ |
H A D | ip.c | 1664 mi_osize(const queue_t *q) in mi_osize() 1683 ip_ill_qinfo(const queue_t *q, char *buf, size_t nbytes) in ip_ill_qinfo() 1695 ip_qinfo(const queue_t *q, char *buf, size_t nbytes) in ip_qinfo() 1704 ip_rnext(const queue_t *q) in ip_rnext() 1717 ip_wnext(const queue_t *q) in ip_wnext()
|
/illumos-gate/usr/src/uts/common/fs/sockfs/ |
H A D | socktpi.c | 469 queue_t *tq = stp->sd_wrq->q_next; in sotpi_init() 1974 queue_t *q; in sotpi_accept() 4533 queue_t *udp_wq; in sodgram_direct() 4640 queue_t *tcp_wq = stp->sd_wrq->q_next; in sostream_direct() 6319 boolean_t *direct, queue_t **qp, struct cred *cr) in sotpi_convert_sonode() 6326 queue_t *q; in sotpi_convert_sonode()
|
H A D | sockcommon_subr.c | 2266 queue_t *q; in so_tpi_fallback()
|
/illumos-gate/usr/src/uts/common/sys/ |
H A D | tem_impl.h | 200 queue_t *tvs_queue; /* read queue for console */
|
/illumos-gate/usr/src/uts/common/io/ |
H A D | tem.c | 281 tem_init(cred_t *credp, queue_t *rq) in tem_init()
|
/illumos-gate/usr/src/uts/common/io/e1000g/ |
H A D | e1000g_main.c | 81 static void e1000g_m_ioctl(void *, queue_t *, mblk_t *); 1783 e1000g_m_ioctl(void *arg, queue_t *q, mblk_t *mp) in e1000g_m_ioctl()
|
/illumos-gate/usr/src/cmd/mdb/common/modules/sppp/ |
H A D | sppp.c | 85 queue_t upq; in sps_format() 270 sppp_qinfo(const queue_t *q, char *buf, size_t nbytes) in sppp_qinfo() 290 sppp_rnext(const queue_t *q) in sppp_rnext() 301 sppp_wnext(const queue_t *q) in sppp_wnext() 610 sppptun_qinfo(const queue_t *q, char *buf, size_t nbytes) in sppptun_qinfo() 625 sppptun_rnext(const queue_t *q) in sppptun_rnext() 641 sppptun_wnext(const queue_t *q) in sppptun_wnext()
|
/illumos-gate/usr/src/cmd/mdb/common/modules/ptm/ |
H A D | ptm.c | 77 queue_t *peerq, char *procname) in ptms_pr_qinfo() 177 ptms_qinfo(const queue_t *q, char *buf, size_t nbytes, int ismaster) in ptms_qinfo() 200 ptm_qinfo(const queue_t *q, char *buf, size_t nbytes) in ptm_qinfo() 206 pts_qinfo(const queue_t *q, char *buf, size_t nbytes) in pts_qinfo()
|