Home
last modified time | relevance | path

Searched refs:queue_t (Results 1 – 25 of 346) sorted by last modified time

12345678910>>...14

/illumos-gate/usr/src/uts/common/rpc/
H A Dclnt_clts.c124 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 Dclnt_cots.c222 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 Dtcp_impl.h680 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 Dkeysock.h109 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 Dtcp.h526 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 Dipclassifier.h149 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 Dip.h1610 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 Dtcp_output.c59 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 Dtcp_stats.c144 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 Dtcp_input.c2096 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 Dtcp_opt_data.c50 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 Dtcp.c290 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 Dtcp_fusion.c175 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 Dkeysock.c151 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 Dip.c676 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 Dip_mroute.c415 mrt_ioctl(ipif_t *ipif, sin_t *sin, queue_t *q, mblk_t *mp, in mrt_ioctl()
H A Dip_helper_stream.c43 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 Dip.c1664 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 Dsocktpi.c469 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 Dsockcommon_subr.c2266 queue_t *q; in so_tpi_fallback()
/illumos-gate/usr/src/uts/common/sys/
H A Dtem_impl.h200 queue_t *tvs_queue; /* read queue for console */
/illumos-gate/usr/src/uts/common/io/
H A Dtem.c281 tem_init(cred_t *credp, queue_t *rq) in tem_init()
/illumos-gate/usr/src/uts/common/io/e1000g/
H A De1000g_main.c81 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 Dsppp.c85 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 Dptm.c77 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()

12345678910>>...14