Home
last modified time | relevance | path

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

12345678910>>...15

/titanic_44/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;
/titanic_44/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.h46 typedef int (*ndgetf_t)(queue_t *, MBLKP, caddr_t, cred_t *);
47 typedef int (*ndsetf_t)(queue_t *, MBLKP, char *, caddr_t, cred_t *);
76 extern int nd_getset(queue_t *, caddr_t, MBLKP);
81 extern int nd_get_default(queue_t *, MBLKP, caddr_t, cred_t *);
82 extern int nd_get_long(queue_t *, MBLKP, caddr_t, cred_t *);
83 extern int nd_get_names(queue_t *, MBLKP, caddr_t, cred_t *);
84 extern int nd_set_default(queue_t *, MBLKP, char *, caddr_t, cred_t *);
85 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.h33 extern int keysock_opt_get(queue_t *, int, int, uchar_t *);
34 extern int keysock_opt_set(queue_t *, uint_t, int, int, uint_t,
108 queue_t *keysock_rq; /* Read queue - putnext() to userland */
109 queue_t *keysock_wq; /* Write queue */
141 queue_t *kc_rq; /* Read queue, requests from AH, ESP. */
142 queue_t *kc_wq; /* Write queue, putnext down */
/titanic_44/usr/src/uts/common/sys/
H A Dstream.h155 } queue_t; typedef
292 queue_t *l_qtop; /* lowest level write queue of upper stream */
294 queue_t *l_qbot; /* highest level write queue of lower stream */
377 queue_t *b_queue; /* for sync queues */
791 extern mblk_t *getq(queue_t *);
792 extern void rmvq(queue_t *, mblk_t *);
793 extern void flushq(queue_t *, int);
794 extern void flushq_common(queue_t *, int, int);
795 extern void flushband(queue_t *, unsigned char, int);
796 extern int canput(queue_t *);
[all …]
H A Dstrsubr.h451 queue_t *sq_head; /* queue of deferred messages */
452 queue_t *sq_tail; /* queue of deferred messages */
1087 extern int qattach(queue_t *, dev_t *, int, cred_t *, fmodsw_impl_t *,
1089 extern int qreopen(queue_t *, dev_t *, int, cred_t *);
1090 extern void qdetach(queue_t *, int, int, cred_t *, boolean_t);
1091 extern void enterq(queue_t *);
1092 extern void leaveq(queue_t *);
1095 extern struct linkinfo *alloclink(queue_t *, queue_t *, struct file *);
1099 extern queue_t *getendq(queue_t *);
1109 extern void setq(queue_t *, struct qinit *, struct qinit *, perdm_t *,
[all …]
H A Dlog.h66 queue_t *log_q; /* message queue */
99 extern queue_t *log_consq; /* primary console reader queue */
100 extern queue_t *log_backlogq; /* console backlog queue */
101 extern queue_t *log_intrq; /* pending high-level interrupt message queue */
110 extern void log_update(log_t *, queue_t *, short, log_filter_t);
114 extern void log_flushq(queue_t *);
115 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);
/titanic_44/usr/src/cmd/mdb/common/mdb/
H A Dmdb_ks.h113 void (*q_info)(const queue_t *, char *, size_t);
114 uintptr_t (*q_rnext)(const queue_t *);
115 uintptr_t (*q_wnext)(const queue_t *);
121 extern char *mdb_qname(const queue_t *, char *, size_t);
122 extern void mdb_qinfo(const queue_t *, char *, size_t);
124 extern uintptr_t mdb_qrnext(const queue_t *);
125 extern uintptr_t mdb_qwnext(const queue_t *);
132 extern uintptr_t mdb_qrnext_default(const queue_t *);
133 extern uintptr_t mdb_qwnext_default(const queue_t *);
/titanic_44/usr/src/uts/common/rpc/
H A Drpcmod.c206 int rmm_open(queue_t *, dev_t *, int, int, cred_t *);
207 int rmm_close(queue_t *, int, cred_t *);
213 void rmm_rput(queue_t *, mblk_t *);
214 void rmm_wput(queue_t *, mblk_t *);
215 void rmm_rsrv(queue_t *);
216 void rmm_wsrv(queue_t *);
218 int rpcmodopen(queue_t *, dev_t *, int, int, cred_t *);
219 int rpcmodclose(queue_t *, int, cred_t *);
220 void rpcmodrput(queue_t *, mblk_t *);
221 void rpcmodwput(queue_t *, mblk_t *);
[all …]
/titanic_44/usr/src/uts/common/fs/sockfs/
H A Dnl7cnca.c232 nl7c_uri_ttl_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) in nl7c_uri_ttl_get()
240 nl7c_uri_ttl_set(queue_t *q, mblk_t *mp, char *value, caddr_t nu, cred_t *cr) in nl7c_uri_ttl_set()
249 nca_logging_on_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) in nca_logging_on_get()
257 nca_logging_on_set(queue_t *q, mblk_t *mp, char *value, caddr_t nu, cred_t *cr) in nca_logging_on_set()
274 nca_version_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) in nca_version_get()
282 nca_httpd_version_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) in nca_httpd_version_get()
290 nca_logd_version_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) in nca_logd_version_get()
298 nca_httpd_door_inst_get(queue_t *q, mblk_t *mp, caddr_t nu, cred_t *cr) in nca_httpd_door_inst_get()
306 nca_param_get(queue_t *q, mblk_t *mp, caddr_t cp, cred_t *cr) in nca_param_get()
316 nca_param_set(queue_t *q, mblk_t *mp, char *value, caddr_t cp, cred_t *cr) in nca_param_set()
[all …]
/titanic_44/usr/src/uts/sun4u/starcat/io/
H A Dcvcredir.c56 extern int cvc_register(queue_t *);
57 extern int cvc_unregister(queue_t *);
62 static int cvcr_wput(queue_t *, mblk_t *);
63 static int cvcr_open(queue_t *, dev_t *, int, int, cred_t *);
64 static int cvcr_close(queue_t *, int, cred_t *);
65 static void cvcr_ioctl(queue_t *, mblk_t *);
206 cvcr_open(queue_t *q, dev_t *dev, int flag, int sflag, cred_t *cred) in cvcr_open()
223 cvcr_close(queue_t *q, int flag, cred_t *cred) in cvcr_close()
235 cvcr_wput(queue_t *q, mblk_t *mp) in cvcr_wput()
254 cvcr_ioctl(queue_t *q, mblk_t *mp) in cvcr_ioctl()
/titanic_44/usr/src/uts/sun4u/starfire/cvcredir/
H A Dcvcredir.c57 extern int cvc_register(queue_t *);
58 extern int cvc_unregister(queue_t *);
63 static int cvcr_wput(queue_t *, mblk_t *);
64 static int cvcr_open(queue_t *, dev_t *, int, int, cred_t *);
65 static int cvcr_close(queue_t *, int, cred_t *);
66 static void cvcr_ioctl(queue_t *, mblk_t *);
201 cvcr_open(queue_t *q, dev_t *dev, int flag, int sflag, cred_t *cred) in cvcr_open()
218 cvcr_close(queue_t *q, int flag, cred_t *cred) in cvcr_close()
230 cvcr_wput(queue_t *q, mblk_t *mp) in cvcr_wput()
249 cvcr_ioctl(queue_t *q, mblk_t *mp) in cvcr_ioctl()
/titanic_44/usr/src/uts/common/io/
H A Dtirdwr.c61 queue_t *trw_rdq;
68 static int tirdwropen(queue_t *q, dev_t *dev,
71 static int tirdwrclose(queue_t *q, int flag, cred_t *cr);
73 static int check_strhead(queue_t *q);
79 static void tirdwrrput(queue_t *q, mblk_t *mp);
80 static void tirdwrwput(queue_t *q, mblk_t *mp);
150 static void send_fatal(queue_t *q, mblk_t *mp);
151 static void strip_strhead(queue_t *q);
161 queue_t *q, in tirdwropen()
210 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.c100 static int pcktopen(queue_t *, dev_t *, int, int, cred_t *);
101 static int pcktclose(queue_t *, int, cred_t *);
102 static void pcktrput(queue_t *, mblk_t *);
103 static void pcktrsrv(queue_t *);
104 static void pcktwput(queue_t *, mblk_t *);
105 static mblk_t *add_ctl_info(queue_t *, mblk_t *);
178 queue_t *pi_qptr; /* back pointer to q */
206 queue_t *q, /* pointer to the read side queue */ in pcktopen()
289 queue_t *q, /* Pointer to the read queue */ in pcktclose()
319 queue_t *q, /* Pointer to the read queue */ in pcktrput()
[all …]
H A Dstrredirm.c56 static int wcmopen(queue_t *, dev_t *, int, int, cred_t *);
57 static int wcmclose(queue_t *, int, cred_t *);
58 static int wcmrput(queue_t *, mblk_t *);
132 wcmopen(queue_t *q, dev_t *dev, int flag, int sflag, cred_t *cred) in wcmopen()
142 wcmclose(queue_t *q, int flag, cred_t *cred) in wcmclose()
154 wcmrput(queue_t *q, mblk_t *mp) in wcmrput()
/titanic_44/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 *);
/titanic_44/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 …]
/titanic_44/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 *);
366 extern void sppp_lrput(queue_t *, mblk_t *);
367 extern void sppp_lrsrv(queue_t *);
368 extern void 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 void sppp_uwput(queue_t *, mblk_t *);
372 extern void sppp_uwsrv(queue_t *);
/titanic_44/usr/src/uts/common/io/softmac/
H A Dsoftmac_dev.c41 static int softmac_cmn_open(queue_t *, dev_t *, int, int, cred_t *);
47 static int softmac_mod_close(queue_t *);
48 static void softmac_mod_rput(queue_t *, mblk_t *);
49 static void softmac_mod_wput(queue_t *, mblk_t *);
50 static void softmac_mod_wsrv(queue_t *);
56 static int softmac_drv_open(queue_t *, dev_t *, int, int, cred_t *);
57 static int softmac_drv_close(queue_t *);
58 static void softmac_drv_wput(queue_t *, mblk_t *);
59 static void softmac_drv_wsrv(queue_t *);
242 softmac_cmn_open(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *credp) in softmac_cmn_open()
[all …]
/titanic_44/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 …]

12345678910>>...15