Home
last modified time | relevance | path

Searched refs:queue_t (Results 1 – 25 of 346) sorted by relevance

12345678910>>...14

/illumos-gate/usr/src/uts/sun4u/opl/sys/oplmsu/
H A Doplmsu_proto.h41 int oplmsu_open(queue_t *, dev_t *, int, int, cred_t *);
42 int oplmsu_close(queue_t *, int, cred_t *);
43 int oplmsu_uwput(queue_t *, mblk_t *);
44 int oplmsu_uwsrv(queue_t *);
45 int oplmsu_lwsrv(queue_t *);
46 int oplmsu_lrput(queue_t *, mblk_t *);
47 int oplmsu_lrsrv(queue_t *);
48 int oplmsu_ursrv(queue_t *);
71 int oplmsu_uwioctl_iplink(queue_t *, mblk_t *);
72 int oplmsu_uwioctl_ipunlink(queue_t *, mblk_t *);
[all …]
H A Doplmsu.h224 queue_t *hndl_uqueue;
225 queue_t *lower_queue;
226 queue_t *uwq_queue;
247 queue_t *queue;
248 queue_t *lrq_queue;
249 queue_t *wait_queue;
270 queue_t *lower_queue;
289 queue_t *q;
304 queue_t *q;
/illumos-gate/usr/src/uts/common/inet/
H A Dip_if.h182 extern int ill_dl_phys(ill_t *, ipif_t *, mblk_t *, queue_t *);
190 extern int ill_init(queue_t *, ill_t *);
212 extern boolean_t ill_down_start(queue_t *, mblk_t *);
225 extern int ill_up_ipifs(ill_t *, queue_t *, mblk_t *);
268 extern void ipif_all_down_tail(ipsq_t *, queue_t *, mblk_t *, void *);
270 extern int ipif_down(ipif_t *, queue_t *, mblk_t *);
294 extern int ipif_up(ipif_t *, queue_t *, mblk_t *);
299 extern void ipsq_enq(ipsq_t *, queue_t *, mblk_t *, ipsq_func_t, int,
302 extern ipsq_t *ipsq_try_enter(ipif_t *, ill_t *, queue_t *, mblk_t *,
307 extern boolean_t ipsq_pending_mp_add(conn_t *, ipif_t *, queue_t *,
[all …]
H A Dnd.h44 typedef int (*ndgetf_t)(queue_t *, MBLKP, caddr_t, cred_t *);
45 typedef int (*ndsetf_t)(queue_t *, MBLKP, char *, caddr_t, cred_t *);
74 extern int nd_getset(queue_t *, caddr_t, MBLKP);
79 extern int nd_get_default(queue_t *, MBLKP, caddr_t, cred_t *);
80 extern int nd_get_long(queue_t *, MBLKP, caddr_t, cred_t *);
81 extern int nd_get_names(queue_t *, MBLKP, caddr_t, cred_t *);
82 extern int nd_set_default(queue_t *, MBLKP, char *, caddr_t, cred_t *);
83 extern int nd_set_long(queue_t *, MBLKP, char *, caddr_t, cred_t *);
H A Dproto_set.h38 extern boolean_t proto_set_rx_hiwat(queue_t *, struct conn_s *, size_t);
39 extern boolean_t proto_set_rx_lowat(queue_t *, struct conn_s *, size_t);
40 extern boolean_t proto_set_maxpsz(queue_t *, struct conn_s *, size_t);
41 extern boolean_t proto_set_tx_maxblk(queue_t *, struct conn_s *,
43 extern boolean_t proto_set_tx_copyopt(queue_t *, struct conn_s *, int);
44 extern boolean_t proto_set_tx_wroff(queue_t *, struct conn_s *, size_t);
H A Dmi.h85 extern int mi_close_comm(void **mi_head, queue_t *q);
89 extern void mi_copyin(queue_t *q, MBLKP mp, char *uaddr, size_t len);
90 extern void mi_copyin_n(queue_t *q, MBLKP mp, size_t offset, size_t len);
91 extern void mi_copyout(queue_t *q, MBLKP mp);
92 extern MBLKP mi_copyout_alloc(queue_t *q, MBLKP mp, char *uaddr, size_t len,
94 extern void mi_copy_done(queue_t *q, MBLKP mp, int err);
95 extern int mi_copy_state(queue_t *q, MBLKP mp, MBLKP *mpp);
112 extern int mi_open_comm(void **mi_head, size_t size, queue_t *q,
129 extern int mi_strlog(queue_t *q, char level, ushort_t flags,
135 extern void mi_timer(queue_t *q, MBLKP mp, clock_t tim);
[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,
/illumos-gate/usr/src/uts/common/sys/
H A Dstream.h158 } queue_t; typedef
268 typedef int (*qi_putp_t)(queue_t *, mblk_t *);
269 typedef int (*qi_srvp_t)(queue_t *);
270 typedef int (*qi_qopen_t)(queue_t *, dev_t *, int, int, cred_t *);
271 typedef int (*qi_qclose_t)(queue_t *, int, cred_t *);
273 typedef int (*qi_rwp_t)(queue_t *, struiod_t *);
274 typedef int (*qi_infop_t)(queue_t *, infod_t *);
310 queue_t *l_qtop; /* lowest level write queue of upper stream */
312 queue_t *l_qbot; /* highest level write queue of lower stream */
395 queue_t *b_queue; /* for sync queues */
[all …]
H A Dstrsubr.h469 queue_t *sq_head; /* queue of deferred messages */
470 queue_t *sq_tail; /* queue of deferred messages */
1105 extern int qattach(queue_t *, dev_t *, int, cred_t *, fmodsw_impl_t *,
1107 extern int qreopen(queue_t *, dev_t *, int, cred_t *);
1108 extern void qdetach(queue_t *, int, int, cred_t *, boolean_t);
1109 extern void enterq(queue_t *);
1110 extern void leaveq(queue_t *);
1113 extern struct linkinfo *alloclink(queue_t *, queue_t *, struct file *);
1117 extern queue_t *getendq(queue_t *);
1127 extern void setq(queue_t *, struct qinit *, struct qinit *, perdm_t *,
[all …]
H A Dlog.h64 queue_t *log_q; /* message queue */
97 extern queue_t *log_consq; /* primary console reader queue */
98 extern queue_t *log_backlogq; /* console backlog queue */
99 extern queue_t *log_intrq; /* pending high-level interrupt message queue */
108 extern void log_update(log_t *, queue_t *, short, log_filter_t);
112 extern void log_flushq(queue_t *);
113 extern void log_printq(queue_t *);
H A Dvt_impl.h77 queue_t *vc_wq; /* write queue */
111 void vt_ioctl(queue_t *q, mblk_t *mp);
112 void vt_miocdata(queue_t *qp, mblk_t *mp);
113 void vt_clean(queue_t *q, vc_state_t *pvc);
114 void vt_close(queue_t *q, vc_state_t *pvc, cred_t *crp);
115 int vt_open(minor_t minor, queue_t *rq, cred_t *crp);
/illumos-gate/usr/src/cmd/mdb/common/mdb/
H A Dmdb_ks.h117 void (*q_info)(const queue_t *, char *, size_t);
118 uintptr_t (*q_rnext)(const queue_t *);
119 uintptr_t (*q_wnext)(const queue_t *);
125 extern char *mdb_qname(const queue_t *, char *, size_t);
126 extern void mdb_qinfo(const queue_t *, char *, size_t);
128 extern uintptr_t mdb_qrnext(const queue_t *);
129 extern uintptr_t mdb_qwnext(const queue_t *);
136 extern uintptr_t mdb_qrnext_default(const queue_t *);
137 extern uintptr_t mdb_qwnext_default(const queue_t *);
/illumos-gate/usr/src/uts/common/rpc/
H A Drpcmod.c208 int rmm_open(queue_t *, dev_t *, int, int, cred_t *);
209 int rmm_close(queue_t *, int, cred_t *);
215 int rmm_rput(queue_t *, mblk_t *);
216 int rmm_wput(queue_t *, mblk_t *);
217 int rmm_rsrv(queue_t *);
218 int rmm_wsrv(queue_t *);
220 int rpcmodopen(queue_t *, dev_t *, int, int, cred_t *);
221 int rpcmodclose(queue_t *, int, cred_t *);
222 void rpcmodrput(queue_t *, mblk_t *);
223 void rpcmodwput(queue_t *, mblk_t *);
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Dstrredirm.c54 static int wcmopen(queue_t *, dev_t *, int, int, cred_t *);
55 static int wcmclose(queue_t *, int, cred_t *);
56 static int wcmrput(queue_t *, mblk_t *);
57 static int wcmwput(queue_t *, mblk_t *);
131 wcmopen(queue_t *q, dev_t *dev, int flag, int sflag, cred_t *cred) in wcmopen()
141 wcmclose(queue_t *q, int flag, cred_t *cred) in wcmclose()
153 wcmrput(queue_t *q, mblk_t *mp) in wcmrput()
163 wcmwput(queue_t *q, mblk_t *mp) in wcmwput()
H A Dtirdwr.c58 queue_t *trw_rdq;
65 static int tirdwropen(queue_t *q, dev_t *dev,
68 static int tirdwrclose(queue_t *q, int flag, cred_t *cr);
70 static int check_strhead(queue_t *q);
76 static int tirdwrrput(queue_t *q, mblk_t *mp);
77 static int tirdwrwput(queue_t *q, mblk_t *mp);
147 static void send_fatal(queue_t *q, mblk_t *mp);
148 static void strip_strhead(queue_t *q);
158 queue_t *q, in tirdwropen()
207 tirdwrclose(queue_t *q, int flag, cred_t *cr) in tirdwrclose()
[all …]
H A Dlogindmux.c86 static int logdmuxopen(queue_t *, dev_t *, int, int, cred_t *);
87 static int logdmuxclose(queue_t *, int, cred_t *);
88 static int logdmuxursrv(queue_t *);
89 static int logdmuxuwput(queue_t *, mblk_t *);
90 static int logdmuxlrput(queue_t *, mblk_t *);
91 static int logdmuxlrsrv(queue_t *);
92 static int logdmuxlwsrv(queue_t *);
93 static int logdmuxuwsrv(queue_t *);
96 static void logdmuxlink(queue_t *, mblk_t *);
97 static void logdmuxunlink(queue_t *, mblk_t *);
[all …]
H A Dpckt.c98 static int pcktopen(queue_t *, dev_t *, int, int, cred_t *);
99 static int pcktclose(queue_t *, int, cred_t *);
100 static int pcktrput(queue_t *, mblk_t *);
101 static int pcktrsrv(queue_t *);
102 static int pcktwput(queue_t *, mblk_t *);
103 static mblk_t *add_ctl_info(queue_t *, mblk_t *);
176 queue_t *pi_qptr; /* back pointer to q */
204 queue_t *q, /* pointer to the read side queue */ in pcktopen()
286 queue_t *q, /* Pointer to the read queue */ in pcktclose()
316 queue_t *q, /* Pointer to the read queue */ in pcktrput()
[all …]
/illumos-gate/usr/src/uts/common/inet/ip/
H A Dip_dummy.c40 static int dummy_wput(queue_t *, mblk_t *);
41 static int dummy_modclose(queue_t *, int, cred_t *);
42 static int dummy_modopen(queue_t *q, dev_t *devp, int flag,
70 dummy_wput(queue_t *q, mblk_t *m) in dummy_wput()
77 dummy_modclose(queue_t *q, int flags __unused, cred_t *credp __unused) in dummy_modclose()
85 dummy_modopen(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *credp) in dummy_modopen()
/illumos-gate/usr/src/uts/common/os/
H A Dddi.c253 queue_t *
254 OTHERQ(queue_t *q) in OTHERQ()
262 queue_t *
263 RD(queue_t *q) in RD()
273 SAMESTR(queue_t *q) in SAMESTR()
281 queue_t *
282 WR(queue_t *q) in WR()
481 bcanputnext(queue_t *q, unsigned char band) in bcanputnext()
492 canputnext(queue_t *q) in canputnext()
494 queue_t *qofsq = q; in canputnext()
[all …]
/illumos-gate/usr/src/uts/common/io/ppp/sppp/
H A Dsppp.h177 queue_t *sps_rq; /* pointer to the read queue */
282 queue_t *ppa_lower_wq; /* pointer to lower write queue */
362 extern int sppp_close(queue_t *, int, cred_t *);
366 extern int sppp_lrput(queue_t *, mblk_t *);
367 extern int sppp_lrsrv(queue_t *);
368 extern int sppp_lwsrv(queue_t *);
369 extern int sppp_mproto(queue_t *, mblk_t *, spppstr_t *);
370 extern int sppp_open(queue_t *, dev_t *, int, int, cred_t *);
371 extern int sppp_uwput(queue_t *, mblk_t *);
372 extern int sppp_uwsrv(queue_t *);
/illumos-gate/usr/src/uts/common/sys/usb/clients/usbser/
H A Dusbser.h49 int usbser_open(queue_t *, dev_t *, int, int, cred_t *, void *);
50 int usbser_close(queue_t *, int, cred_t *);
51 int usbser_wput(queue_t *, mblk_t *);
52 int usbser_wsrv(queue_t *);
53 int usbser_rsrv(queue_t *);
/illumos-gate/usr/src/uts/common/io/softmac/
H A Dsoftmac_dev.c45 static int softmac_cmn_open(queue_t *, dev_t *, int, int, cred_t *);
51 static int softmac_mod_close(queue_t *, int, cred_t *);
52 static int softmac_mod_rput(queue_t *, mblk_t *);
53 static int softmac_mod_wput(queue_t *, mblk_t *);
54 static int softmac_mod_wsrv(queue_t *);
60 static int softmac_drv_open(queue_t *, dev_t *, int, int, cred_t *);
61 static int softmac_drv_close(queue_t *, int, cred_t *);
62 static int softmac_drv_wput(queue_t *, mblk_t *);
63 static int softmac_drv_wsrv(queue_t *);
246 softmac_cmn_open(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *credp) in softmac_cmn_open()
[all …]
/illumos-gate/usr/src/uts/common/io/nxge/
H A Dnxge_ndd.c83 int nxge_param_set_mac(p_nxge_t, queue_t *,
85 static int nxge_param_set_port_rdc(p_nxge_t, queue_t *,
87 static int nxge_param_set_grp_rdc(p_nxge_t, queue_t *,
90 queue_t *, mblk_t *, char *, caddr_t);
92 queue_t *, mblk_t *, char *, caddr_t);
94 queue_t *, mblk_t *, char *, caddr_t);
96 queue_t *, mblk_t *, char *, caddr_t);
98 queue_t *, mblk_t *, char *, caddr_t);
99 static int nxge_param_llc_snap_enable(p_nxge_t, queue_t *,
101 static int nxge_param_hash_lookup_enable(p_nxge_t, queue_t *,
[all …]
/illumos-gate/usr/src/uts/common/io/vuidmice/
H A Dvuidmice.c51 static int vuidmice_open(queue_t *, dev_t *, int, int, cred_t *);
52 static int vuidmice_close(queue_t *, int, cred_t *);
53 static int vuidmice_rput(queue_t *, mblk_t *);
54 static int vuidmice_rsrv(queue_t *);
55 static int vuidmice_wput(queue_t *, mblk_t *);
56 static void vuidmice_miocdata(queue_t *, mblk_t *);
57 static int vuidmice_handle_wheel_resolution_ioctl(queue_t *, mblk_t *, int);
60 static int vuidmice_service_wheel_state(queue_t *, mblk_t *, uint_t);
62 void VUID_QUEUE(queue_t *const, mblk_t *);
63 int VUID_OPEN(queue_t *const);
[all …]
/illumos-gate/usr/src/cmd/mdb/common/modules/genunix/
H A Dstreams.c62 typedef void qprint_func(queue_t *, queue_t *);
361 queue_t q; in queue()
733 qprint_syncq(queue_t *addr, queue_t *q) in qprint_syncq()
740 qprint_stream(queue_t *addr, queue_t *q) in qprint_stream()
746 qprint_wrq(queue_t *addr, queue_t *q) in qprint_wrq()
752 qprint_rdq(queue_t *addr, queue_t *q) in qprint_rdq()
758 qprint_otherq(queue_t *addr, queue_t *q) in qprint_otherq()
766 queue_t q; in q2x()
776 prfunc((queue_t *)addr, &q); in q2x()
869 queue_t q; in syncq2q()
[all …]

12345678910>>...14