Home
last modified time | relevance | path

Searched refs:rq (Results 1 – 25 of 95) sorted by relevance

1234

/titanic_50/usr/src/uts/common/io/fibre-channel/fca/oce/
H A Doce_rx.c33 static int oce_rqb_ctor(oce_rq_bdesc_t *rqbd, struct oce_rq *rq,
36 static inline mblk_t *oce_rx(struct oce_dev *dev, struct oce_rq *rq,
39 struct oce_rq *rq, struct oce_nic_rx_cqe *cqe);
40 static int oce_rq_charge(struct oce_rq *rq, uint32_t nbufs, boolean_t repost);
43 static inline void oce_rx_drop_pkt(struct oce_rq *rq,
45 static oce_rq_bdesc_t *oce_rqb_alloc(struct oce_rq *rq);
46 static void oce_rqb_free(struct oce_rq *rq, oce_rq_bdesc_t *rqbd);
47 static void oce_rq_post_buffer(struct oce_rq *rq, int nbufs);
84 oce_rqb_cache_create(struct oce_rq *rq, size_t buf_size) in oce_rqb_cache_create() argument
92 rqbd = rq->rq_bdesc_array; in oce_rqb_cache_create()
[all …]
H A Doce_queue.c60 static void oce_rq_fini(struct oce_dev *dev, struct oce_rq *rq);
61 static int oce_rq_create(struct oce_rq *rq, uint32_t if_id, struct oce_eq *eq);
62 static void oce_rq_del(struct oce_dev *dev, struct oce_rq *rq);
699 struct oce_rq *rq; in oce_rq_init() local
709 rq = kmem_zalloc(sizeof (struct oce_rq), KM_NOSLEEP); in oce_rq_init()
710 if (rq == NULL) { in oce_rq_init()
716 rq->cfg.q_len = q_len; in oce_rq_init()
717 rq->cfg.frag_size = frag_size; in oce_rq_init()
718 rq->cfg.mtu = mtu; in oce_rq_init()
719 rq->cfg.eqd = 0; in oce_rq_init()
[all …]
/titanic_50/usr/src/uts/common/io/
H A Dclone.c59 int clnopen(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *crp);
163 clnopen(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *crp) in clnopen() argument
237 rinit = rq->q_qinfo; in clnopen()
238 winit = WR(rq)->q_qinfo; in clnopen()
239 ASSERT(rq->q_syncq->sq_type == (SQ_CI|SQ_CO)); in clnopen()
240 ASSERT((rq->q_flag & QMT_TYPEMASK) == QMTSAFE); in clnopen()
260 leavesq(rq->q_syncq, SQ_OPENCLOSE); in clnopen()
266 setq(rq, str->st_rdinit, str->st_wrinit, dmp, qflag, sqtype, B_FALSE); in clnopen()
275 entersq(rq->q_syncq, SQ_OPENCLOSE); in clnopen()
281 error = (*rq->q_qinfo->qi_qopen)(rq, &newdev, flag, CLONEOPEN, crp); in clnopen()
[all …]
H A Dbufmod.c201 sbopen(queue_t *rq, dev_t *dev, int oflag, int sflag, cred_t *crp) in sbopen() argument
204 ASSERT(rq); in sbopen()
209 if (rq->q_ptr) in sbopen()
216 sbp->sb_rq = rq; in sbopen()
228 rq->q_ptr = WR(rq)->q_ptr = sbp; in sbopen()
230 qprocson(rq); in sbopen()
238 sbclose(queue_t *rq, int flag, cred_t *credp) in sbclose() argument
240 struct sb *sbp = (struct sb *)rq->q_ptr; in sbclose()
244 qprocsoff(rq); in sbclose()
249 (void) quntimeout(rq, sbp->sb_timeoutid); in sbclose()
[all …]
H A Dpfmod.c169 pfopen(queue_t *rq, dev_t *dev, int oflag, int sflag, cred_t *crp) in pfopen() argument
173 ASSERT(rq); in pfopen()
178 if (rq->q_ptr) in pfopen()
185 rq->q_ptr = WR(rq)->q_ptr = (char *)pfp; in pfopen()
187 qprocson(rq); in pfopen()
193 pfclose(queue_t *rq) in pfclose() argument
195 struct epacketfilt *pfp = (struct epacketfilt *)rq->q_ptr; in pfclose()
199 qprocsoff(rq); in pfclose()
202 rq->q_ptr = WR(rq)->q_ptr = NULL; in pfclose()
235 pfrput(queue_t *rq, mblk_t *mp) in pfrput() argument
[all …]
/titanic_50/usr/src/lib/fm/libdiskstatus/common/
H A Dds_scsi_uscsi.c58 static void scsi_print_extended_sense(struct scsi_extended_sense *rq,
60 static void scsi_print_descr_sense(struct scsi_descr_sense_hdr *rq, int rqlen);
659 scsi_printerr(struct uscsi_cmd *ucmd, struct scsi_extended_sense *rq, int rqlen) in scsi_printerr() argument
662 struct scsi_descr_sense_hdr *sdsp = (struct scsi_descr_sense_hdr *)rq; in scsi_printerr()
665 if (find_string(sensekey_strings, rq->es_key) == NULL) in scsi_printerr()
676 switch (rq->es_code) { in scsi_printerr()
693 if (rq->es_valid) { in scsi_printerr()
694 blkno = (rq->es_info_1 << 24) | in scsi_printerr()
695 (rq->es_info_2 << 16) | in scsi_printerr()
696 (rq->es_info_3 << 8) | rq->es_info_4; in scsi_printerr()
[all …]
/titanic_50/usr/src/uts/common/io/softmac/
H A Dsoftmac_dev.c242 softmac_cmn_open(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *credp) in softmac_cmn_open() argument
249 if (rq->q_ptr != NULL) in softmac_cmn_open()
260 slp->sl_wq = WR(rq); in softmac_cmn_open()
264 rq->q_ptr = WR(rq)->q_ptr = slp; in softmac_cmn_open()
265 qprocson(rq); in softmac_cmn_open()
274 rq->q_qinfo = &softmac_dld_r_qinit; in softmac_cmn_open()
275 WR(rq)->q_qinfo = &softmac_dld_w_qinit; in softmac_cmn_open()
276 return (softmac_drv_open(rq, devp, flag, sflag, credp)); in softmac_cmn_open()
280 softmac_mod_close(queue_t *rq) in softmac_mod_close() argument
282 softmac_lower_t *slp = rq->q_ptr; in softmac_mod_close()
[all …]
H A Dsoftmac_ctl.c302 softmac_enqueue_notify_ind(queue_t *rq, mblk_t *mp) in softmac_enqueue_notify_ind() argument
304 softmac_lower_t *slp = rq->q_ptr; in softmac_enqueue_notify_ind()
347 softmac_rput_process_proto(queue_t *rq, mblk_t *mp) in softmac_rput_process_proto() argument
349 softmac_lower_t *slp = rq->q_ptr; in softmac_rput_process_proto()
404 softmac_enqueue_notify_ind(rq, mp); in softmac_rput_process_proto()
447 softmac_rput_process_notdata(queue_t *rq, softmac_upper_t *sup, mblk_t *mp) in softmac_rput_process_notdata() argument
449 softmac_lower_t *slp = rq->q_ptr; in softmac_rput_process_notdata()
461 softmac_rput_process_proto(rq, mp); in softmac_rput_process_notdata()
481 softmac_rput_process_proto(rq, mp); in softmac_rput_process_notdata()
498 softmac_rput_process_proto(rq, mp); in softmac_rput_process_notdata()
[all …]
/titanic_50/usr/src/uts/sun4u/opl/io/
H A Ddm2s.c112 int dm2s_open(queue_t *rq, dev_t *dev, int flag, int sflag, cred_t *cr);
113 int dm2s_close(queue_t *rq, int flag, cred_t *cred);
115 int dm2s_rsrv(queue_t *rq);
388 dm2s_open(queue_t *rq, dev_t *dev, int flag, int sflag, cred_t *cr) in dm2s_open() argument
401 if (rq->q_ptr != NULL) { in dm2s_open()
426 rq->q_ptr = WR(rq)->q_ptr = (void *)dm2sp; in dm2s_open()
427 dm2sp->ms_rq = rq; in dm2s_open()
428 dm2sp->ms_wq = WR(rq); in dm2s_open()
432 qprocson(rq); /* now schedule our queue */ in dm2s_open()
443 dm2s_close(queue_t *rq, int flag, cred_t *cred) in dm2s_close() argument
[all …]
/titanic_50/usr/src/cmd/format/
H A Dctlr_scsi.c1752 struct scsi_extended_sense *rq; local
1777 rq = (struct scsi_extended_sense *)ucmd.uscsi_rqbuf;
1787 rq->es_key == KEY_ILLEGAL_REQUEST &&
1788 rq->es_add_code == INVALID_OPCODE) {
1988 struct scsi_extended_sense *rq; local
2132 rq = (struct scsi_extended_sense *)ucmd->uscsi_rqbuf;
2134 if ((((int)rq->es_add_len) + 8) < MIN_REQUEST_SENSE_LEN ||
2135 rq->es_class != CLASS_EXTENDED_SENSE ||
2161 if (rq->es_key == KEY_RECOVERABLE_ERROR &&
2162 rq->es_add_code == ROUNDED_PARAMETER &&
[all …]
/titanic_50/usr/src/cmd/spell/
H A Dhuff.c186 double rc, rq; in huff() local
188 for (i = 0, q = 1, rq = r; i < QW; i++, q *= 2, rq *= rq) in huff()
190 rq /= r; /* rq = r^(q-1) */ in huff()
191 (void) qlog(rq, 1./q, 1L, rq); in huff()
/titanic_50/usr/src/cmd/troff/
H A Dn3.c100 contab[oldmn].rq = j; in casern()
113 if (rp->rq == 0)
115 hp = &mhash[MHASH(rp->rq)];
129 if (mp->rq == 0)
131 lp = &mhash[MHASH(mp->rq)];
157 if (p->rq == 0) in mrehash()
159 i = MHASH(p->rq); in mrehash()
234 if (contab[newmn].rq) in casede()
236 contab[newmn].rq = i; in casede()
261 if (i == p->rq)
[all …]
/titanic_50/usr/src/uts/common/io/audio/impl/
H A Daudio_ddi.c193 audio_stropen(queue_t *rq, dev_t *devp, int oflag, int sflag, cred_t *credp) in audio_stropen() argument
220 rq->q_ptr = WR(rq)->q_ptr = c; in audio_stropen()
224 c->c_rq = rq; in audio_stropen()
225 c->c_wq = WR(rq); in audio_stropen()
243 qprocson(rq); in audio_stropen()
254 audio_strclose(queue_t *rq, int flag, cred_t *credp) in audio_strclose() argument
263 if ((c = rq->q_ptr) == NULL) { in audio_strclose()
285 qprocsoff(rq); in audio_strclose()
452 audio_rsrv(queue_t *rq) in audio_rsrv() argument
456 c = rq->q_ptr; in audio_rsrv()
[all …]
/titanic_50/usr/src/lib/libnsl/rpc/
H A Dsvid_funcs.c83 clnt_control(CLIENT *cl, uint_t rq, char *in) in clnt_control() argument
85 return ((*(cl)->cl_ops->cl_control)(cl, rq, in)); in clnt_control()
107 svc_control(SVCXPRT *xprt, const uint_t rq, void *in) in svc_control() argument
109 switch (rq) { in svc_control()
120 return ((*(xprt)->xp_ops->xp_control)(xprt, rq, in)); in svc_control()
/titanic_50/usr/src/cmd/mdb/common/modules/nsmb/
H A Dnsmb.c390 smb_rq_t rq; in rqlist_walk_step() local
396 if (mdb_vread(&rq, sizeof (rq), wsp->walk_addr) == -1) { in rqlist_walk_step()
401 status = wsp->walk_callback(wsp->walk_addr, &rq, in rqlist_walk_step()
404 wsp->walk_addr = (uintptr_t)rq.sr_link.tqe_next; in rqlist_walk_step()
417 const smb_rq_t *rq = data; in rqlist_cb() local
426 mdb_printf(" x%04x", rq->sr_mid); in rqlist_cb()
427 mdb_printf(" x%02x", rq->sr_cmd); in rqlist_cb()
428 mdb_printf(" %d", rq->sr_state); in rqlist_cb()
429 mdb_printf(" x%x", rq->sr_flags); in rqlist_cb()
/titanic_50/usr/src/uts/common/io/dld/
H A Ddld_str.c272 dld_str_open(queue_t *rq, dev_t *devp, void *private) in dld_str_open() argument
287 dsp = dld_str_create(rq, DLD_DLPI, major, in dld_str_open()
303 (void) qassociate(rq, -1); in dld_str_open()
309 qprocson(rq); in dld_str_open()
323 dld_str_close(queue_t *rq) in dld_str_close() argument
325 dld_str_t *dsp = rq->q_ptr; in dld_str_close()
364 dld_open(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *credp) in dld_open() argument
373 if (rq->q_ptr != NULL) in dld_open()
376 return (dld_str_open(rq, devp, NULL)); in dld_open()
383 dld_close(queue_t *rq) in dld_close() argument
[all …]
/titanic_50/usr/src/lib/storage/libg_fc/common/
H A Dgenf.c786 g_scsi_printerr(struct uscsi_cmd *ucmd, struct scsi_extended_sense *rq, in g_scsi_printerr() argument
791 switch (rq->es_key) { in g_scsi_printerr()
860 if (rq->es_valid) { in g_scsi_printerr()
861 blkno = (rq->es_info_1 << 24) | (rq->es_info_2 << 16) | in g_scsi_printerr()
862 (rq->es_info_3 << 8) | rq->es_info_4; in g_scsi_printerr()
869 if (rq->es_add_len >= 6) { in g_scsi_printerr()
872 rq->es_add_code, rq->es_qual_code); in g_scsi_printerr()
878 if (rq->es_key == KEY_ILLEGAL_REQUEST) { in g_scsi_printerr()
886 (uchar_t *)rq, 8 + rq->es_add_len, HEX_ONLY, in g_scsi_printerr()
/titanic_50/usr/src/uts/common/os/
H A Dstrsubr.c1123 queue_t *rq; in qattach() local
1131 rq = allocq(); in qattach()
1132 wrq = _WR(rq); in qattach()
1133 STREAM(rq) = STREAM(wrq) = STREAM(qp); in qattach()
1147 rq->q_fp = fp; in qattach()
1173 setq(rq, str->st_rdinit, str->st_wrinit, dmp, qflag, sqtype, B_FALSE); in qattach()
1189 rq->q_flag |= _QINSERTING; in qattach()
1190 rq->q_next = qp; in qattach()
1197 entersq(rq->q_syncq, SQ_OPENCLOSE); in qattach()
1198 error = (*rq->q_qinfo->qi_qopen)(rq, devp, oflag, sflag, crp); in qattach()
[all …]
/titanic_50/usr/src/lib/libbc/inc/include/rpc/
H A Dclnt.h180 #define CLNT_CONTROL(cl, rq, in) ((*(cl)->cl_ops->cl_control)(cl, rq, in)) argument
181 #define clnt_control(cl, rq, in) ((*(cl)->cl_ops->cl_control)(cl, rq, in)) argument
/titanic_50/usr/src/uts/common/io/usb/clients/usbser/
H A Dusbser.c473 usbser_open(queue_t *rq, dev_t *dev, int flag, int sflag, cred_t *cr, in usbser_open() argument
513 rval = usbser_open_setup(rq, pp, minor, flag, cr); in usbser_open()
534 usbser_close(queue_t *rq, int flag, cred_t *cr) in usbser_close() argument
536 usbser_port_t *pp = (usbser_port_t *)rq->q_ptr; in usbser_close()
1080 queue_t *rq; in usbser_disconnect_ports() local
1101 rq = pp->port_ttycommon.t_readq; in usbser_disconnect_ports()
1125 (void) putnextctl(rq, M_HANGUP); in usbser_disconnect_ports()
1289 queue_t *rq; in usbser_restore_ports_state() local
1313 rq = pp->port_ttycommon.t_readq; in usbser_restore_ports_state()
1316 (void) putnextctl(rq, M_UNHANGUP); in usbser_restore_ports_state()
[all …]
/titanic_50/usr/src/uts/sun/io/ttymux/
H A Dttymux.c1451 sm_uriocack(queue_t *rq, mblk_t *mp) in sm_uriocack() argument
1453 sm_uqi_t *uqi = (sm_uqi_t *)rq->q_ptr; in sm_uriocack()
1539 putnext(rq, mp); in sm_uriocack()
2111 sm_open(queue_t *rq, dev_t *devp, int flag, int sflag, cred_t *credp) in sm_open() argument
2135 rq, *devp, flag, unit, protocol, uqi)); in sm_open()
2239 SM_RQ(uqi) = rq; in sm_open()
2240 SM_WQ(uqi) = WR(rq); in sm_open()
2242 if (rq->q_ptr == 0) { in sm_open()
2246 rq->q_ptr = WR(rq)->q_ptr = uqi; in sm_open()
2247 SM_RQ(uqi) = rq; in sm_open()
[all …]
/titanic_50/usr/src/uts/common/fs/smbclnt/smbfs/
H A Dsmbfs_smb.c104 struct smb_rq rq, *rqp = &rq; in smbfs_smb_lockandx() local
535 struct smb_rq rq, *rqp = &rq; in smbfs_smb_statfsLM1() local
692 struct smb_rq rq, *rqp = &rq; in smbfs_smb_flush() local
732 struct smb_rq rq, *rqp = &rq; in smbfs_smb_setfsize() local
785 struct smb_rq rq, *rqp = &rq; in smbfs_smb_query_info() local
846 struct smb_rq rq, *rqp = &rq; in smbfs_smb_setpattr1() local
971 struct smb_rq rq, *rqp = &rq; in smbfs_smb_setftime1() local
1203 struct smb_rq rq, *rqp = &rq; in smbfs_smb_oldopen() local
1448 struct smb_rq rq, *rqp = &rq; in smbfs_smb_oldcreate() local
1542 struct smb_rq rq, *rqp = &rq; in smbfs_smb_delete() local
[all …]
/titanic_50/usr/src/cmd/luxadm/
H A Dlux_util.c71 struct scsi_extended_sense *rq, int rqlen,
283 scsi_printerr(struct uscsi_cmd *ucmd, struct scsi_extended_sense *rq, in scsi_printerr() argument
288 switch (rq->es_key) { in scsi_printerr()
355 if (rq->es_valid) { in scsi_printerr()
356 blkno = (rq->es_info_1 << 24) | (rq->es_info_2 << 16) | in scsi_printerr()
357 (rq->es_info_3 << 8) | rq->es_info_4; in scsi_printerr()
364 if (rq->es_add_len >= 6) { in scsi_printerr()
368 rq->es_add_code, rq->es_qual_code); in scsi_printerr()
374 if (rq->es_key == KEY_ILLEGAL_REQUEST) { in scsi_printerr()
382 (uchar_t *)rq, 8 + rq->es_add_len, HEX_ONLY, msg_string); in scsi_printerr()
/titanic_50/usr/src/uts/common/sys/fibre-channel/fca/oce/
H A Doce_buf.h92 struct oce_rq *rq; member
174 int oce_rqb_cache_create(struct oce_rq *rq, size_t buf_size);
175 void oce_rqb_cache_destroy(struct oce_rq *rq);
/titanic_50/usr/src/cmd/mandoc/
H A Dpredefs.in40 PREDEF("Rq", "\\(rq")
61 PREDEF("rq", "\\(rq")

1234