Home
last modified time | relevance | path

Searched refs:rqp (Results 1 – 23 of 23) sorted by relevance

/illumos-gate/usr/src/uts/common/fs/smbclnt/netsmb/
H A Dsmb2_rq.c71 if (rqp->sr2_nextcmd != 0) { in smb2_rq_fillhdr()
93 m = dupb(rqp->sr_rq.mb_top); in smb2_rq_fillhdr()
132 rqp->sr_state = SMBRQ_NOTSENT; in smb2_rq_simple_timed()
134 error = smb2_rq_enqueue(rqp); in smb2_rq_simple_timed()
136 error = smb2_rq_reply(rqp); in smb2_rq_simple_timed()
195 error = smb2_iod_addrq(rqp); in smb2_rq_enqueue()
224 error = smb2_iod_addrq(rqp); in smb2_rq_internal()
233 smb_iod_removerq(rqp); in smb2_rq_internal()
273 smb_iod_removerq(rqp); in smb2_rq_reply()
277 error = smb_iod_waitrq(rqp); in smb2_rq_reply()
[all …]
H A Dsmb_rq.c102 kmem_free(rqp, sizeof (*rqp)); in smb_rq_done()
109 struct smb_rq *rqp; in smb_rq_alloc() local
113 if (rqp == NULL) in smb_rq_alloc()
117 smb_rq_done(rqp); in smb_rq_alloc()
121 *rqpp = rqp; in smb_rq_alloc()
131 bzero(rqp, sizeof (*rqp)); in smb_rq_init()
135 error = smb_rq_getenv(co, &rqp->sr_vc, &rqp->sr_share); in smb_rq_init()
287 SMBRQ_LOCK(rqp); in smb_rq_simple_timed()
289 (void) cv_reltimedwait(&rqp->sr_cond, &(rqp)->sr_lock, in smb_rq_simple_timed()
434 rqp->sr_wcount = mb_reserve(&rqp->sr_rq, sizeof (uint8_t)); in smb_rq_wstart()
[all …]
H A Dsmb_iod.c140 rqp->sr_rpgen++; in smb_iod_rqprocessed_LH()
152 SMBRQ_LOCK(rqp); in smb_iod_rqprocessed()
154 SMBRQ_UNLOCK(rqp); in smb_iod_rqprocessed()
259 SMBRQ_LOCK(rqp); in smb1_iod_sendrq()
368 SMBRQ_LOCK(rqp); in smb2_iod_sendrq()
699 rqp = NULL; in smb1_iod_process()
851 rqp = NULL; in smb2_iod_process()
1047 rqp->sr2_totalcreditcharge = rqp->sr2_creditcharge; in smb2_iod_addrq()
1267 if (tmo1 && rqp->sr_rpgen == rqp->sr_rplast) { in smb_iod_waitrq()
1287 while (rqp->sr_rpgen == rqp->sr_rplast) { in smb_iod_waitrq()
[all …]
H A Dsmb_smb.c165 smb_rq_wend(rqp); in smb_smb_negotiate()
173 smb_rq_bend(rqp); in smb_smb_negotiate()
186 smb_rq_done(rqp); in smb_smb_negotiate()
440 smb_rq_done(rqp); in smb_smb_negotiate()
444 smb_rq_done(rqp); in smb_smb_negotiate()
472 scred, &rqp); in smb_smb_ssnsetup()
502 smb_rq_bend(rqp); in smb_smb_ssnsetup()
574 if (rqp) in smb_smb_ssnsetup()
598 smb_rq_wend(rqp); in smb_smb_logoff()
600 smb_rq_bend(rqp); in smb_smb_logoff()
[all …]
H A Dsmb2_smb.c333 smb_rq_done(rqp); in smb2_smb_negotiate()
337 smb_rq_done(rqp); in smb2_smb_negotiate()
497 if (rqp) in smb2_smb_ssnsetup()
498 smb_rq_done(rqp); in smb2_smb_ssnsetup()
531 smb_rq_done(rqp); in smb2_smb_logoff()
681 smb_rq_done(rqp); in smb2_smb_treeconnect()
728 smb_rq_done(rqp); in smb2_smb_treedisconnect()
955 smb_rq_done(rqp); in smb2_smb_ntcreate()
993 smb_rq_done(rqp); in smb2_smb_close()
1118 smb_rq_done(rqp); in smb2_smb_ioctl()
[all …]
H A Dsmb_rq.h73 #define SMBRQ_LOCK(rqp) mutex_enter(&(rqp)->sr_lock) argument
74 #define SMBRQ_UNLOCK(rqp) mutex_exit(&(rqp)->sr_lock) argument
210 void smb_rq_done(struct smb_rq *rqp);
218 void smb_rq_fillhdr(struct smb_rq *rqp);
219 void smb_rq_wstart(struct smb_rq *rqp);
220 void smb_rq_wend(struct smb_rq *rqp);
221 void smb_rq_bstart(struct smb_rq *rqp);
222 void smb_rq_bend(struct smb_rq *rqp);
223 int smb_rq_simple(struct smb_rq *rqp);
225 int smb_rq_internal(struct smb_rq *rqp, int timeout);
[all …]
H A Dsmb2_rq.h37 int smb2_rq_parsehdr(struct smb_rq *rqp);
38 void smb2_rq_fillhdr(struct smb_rq *rqp);
40 int smb2_rq_simple(struct smb_rq *rqp);
41 int smb2_rq_simple_timed(struct smb_rq *rqp, int timeout);
42 int smb2_rq_internal(struct smb_rq *rqp, int timeout);
H A Dsmb_sign.c200 smb_rq_sign(struct smb_rq *rqp) in smb_rq_sign() argument
202 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_sign()
203 mblk_t *mp = rqp->sr_rq.mb_top; in smb_rq_sign()
228 status = smb_compute_MAC(vcp, mp, rqp->sr_seqno, sigloc); in smb_rq_sign()
239 smb_rq_verify(struct smb_rq *rqp) in smb_rq_verify() argument
241 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_verify()
242 mblk_t *mp = rqp->sr_rp.md_top; in smb_rq_verify()
271 rsn = rqp->sr_rseqno; in smb_rq_verify()
290 vcp->vc_srvname, rqp->sr_mid, rsn); in smb_rq_verify()
309 rqp->sr_mid, rsn, rsn + fudge); in smb_rq_verify()
H A Dsmb2_sign.c277 smb2_rq_sign(struct smb_rq *rqp) in smb2_rq_sign() argument
279 struct smb_vc *vcp = rqp->sr_vc; in smb2_rq_sign()
280 mblk_t *mp = rqp->sr_rq.mb_top; in smb2_rq_sign()
309 smb2_rq_verify(struct smb_rq *rqp) in smb2_rq_verify() argument
311 struct smb_vc *vcp = rqp->sr_vc; in smb2_rq_verify()
312 mblk_t *mp = rqp->sr_rp.md_top; in smb2_rq_verify()
360 vcp->vc_srvname, (long long)rqp->sr2_messageid); in smb2_rq_verify()
H A Dsmb_conn.h442 int smb2_iod_addrq(struct smb_rq *rqp);
443 int smb1_iod_addrq(struct smb_rq *rqp);
444 int smb1_iod_multirq(struct smb_rq *rqp);
445 int smb_iod_waitrq(struct smb_rq *rqp);
446 int smb_iod_waitrq_int(struct smb_rq *rqp);
447 void smb_iod_removerq(struct smb_rq *rqp);
H A Dsmb_subr.h153 int smb_put_string(struct smb_rq *rqp, const char *src);
154 int smb_put_asunistring(struct smb_rq *rqp, const char *src);
/illumos-gate/usr/src/lib/libsmbfs/smb/
H A Dnbns_rq.c259 nbns_rq_done(rqp); in nbns_resolvename()
363 nbns_rq_done(rqp); in nbns_getnodestatus()
376 rqp = malloc(sizeof (*rqp)); in nbns_rq_create()
377 if (rqp == NULL) in nbns_rq_create()
379 bzero(rqp, sizeof (*rqp)); in nbns_rq_create()
382 free(rqp); in nbns_rq_create()
388 *rqpp = rqp; in nbns_rq_create()
395 if (rqp == NULL) in nbns_rq_done()
401 if (rqp->nr_if) in nbns_rq_done()
403 free(rqp); in nbns_rq_done()
[all …]
/illumos-gate/usr/src/uts/common/fs/smbclnt/smbfs/
H A Dsmbfs_smb1.c92 smb_rq_wstart(rqp);
102 smb_rq_wend(rqp);
103 smb_rq_bstart(rqp);
115 smb_rq_bend(rqp);
127 smb_rq_done(rqp);
305 smb_rq_wend(rqp); in smbfs_smb1_flush()
307 smb_rq_bend(rqp); in smbfs_smb1_flush()
309 smb_rq_done(rqp); in smbfs_smb1_flush()
494 smb_rq_wend(rqp); in smbfs_smb1_oldrename()
515 smb_rq_bend(rqp); in smbfs_smb1_oldrename()
[all …]
H A Dsmbfs_smb2.c123 struct smb_rq *rqp = NULL; in smbfs_smb2_query_info() local
151 error = smb2_rq_simple(rqp); in smbfs_smb2_query_info()
161 smb_rq_getreply(rqp, &mdp); in smbfs_smb2_query_info()
196 smb_rq_done(rqp); in smbfs_smb2_query_info()
335 struct smb_rq *rqp; in smbfs_smb2_flush() local
356 smb_rq_done(rqp); in smbfs_smb2_flush()
370 struct smb_rq *rqp = NULL; in smbfs_smb2_set_info() local
414 smb_rq_done(rqp); in smbfs_smb2_set_info()
527 struct smb_rq *rqp; in smbfs_smb2_qdir() local
556 ctx->f_scred, &rqp); in smbfs_smb2_qdir()
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Dpts.c331 if (rqp->q_ptr != NULL) { in ptsopen()
385 WR(rqp)->q_ptr = rqp->q_ptr = ptsp; in ptsopen()
393 qprocson(rqp); in ptsopen()
403 ptsp->pts_rdq = rqp; in ptsopen()
419 putnext(rqp, mop); in ptsopen()
444 if (rqp->q_ptr == NULL) { in ptsclose()
445 qprocsoff(rqp); in ptsclose()
466 wqp = WR(rqp); in ptsclose()
493 qprocsoff(rqp); in ptsclose()
495 rqp->q_ptr = NULL; in ptsclose()
[all …]
H A Dzcons.c487 WR(rqp)->q_ptr = rqp->q_ptr = zcs; in zc_manager_open()
488 qprocson(rqp); in zc_manager_open()
512 putnext(rqp, mop); in zc_manager_open()
536 ASSERT((rqp != NULL) && (WR(rqp)->q_ptr == zcs)); in zc_subsidiary_open()
567 WR(rqp)->q_ptr = rqp->q_ptr = zcs; in zc_subsidiary_open()
569 qprocson(rqp); in zc_subsidiary_open()
654 qprocsoff(rqp); in zc_close()
655 WR(rqp)->q_ptr = rqp->q_ptr = NULL; in zc_close()
663 wqp = WR(rqp); in zc_close()
680 qprocsoff(rqp); in zc_close()
[all …]
H A Dptm.c328 if (rqp->q_ptr != NULL) in ptmopen()
368 WR(rqp)->q_ptr = rqp->q_ptr = ptmp; in ptmopen()
370 qprocson(rqp); in ptmopen()
374 ptmp->ptm_rdq = rqp; in ptmopen()
390 putnext(rqp, mop); in ptmopen()
410 ptmclose(queue_t *rqp, int flag, cred_t *credp) in ptmclose() argument
415 ASSERT(rqp->q_ptr); in ptmclose()
417 ptmp = (struct pt_ttys *)rqp->q_ptr; in ptmclose()
443 qprocsoff(rqp); in ptmclose()
446 rqp->q_ptr = NULL; in ptmclose()
[all …]
H A Dconnld.c147 connopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) in connopen() argument
153 if ((streamvp = strq2vp(rqp)) == NULL) { in connopen()
178 if (rqp->q_ptr == 0) { in connopen()
183 rqp->q_ptr = (caddr_t)1; in connopen()
185 qprocson(rqp); in connopen()
H A Dpipemod.c46 pipeopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) in pipeopen() argument
48 qprocson(rqp); in pipeopen()
/illumos-gate/usr/src/cmd/fm/fmd/common/
H A Dfmd_rpc.c240 fmd_rpc_deny(struct svc_req *rqp) in fmd_rpc_deny() argument
253 if (svc_getcallerucred(rqp->rq_xprt, &ucp) != 0 || in fmd_rpc_deny()
262 if (rqp->rq_proc == FMD_ADM_MODLOAD) in fmd_rpc_deny()
/illumos-gate/usr/src/uts/common/rpc/
H A Dib.h375 #define qptoc(rqp) ((CONN *)&((rqp)->rdmaconn)) argument
/illumos-gate/usr/src/uts/common/os/
H A Dstrsubr.c7740 reset_nfsrv_ptr(queue_t *rqp, queue_t *wqp) in reset_nfsrv_ptr() argument
7745 if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) { in reset_nfsrv_ptr()
7754 if (rqp->q_qinfo->qi_srvp) { in reset_nfsrv_ptr()
7757 while (tmp_qp && tmp_qp->q_nfsrv == rqp) { in reset_nfsrv_ptr()
7759 ASSERT(rqp->q_next != NULL); in reset_nfsrv_ptr()
7760 tmp_qp->q_nfsrv = rqp->q_next->q_nfsrv; in reset_nfsrv_ptr()
/illumos-gate/usr/src/uts/common/sys/ib/adapters/hermon/
H A Dhermon_hw.h4462 uint32_t rqp :24; member