Home
last modified time | relevance | path

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

12

/titanic_41/usr/src/lib/libsmbfs/smb/
H A Drq.c78 struct smb_rq *rqp; in smb_rq_init() local
80 rqp = malloc(sizeof (*rqp)); in smb_rq_init()
81 if (rqp == NULL) in smb_rq_init()
83 bzero(rqp, sizeof (*rqp)); in smb_rq_init()
84 rqp->rq_cmd = cmd; in smb_rq_init()
85 rqp->rq_ctx = ctx; in smb_rq_init()
91 if (mb_init(&rqp->rq_rq)) in smb_rq_init()
95 mb_put_mem(&rqp->rq_rq, NULL, SMB_HDRLEN, MB_MSYSTEM); in smb_rq_init()
101 rqp->rq_hflags = ctx->ct_hflags; in smb_rq_init()
102 rqp->rq_hflags2 = ctx->ct_hflags2; in smb_rq_init()
[all …]
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 …]
H A Dssnsetup.c291 struct smb_rq *rqp = NULL; in smb__ssnsetup() local
302 err = smb_rq_init(ctx, SMB_COM_SESSION_SETUP_ANDX, &rqp); in smb__ssnsetup()
309 mbp = &rqp->rq_rq; in smb__ssnsetup()
310 smb_rq_wstart(rqp); in smb__ssnsetup()
323 smb_rq_wend(rqp); /* 12: Byte Count */ in smb__ssnsetup()
324 smb_rq_bstart(rqp); in smb__ssnsetup()
341 smb_rq_wend(rqp); /* 13: Byte Count */ in smb__ssnsetup()
342 smb_rq_bstart(rqp); in smb__ssnsetup()
356 smb_rq_bend(rqp); in smb__ssnsetup()
358 err = smb_rq_internal(ctx, rqp); in smb__ssnsetup()
[all …]
H A Dsigning.c146 smb_rq_sign(struct smb_rq *rqp) in smb_rq_sign() argument
148 struct smb_ctx *ctx = rqp->rq_ctx; in smb_rq_sign()
149 mbuf_t *m = rqp->rq_rq.mb_top; in smb_rq_sign()
175 rqp->rq_seqno = ctx->ct_mac_seqno; in smb_rq_sign()
177 err = smb_compute_MAC(ctx, m, rqp->rq_seqno, sigloc); in smb_rq_sign()
188 smb_rq_verify(struct smb_rq *rqp) in smb_rq_verify() argument
190 struct smb_ctx *ctx = rqp->rq_ctx; in smb_rq_verify()
191 mbuf_t *m = rqp->rq_rp.mb_top; in smb_rq_verify()
219 rseqno = rqp->rq_seqno + 1; in smb_rq_verify()
240 DPRINT("BAD signature, MID=0x%x", rqp->rq_mid); in smb_rq_verify()
H A Dnegprot.c110 struct smb_rq *rqp; in smb_negprot() local
171 err = smb_rq_init(ctx, SMB_COM_NEGOTIATE, &rqp); in smb_negprot()
178 mbp = &rqp->rq_rq; in smb_negprot()
180 smb_rq_bstart(rqp); in smb_negprot()
185 smb_rq_bend(rqp); in smb_negprot()
190 err = smb_rq_internal(ctx, rqp); in smb_negprot()
195 if (rqp->rq_status != 0) { in smb_negprot()
196 DPRINT("nt status 0x%x", rqp->rq_status); in smb_negprot()
208 mbp = &rqp->rq_rp; in smb_negprot()
388 smb_rq_done(rqp); in smb_negprot()
[all …]
H A Dprivate.h100 #define smb_rq_getrequest(rqp) (&(rqp)->rq_rq) argument
101 #define smb_rq_getreply(rqp) (&(rqp)->rq_rp) argument
/titanic_41/usr/src/uts/common/fs/smbclnt/netsmb/
H A Dsmb_iod.c115 struct smb_rq *rqp, in smb_iod_rqprocessed_LH() argument
119 rqp->sr_flags |= flags; in smb_iod_rqprocessed_LH()
120 rqp->sr_lerror = error; in smb_iod_rqprocessed_LH()
121 rqp->sr_rpgen++; in smb_iod_rqprocessed_LH()
122 rqp->sr_state = SMBRQ_NOTIFIED; in smb_iod_rqprocessed_LH()
123 cv_broadcast(&rqp->sr_cond); in smb_iod_rqprocessed_LH()
128 struct smb_rq *rqp, in smb_iod_rqprocessed() argument
133 SMBRQ_LOCK(rqp); in smb_iod_rqprocessed()
134 smb_iod_rqprocessed_LH(rqp, error, flags); in smb_iod_rqprocessed()
135 SMBRQ_UNLOCK(rqp); in smb_iod_rqprocessed()
[all …]
H A Dsmb_rq.c71 static int smb_rq_reply(struct smb_rq *rqp);
72 static int smb_rq_enqueue(struct smb_rq *rqp);
75 static int smb_rq_new(struct smb_rq *rqp, uchar_t cmd);
88 smb_rq_done(struct smb_rq *rqp) in smb_rq_done() argument
94 mb_done(&rqp->sr_rq); in smb_rq_done()
95 md_done(&rqp->sr_rp); in smb_rq_done()
96 mutex_destroy(&rqp->sr_lock); in smb_rq_done()
97 cv_destroy(&rqp->sr_cond); in smb_rq_done()
98 if (rqp->sr_flags & SMBR_ALLOCED) in smb_rq_done()
99 kmem_free(rqp, sizeof (*rqp)); in smb_rq_done()
[all …]
H A Dsmb_smb.c156 struct smb_rq *rqp = NULL; in smb_smb_treeconnect() local
178 scred, &rqp); in smb_smb_treeconnect()
205 mbp = &rqp->sr_rq; in smb_smb_treeconnect()
206 smb_rq_wstart(rqp); in smb_smb_treeconnect()
212 smb_rq_wend(rqp); in smb_smb_treeconnect()
213 smb_rq_bstart(rqp); in smb_smb_treeconnect()
235 smb_rq_bend(rqp); in smb_smb_treeconnect()
244 rqp->sr_flags |= SMBR_NOINTR_RECV; in smb_smb_treeconnect()
245 error = smb_rq_simple(rqp); in smb_smb_treeconnect()
254 unc_name, rqp->sr_error); in smb_smb_treeconnect()
[all …]
H A Dsmb_rq.h67 #define SMBRQ_LOCK(rqp) mutex_enter(&(rqp)->sr_lock) argument
68 #define SMBRQ_UNLOCK(rqp) mutex_exit(&(rqp)->sr_lock) argument
182 void smb_rq_done(struct smb_rq *rqp);
185 int smb_rq_init(struct smb_rq *rqp, struct smb_connobj *layer,
188 void smb_rq_fillhdr(struct smb_rq *rqp);
189 void smb_rq_wstart(struct smb_rq *rqp);
190 void smb_rq_wend(struct smb_rq *rqp);
191 void smb_rq_bstart(struct smb_rq *rqp);
192 void smb_rq_bend(struct smb_rq *rqp);
193 int smb_rq_intr(struct smb_rq *rqp);
[all …]
H A Dsmb_sign.c192 smb_rq_sign(struct smb_rq *rqp) in smb_rq_sign() argument
194 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_sign()
195 mblk_t *mp = rqp->sr_rq.mb_top; in smb_rq_sign()
223 status = smb_compute_MAC(vcp, mp, rqp->sr_seqno, sigloc); in smb_rq_sign()
234 smb_rq_verify(struct smb_rq *rqp) in smb_rq_verify() argument
236 struct smb_vc *vcp = rqp->sr_vc; in smb_rq_verify()
237 mblk_t *mp = rqp->sr_rp.md_top; in smb_rq_verify()
268 rsn = rqp->sr_rseqno; in smb_rq_verify()
287 vcp->vc_srvname, rqp->sr_mid, rsn); in smb_rq_verify()
306 rqp->sr_mid, rsn, rsn + fudge); in smb_rq_verify()
H A Dsmb_usr.c124 struct smb_rq *rqp = NULL; in smb_usr_simplerq() local
162 err = smb_rq_alloc(SSTOCP(ssp), ioc->ioc_cmd, &scred, &rqp); in smb_usr_simplerq()
166 mbp = &rqp->sr_rq; in smb_usr_simplerq()
169 err = smb_rq_simple(rqp); in smb_usr_simplerq()
182 mdp = &rqp->sr_rp; in smb_usr_simplerq()
195 ioc->ioc_errclass = rqp->sr_errclass; in smb_usr_simplerq()
196 ioc->ioc_serror = rqp->sr_serror; in smb_usr_simplerq()
197 ioc->ioc_error = rqp->sr_error; in smb_usr_simplerq()
201 if (rqp != NULL) in smb_usr_simplerq()
202 smb_rq_done(rqp); /* free rqp */ in smb_usr_simplerq()
H A Dsmb_conn.h332 int smb_iod_addrq(struct smb_rq *rqp);
333 int smb_iod_multirq(struct smb_rq *rqp);
334 int smb_iod_waitrq(struct smb_rq *rqp);
335 void smb_iod_removerq(struct smb_rq *rqp);
H A Dsmb_subr.h138 int smb_put_string(struct smb_rq *rqp, const char *src);
139 int smb_put_asunistring(struct smb_rq *rqp, const char *src);
/titanic_41/usr/src/uts/common/fs/smbclnt/smbfs/
H A Dsmbfs_smb.c104 struct smb_rq rq, *rqp = &rq; in smbfs_smb_lockandx() local
121 error = smb_rq_init(rqp, SSTOCP(ssp), SMB_COM_LOCKING_ANDX, scrp); in smbfs_smb_lockandx()
124 smb_rq_getrequest(rqp, &mbp); in smbfs_smb_lockandx()
125 smb_rq_wstart(rqp); in smbfs_smb_lockandx()
135 smb_rq_wend(rqp); in smbfs_smb_lockandx()
136 smb_rq_bstart(rqp); in smbfs_smb_lockandx()
148 smb_rq_bend(rqp); in smbfs_smb_lockandx()
155 rqp->sr_flags |= SMBR_NOINTR_SEND; in smbfs_smb_lockandx()
157 rqp->sr_flags |= SMBR_NOINTR_RECV; in smbfs_smb_lockandx()
159 error = smb_rq_simple(rqp); in smbfs_smb_lockandx()
[all …]
/titanic_41/usr/src/uts/common/io/
H A Dpts.c288 queue_t *rqp, /* pointer to the read side queue */ in ptsopen() argument
329 if (rqp->q_ptr != NULL) { in ptsopen()
330 ASSERT(rqp->q_ptr == ptsp); in ptsopen()
331 ASSERT(ptsp->pts_rdq == rqp); in ptsopen()
353 ASSERT(rqp->q_ptr == ptsp); in ptsopen()
354 ASSERT(ptsp->pts_rdq == rqp); in ptsopen()
384 WR(rqp)->q_ptr = rqp->q_ptr = ptsp; in ptsopen()
389 qprocson(rqp); in ptsopen()
398 ptsp->pts_rdq = rqp; in ptsopen()
414 putnext(rqp, mop); in ptsopen()
[all …]
H A Dzcons.c454 queue_t *rqp, /* pointer to the read side queue */ in zc_master_open() argument
481 WR(rqp)->q_ptr = rqp->q_ptr = zcs; in zc_master_open()
482 qprocson(rqp); in zc_master_open()
491 zcs->zc_master_rdq = rqp; in zc_master_open()
506 putnext(rqp, mop); in zc_master_open()
514 queue_t *rqp, /* pointer to the read side queue */ in zc_slave_open() argument
531 ASSERT((rqp != NULL) && (WR(rqp)->q_ptr == zcs)); in zc_slave_open()
562 WR(rqp)->q_ptr = rqp->q_ptr = zcs; in zc_slave_open()
564 qprocson(rqp); in zc_slave_open()
569 zcs->zc_slave_rdq = rqp; in zc_slave_open()
[all …]
H A Dptm.c310 queue_t *rqp, /* pointer to the read side queue */ in ptmopen() argument
322 if (rqp->q_ptr != NULL) in ptmopen()
363 WR(rqp)->q_ptr = rqp->q_ptr = ptmp; in ptmopen()
365 qprocson(rqp); in ptmopen()
369 ptmp->ptm_rdq = rqp; in ptmopen()
385 putnext(rqp, mop); in ptmopen()
406 ptmclose(queue_t *rqp, int flag, cred_t *credp) in ptmclose() argument
411 ASSERT(rqp->q_ptr); in ptmclose()
413 ptmp = (struct pt_ttys *)rqp->q_ptr; in ptmclose()
439 qprocsoff(rqp); in ptmclose()
[all …]
H A Dconnld.c150 connopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) in connopen() argument
156 if ((streamvp = strq2vp(rqp)) == NULL) { in connopen()
181 if (rqp->q_ptr == 0) { in connopen()
186 rqp->q_ptr = (caddr_t)1; in connopen()
188 qprocson(rqp); in connopen()
H A Dpipemod.c49 pipeopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) in pipeopen() argument
51 qprocson(rqp); in pipeopen()
/titanic_41/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()
/titanic_41/usr/src/uts/common/rpc/
H A Dib.h375 #define qptoc(rqp) ((CONN *)&((rqp)->rdmaconn)) argument
/titanic_41/usr/src/uts/common/io/lvm/md/
H A Dmd_subr.c1762 md_requestq_entry_t *rqp; in md_halt() local
1788 rqp = &md_daemon_queues[0]; in md_halt()
1790 while (!NULL_REQUESTQ_ENTRY(rqp)) { in md_halt()
1791 cv_broadcast(&rqp->dispq_headp->a_cv); in md_halt()
1792 rqp = &md_daemon_queues[++i]; in md_halt()
2130 md_requestq_entry_t *rqp; in md_start_daemons() local
2141 rqp = &md_daemon_queues[0]; in md_start_daemons()
2143 while (!NULL_REQUESTQ_ENTRY(rqp)) { in md_start_daemons()
2144 cnt = init_requestq(rqp, start_daemon, in md_start_daemons()
2145 (caddr_t)rqp->dispq_headp, minclsyspri, init_queue); in md_start_daemons()
[all …]
/titanic_41/usr/src/uts/common/sys/lvm/
H A Dmdvar.h394 #define NULL_REQUESTQ_ENTRY(rqp)\ argument
395 ((rqp)->dispq_headp == NULL || (rqp)->num_threadsp == NULL)
/titanic_41/usr/src/uts/common/os/
H A Dstrsubr.c7715 reset_nfsrv_ptr(queue_t *rqp, queue_t *wqp) in reset_nfsrv_ptr() argument
7720 if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) { in reset_nfsrv_ptr()
7729 if (rqp->q_qinfo->qi_srvp) { in reset_nfsrv_ptr()
7732 while (tmp_qp && tmp_qp->q_nfsrv == rqp) { in reset_nfsrv_ptr()
7734 ASSERT(rqp->q_next != NULL); in reset_nfsrv_ptr()
7735 tmp_qp->q_nfsrv = rqp->q_next->q_nfsrv; in reset_nfsrv_ptr()

12