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.c54 static int smb2_rq_enqueue(struct smb_rq *rqp);
55 static int smb2_rq_reply(struct smb_rq *rqp);
64 smb2_rq_fillhdr(struct smb_rq *rqp) in smb2_rq_fillhdr() argument
71 ASSERT((rqp->sr2_nextcmd & 7) == 0); in smb2_rq_fillhdr()
72 if (rqp->sr2_nextcmd != 0) { in smb2_rq_fillhdr()
73 len = msgdsize(rqp->sr_rq.mb_top); in smb2_rq_fillhdr()
82 if (rqp->sr2_command == SMB2_NEGOTIATE) { in smb2_rq_fillhdr()
85 creditcharge = rqp->sr2_creditcharge; in smb2_rq_fillhdr()
86 creditrequest = rqp->sr2_creditsrequested; in smb2_rq_fillhdr()
94 m = dupb(rqp->sr_rq.mb_top); in smb2_rq_fillhdr()
[all …]
H A Dsmb_rq.c75 static int smb_rq_reply(struct smb_rq *rqp);
76 static int smb_rq_parsehdr(struct smb_rq *rqp);
77 static int smb_rq_enqueue(struct smb_rq *rqp);
78 static int smb_rq_new(struct smb_rq *rqp, uchar_t cmd);
91 smb_rq_done(struct smb_rq *rqp) in smb_rq_done() argument
97 mb_done(&rqp->sr_rq); in smb_rq_done()
98 md_done(&rqp->sr_rp); in smb_rq_done()
99 mutex_destroy(&rqp->sr_lock); in smb_rq_done()
100 cv_destroy(&rqp->sr_cond); in smb_rq_done()
101 if (rqp->sr_flags & SMBR_ALLOCED) in smb_rq_done()
[all …]
H A Dsmb_iod.c135 struct smb_rq *rqp, in smb_iod_rqprocessed_LH() argument
139 rqp->sr_flags |= flags; in smb_iod_rqprocessed_LH()
140 rqp->sr_lerror = error; in smb_iod_rqprocessed_LH()
141 rqp->sr_rpgen++; in smb_iod_rqprocessed_LH()
142 rqp->sr_state = SMBRQ_NOTIFIED; in smb_iod_rqprocessed_LH()
143 cv_broadcast(&rqp->sr_cond); in smb_iod_rqprocessed_LH()
148 struct smb_rq *rqp, in smb_iod_rqprocessed() argument
153 SMBRQ_LOCK(rqp); in smb_iod_rqprocessed()
154 smb_iod_rqprocessed_LH(rqp, error, flags); in smb_iod_rqprocessed()
155 SMBRQ_UNLOCK(rqp); in smb_iod_rqprocessed()
[all …]
H A Dsmb_smb.c103 struct smb_rq *rqp = NULL; in smb_smb_negotiate() local
156 err = smb_rq_alloc(VCTOCP(vcp), SMB_COM_NEGOTIATE, scred, &rqp); in smb_smb_negotiate()
163 smb_rq_getrequest(rqp, &mbp); in smb_smb_negotiate()
164 smb_rq_wstart(rqp); in smb_smb_negotiate()
165 smb_rq_wend(rqp); in smb_smb_negotiate()
166 smb_rq_bstart(rqp); in smb_smb_negotiate()
173 smb_rq_bend(rqp); in smb_smb_negotiate()
178 err = smb_rq_internal(rqp, smb_timo_default); in smb_smb_negotiate()
185 err = smb2_parse_smb1nego_resp(rqp); in smb_smb_negotiate()
186 smb_rq_done(rqp); in smb_smb_negotiate()
[all …]
H A Dsmb2_smb.c96 smb2_parse_smb1nego_resp(struct smb_rq *rqp) in smb2_parse_smb1nego_resp() argument
98 struct smb_vc *vcp = rqp->sr_vc; in smb2_parse_smb1nego_resp()
105 smb_rq_getreply(rqp, &mdp); in smb2_parse_smb1nego_resp()
107 error = smb2_rq_parsehdr(rqp); in smb2_parse_smb1nego_resp()
157 struct smb_rq *rqp = NULL; in smb2_smb_negotiate() local
178 err = smb_rq_alloc(VCTOCP(vcp), SMB2_NEGOTIATE, scred, &rqp); in smb2_smb_negotiate()
185 smb_rq_getrequest(rqp, &mbp); in smb2_smb_negotiate()
203 err = smb2_rq_internal(rqp, smb2_timo_default); in smb2_smb_negotiate()
208 if (rqp->sr_error != NT_STATUS_SUCCESS) { in smb2_smb_negotiate()
216 smb_rq_getreply(rqp, &mdp); in smb2_smb_negotiate()
[all …]
H A Dsmb_rq.h75 #define SMBRQ_LOCK(rqp) mutex_enter(&(rqp)->sr_lock) argument
76 #define SMBRQ_UNLOCK(rqp) mutex_exit(&(rqp)->sr_lock) argument
212 void smb_rq_done(struct smb_rq *rqp);
215 int smb_rq_init(struct smb_rq *rqp, struct smb_connobj *layer,
220 void smb_rq_fillhdr(struct smb_rq *rqp);
221 void smb_rq_wstart(struct smb_rq *rqp);
222 void smb_rq_wend(struct smb_rq *rqp);
223 void smb_rq_bstart(struct smb_rq *rqp);
224 void smb_rq_bend(struct smb_rq *rqp);
225 int smb_rq_simple(struct smb_rq *rqp);
[all …]
H A Dsmb_sign.c202 smb_rq_sign(struct smb_rq *rqp) in smb_rq_sign() argument
204 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_sign()
205 mblk_t *mp = rqp->sr_rq.mb_top; in smb_rq_sign()
230 status = smb_compute_MAC(vcp, mp, rqp->sr_seqno, sigloc); in smb_rq_sign()
241 smb_rq_verify(struct smb_rq *rqp) in smb_rq_verify() argument
243 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_verify()
244 mblk_t *mp = rqp->sr_rp.md_top; in smb_rq_verify()
273 rsn = rqp->sr_rseqno; in smb_rq_verify()
292 vcp->vc_srvname, rqp->sr_mid, rsn); in smb_rq_verify()
311 rqp->sr_mid, rsn, rsn + fudge); in smb_rq_verify()
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 Dsmb2_sign.c204 smb2_rq_sign(struct smb_rq *rqp) in smb2_rq_sign() argument
206 struct smb_vc *vcp = rqp->sr_vc; in smb2_rq_sign()
207 mblk_t *mp = rqp->sr_rq.mb_top; in smb2_rq_sign()
236 smb2_rq_verify(struct smb_rq *rqp) in smb2_rq_verify() argument
238 struct smb_vc *vcp = rqp->sr_vc; in smb2_rq_verify()
239 mblk_t *mp = rqp->sr_rp.md_top; in smb2_rq_verify()
287 vcp->vc_srvname, (long long)rqp->sr2_messageid); in smb2_rq_verify()
H A Dsmb_conn.h457 int smb2_iod_addrq(struct smb_rq *rqp);
458 int smb1_iod_addrq(struct smb_rq *rqp);
459 int smb1_iod_multirq(struct smb_rq *rqp);
460 int smb_iod_waitrq(struct smb_rq *rqp);
461 int smb_iod_waitrq_int(struct smb_rq *rqp);
462 void smb_iod_removerq(struct smb_rq *rqp);
H A Dsmb_subr.h154 int smb_put_string(struct smb_rq *rqp, const char *src);
155 int smb_put_asunistring(struct smb_rq *rqp, const char *src);
/illumos-gate/usr/src/lib/libsmbfs/smb/
H A Dnbns_rq.c99 static void nbns_rq_done(struct nbns_rq *rqp);
100 static int nbns_rq_getrr(struct nbns_rq *rqp, struct nbns_rr *rrp);
101 static int nbns_rq_prepare(struct nbns_rq *rqp);
102 static int nbns_rq(struct nbns_rq *rqp);
182 struct nbns_rq *rqp; in nbns_resolvename() local
190 error = nbns_rq_create(NBNS_OPCODE_QUERY, ctx, &rqp); in nbns_resolvename()
202 rqp->nr_nmflags = NBNS_NMFLAG_RD; in nbns_resolvename()
203 rqp->nr_qdname = &nn; in nbns_resolvename()
204 rqp->nr_qdtype = NBNS_QUESTION_TYPE_NB; in nbns_resolvename()
205 rqp->nr_qdclass = NBNS_QUESTION_CLASS_IN; in nbns_resolvename()
[all …]
/illumos-gate/usr/src/uts/common/fs/smbclnt/smbfs/
H A Dsmbfs_smb1.c71 struct smb_rq rq, *rqp = &rq;
88 error = smb_rq_init(rqp, SSTOCP(ssp), SMB_COM_LOCKING_ANDX, scrp);
91 smb_rq_getrequest(rqp, &mbp);
92 smb_rq_wstart(rqp);
102 smb_rq_wend(rqp);
103 smb_rq_bstart(rqp);
115 smb_rq_bend(rqp);
122 rqp->sr_flags |= SMBR_NOINTR_SEND;
124 rqp->sr_flags |= SMBR_NOINTR_RECV;
126 error = smb_rq_simple(rqp);
[all …]
H A Dsmbfs_smb2.c123 struct smb_rq *rqp = NULL; in smbfs_smb2_query_info() local
131 error = smb_rq_alloc(SSTOCP(ssp), SMB2_QUERY_INFO, scrp, &rqp); in smbfs_smb2_query_info()
138 smb_rq_getrequest(rqp, &mbp); in smbfs_smb2_query_info()
151 error = smb2_rq_simple(rqp); in smbfs_smb2_query_info()
153 if (rqp->sr_error == NT_STATUS_INVALID_PARAMETER) 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
339 error = smb_rq_alloc(SSTOCP(ssp), SMB2_FLUSH, scrp, &rqp); in smbfs_smb2_flush()
346 smb_rq_getrequest(rqp, &mbp); in smbfs_smb2_flush()
[all …]
/illumos-gate/usr/src/uts/common/io/
H A Dpts.c290 queue_t *rqp, /* pointer to the read side queue */ in ptsopen() argument
331 if (rqp->q_ptr != NULL) { in ptsopen()
332 ASSERT(rqp->q_ptr == ptsp); in ptsopen()
333 ASSERT(ptsp->pts_rdq == rqp); in ptsopen()
354 ASSERT(rqp->q_ptr == ptsp); in ptsopen()
355 ASSERT(ptsp->pts_rdq == rqp); in ptsopen()
385 WR(rqp)->q_ptr = rqp->q_ptr = ptsp; in ptsopen()
391 STREAM(rqp)->sd_flag |= STRXPG4TTY; in ptsopen()
393 qprocson(rqp); in ptsopen()
403 ptsp->pts_rdq = rqp; in ptsopen()
[all …]
H A Dzcons.c460 queue_t *rqp, /* pointer to the read side queue */ in zc_manager_open() argument
487 WR(rqp)->q_ptr = rqp->q_ptr = zcs; in zc_manager_open()
488 qprocson(rqp); in zc_manager_open()
497 zcs->zc_manager_rdq = rqp; in zc_manager_open()
512 putnext(rqp, mop); in zc_manager_open()
519 queue_t *rqp, /* pointer to the read side queue */ in zc_subsidiary_open() argument
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()
574 zcs->zc_subsid_rdq = rqp; in zc_subsidiary_open()
[all …]
H A Dptm.c316 queue_t *rqp, /* pointer to the read side queue */ in ptmopen() argument
328 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()
[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.c7739 reset_nfsrv_ptr(queue_t *rqp, queue_t *wqp) in reset_nfsrv_ptr() argument
7744 if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) { in reset_nfsrv_ptr()
7753 if (rqp->q_qinfo->qi_srvp) { in reset_nfsrv_ptr()
7756 while (tmp_qp && tmp_qp->q_nfsrv == rqp) { in reset_nfsrv_ptr()
7758 ASSERT(rqp->q_next != NULL); in reset_nfsrv_ptr()
7759 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