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

12

/illumos-gate/usr/src/lib/libsmbfs/smb/
H A Drq.c78 struct smb_rq *rqp; local
80 rqp = malloc(sizeof (*rqp));
81 if (rqp == NULL)
83 bzero(rqp, sizeof (*rqp));
84 rqp->rq_cmd = cmd;
85 rqp->rq_ctx = ctx;
91 if (mb_init(&rqp->rq_rq))
95 mb_put_mem(&rqp
116 smb_rq_done(struct smb_rq *rqp) argument
132 smb_rq_wstart(struct smb_rq *rqp) argument
145 smb_rq_wend(struct smb_rq *rqp) argument
178 smb_rq_bstart(struct smb_rq *rqp) argument
191 smb_rq_bend(struct smb_rq *rqp) argument
216 smb_rq_simple(struct smb_rq *rqp) argument
335 smb_rq_internal(struct smb_ctx *ctx, struct smb_rq *rqp) argument
[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; local
190 error = nbns_rq_create(NBNS_OPCODE_QUERY, ctx, &rqp);
202 rqp->nr_nmflags = NBNS_NMFLAG_RD;
203 rqp->nr_qdname = &nn;
204 rqp->nr_qdtype = NBNS_QUESTION_TYPE_NB;
205 rqp
270 struct nbns_rq *rqp; local
370 struct nbns_rq *rqp; local
393 nbns_rq_done(struct nbns_rq *rqp) argument
411 nbns_rq_getrr(struct nbns_rq *rqp, struct nbns_rr *rrp) argument
436 nbns_rq_prepare(struct nbns_rq *rqp) argument
477 nbns_rq_recv(struct nbns_rq *rqp) argument
513 nbns_rq_opensocket(struct nbns_rq *rqp) argument
539 nbns_rq_send(struct nbns_rq *rqp, in_addr_t ina) argument
581 nbns_rq(struct nbns_rq *rqp) argument
[all...]
H A Dsigning.c146 smb_rq_sign(struct smb_rq *rqp) argument
148 struct smb_ctx *ctx = rqp->rq_ctx;
149 mbuf_t *m = rqp->rq_rq.mb_top;
175 rqp->rq_seqno = ctx->ct_mac_seqno;
177 err = smb_compute_MAC(ctx, m, rqp->rq_seqno, sigloc);
188 smb_rq_verify(struct smb_rq *rqp) argument
190 struct smb_ctx *ctx = rqp->rq_ctx;
191 mbuf_t *m = rqp->rq_rp.mb_top;
219 rseqno = rqp->rq_seqno + 1;
240 DPRINT("BAD signature, MID=0x%x", rqp
[all...]
H A Dssnsetup.c291 struct smb_rq *rqp = NULL; local
302 err = smb_rq_init(ctx, SMB_COM_SESSION_SETUP_ANDX, &rqp);
309 mbp = &rqp->rq_rq;
310 smb_rq_wstart(rqp);
323 smb_rq_wend(rqp); /* 12: Byte Count */
324 smb_rq_bstart(rqp);
341 smb_rq_wend(rqp); /* 13: Byte Count */
342 smb_rq_bstart(rqp);
356 smb_rq_bend(rqp);
358 err = smb_rq_internal(ctx, rqp);
[all...]
H A Dnegprot.c110 struct smb_rq *rqp; local
121 * (per request) rqp->rq_hflags* by smb_rq_init.
171 err = smb_rq_init(ctx, SMB_COM_NEGOTIATE, &rqp);
178 mbp = &rqp->rq_rq;
180 smb_rq_bstart(rqp);
185 smb_rq_bend(rqp);
190 err = smb_rq_internal(ctx, rqp);
195 if (rqp->rq_status != 0) {
196 DPRINT("nt status 0x%x", rqp->rq_status);
208 mbp = &rqp
[all...]
H A Dprivate.h100 #define smb_rq_getrequest(rqp) (&(rqp)->rq_rq)
101 #define smb_rq_getreply(rqp) (&(rqp)->rq_rp)
/illumos-gate/usr/src/uts/common/fs/smbclnt/netsmb/
H A Dsmb_iod.c115 struct smb_rq *rqp,
119 rqp->sr_flags |= flags;
120 rqp->sr_lerror = error;
121 rqp->sr_rpgen++;
122 rqp->sr_state = SMBRQ_NOTIFIED;
123 cv_broadcast(&rqp->sr_cond);
128 struct smb_rq *rqp,
133 SMBRQ_LOCK(rqp);
134 smb_iod_rqprocessed_LH(rqp, error, flags);
135 SMBRQ_UNLOCK(rqp);
114 smb_iod_rqprocessed_LH( struct smb_rq *rqp, int error, int flags) argument
127 smb_iod_rqprocessed( struct smb_rq *rqp, int error, int flags) argument
141 struct smb_rq *rqp; local
201 smb_iod_sendrq(struct smb_rq *rqp) argument
360 struct smb_rq *rqp; local
566 smb_iod_addrq(struct smb_rq *rqp) argument
657 smb_iod_multirq(struct smb_rq *rqp) argument
697 smb_iod_removerq(struct smb_rq *rqp) argument
724 smb_iod_waitrq(struct smb_rq *rqp) argument
885 struct smb_rq *rqp; local
906 struct smb_rq *rqp; local
[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) argument
94 mb_done(&rqp->sr_rq);
95 md_done(&rqp->sr_rp);
96 mutex_destroy(&rqp->sr_lock);
97 cv_destroy(&rqp->sr_cond);
98 if (rqp->sr_flags & SMBR_ALLOCED)
99 kmem_free(rqp, sizeo
106 struct smb_rq *rqp; local
123 smb_rq_init(struct smb_rq *rqp, struct smb_connobj *co, uchar_t cmd, struct smb_cred *scred) argument
157 smb_rq_new(struct smb_rq *rqp, uchar_t cmd) argument
197 smb_rq_fillhdr(struct smb_rq *rqp) argument
229 smb_rq_simple(struct smb_rq *rqp) argument
238 smb_rq_simple_timed(struct smb_rq *rqp, int timeout) argument
278 smb_rq_enqueue(struct smb_rq *rqp) argument
341 smb_rq_wstart(struct smb_rq *rqp) argument
348 smb_rq_wend(struct smb_rq *rqp) argument
373 smb_rq_bstart(struct smb_rq *rqp) argument
380 smb_rq_bend(struct smb_rq *rqp) argument
401 smb_rq_intr(struct smb_rq *rqp) argument
463 smb_rq_reply(struct smb_rq *rqp) argument
685 struct smb_rq *rqp = t2p->t2_rq; local
814 struct smb_rq *rqp = ntp->nt_rq; local
945 struct smb_rq *rqp; local
1177 struct smb_rq *rqp; local
[all...]
H A Dsmb_smb.c156 struct smb_rq *rqp = NULL; local
170 * rqp->sr_share == NULL, and smb_iod_sendrq()
178 scred, &rqp);
205 mbp = &rqp->sr_rq;
206 smb_rq_wstart(rqp);
212 smb_rq_wend(rqp);
213 smb_rq_bstart(rqp);
235 smb_rq_bend(rqp);
244 rqp->sr_flags |= SMBR_NOINTR_RECV;
245 error = smb_rq_simple(rqp);
310 struct smb_rq *rqp; local
370 struct smb_rq rq, *rqp = &rq; local
481 struct smb_rq rq, *rqp = &rq; local
519 struct smb_rq rq, *rqp = &rq; local
581 struct smb_rq rq, *rqp = &rq; local
698 struct smb_rq *rqp; local
793 struct smb_rq *rqp; local
866 struct smb_rq *rqp; local
945 struct smb_rq *rqp; local
1007 struct smb_rq *rqp; local
[all...]
H A Dsmb_rq.h67 #define SMBRQ_LOCK(rqp) mutex_enter(&(rqp)->sr_lock)
68 #define SMBRQ_UNLOCK(rqp) mutex_exit(&(rqp)->sr_lock)
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);
[all...]
H A Dsmb_sign.c192 smb_rq_sign(struct smb_rq *rqp) argument
194 struct smb_vc *vcp = rqp->sr_vc;
195 mblk_t *mp = rqp->sr_rq.mb_top;
223 status = smb_compute_MAC(vcp, mp, rqp->sr_seqno, sigloc);
234 smb_rq_verify(struct smb_rq *rqp) argument
236 struct smb_vc *vcp = rqp->sr_vc;
237 mblk_t *mp = rqp->sr_rp.md_top;
268 rsn = rqp->sr_rseqno;
287 vcp->vc_srvname, rqp->sr_mid, rsn);
306 rqp
[all...]
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);
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_usr.c124 struct smb_rq *rqp = NULL; local
162 err = smb_rq_alloc(SSTOCP(ssp), ioc->ioc_cmd, &scred, &rqp);
166 mbp = &rqp->sr_rq;
169 err = smb_rq_simple(rqp);
182 mdp = &rqp->sr_rp;
195 ioc->ioc_errclass = rqp->sr_errclass;
196 ioc->ioc_serror = rqp->sr_serror;
197 ioc->ioc_error = rqp->sr_error;
201 if (rqp != NULL)
202 smb_rq_done(rqp); /* fre
[all...]
/illumos-gate/usr/src/uts/common/fs/smbclnt/smbfs/
H A Dsmbfs_smb.c104 struct smb_rq rq, *rqp = &rq; local
121 error = smb_rq_init(rqp, SSTOCP(ssp), SMB_COM_LOCKING_ANDX, scrp);
124 smb_rq_getrequest(rqp, &mbp);
125 smb_rq_wstart(rqp);
135 smb_rq_wend(rqp);
136 smb_rq_bstart(rqp);
148 smb_rq_bend(rqp);
155 rqp->sr_flags |= SMBR_NOINTR_SEND;
157 rqp->sr_flags |= SMBR_NOINTR_RECV;
159 error = smb_rq_simple(rqp);
535 struct smb_rq rq, *rqp = &rq; local
692 struct smb_rq rq, *rqp = &rq; local
732 struct smb_rq rq, *rqp = &rq; local
785 struct smb_rq rq, *rqp = &rq; local
846 struct smb_rq rq, *rqp = &rq; local
971 struct smb_rq rq, *rqp = &rq; local
1203 struct smb_rq rq, *rqp = &rq; local
1448 struct smb_rq rq, *rqp = &rq; local
1542 struct smb_rq rq, *rqp = &rq; local
1570 struct smb_rq rq, *rqp = &rq; local
1618 struct smb_rq rq, *rqp = &rq; local
1654 struct smb_rq rq, *rqp = &rq; local
1713 struct smb_rq rq, *rqp = &rq; local
1739 struct smb_rq *rqp; local
1845 struct smb_rq *rqp; local
2021 struct smb_rq rq, *rqp = &rq; local
[all...]
/illumos-gate/usr/src/uts/common/io/
H A Dconnld.c150 connopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) argument
156 if ((streamvp = strq2vp(rqp)) == NULL) {
181 if (rqp->q_ptr == 0) {
186 rqp->q_ptr = (caddr_t)1;
188 qprocson(rqp);
H A Dpts.c288 queue_t *rqp, /* pointer to the read side queue */
329 if (rqp->q_ptr != NULL) {
330 ASSERT(rqp->q_ptr == ptsp);
331 ASSERT(ptsp->pts_rdq == rqp);
353 ASSERT(rqp->q_ptr == ptsp);
354 ASSERT(ptsp->pts_rdq == rqp);
384 WR(rqp)->q_ptr = rqp->q_ptr = ptsp;
389 qprocson(rqp);
398 ptsp->pts_rdq = rqp;
287 ptsopen( queue_t *rqp, dev_t *devp, int oflag, int sflag, cred_t *credp) argument
429 ptsclose(queue_t *rqp, int flag, cred_t *credp) argument
[all...]
H A Dzcons.c454 queue_t *rqp, /* pointer to the read side queue */
481 WR(rqp)->q_ptr = rqp->q_ptr = zcs;
482 qprocson(rqp);
491 zcs->zc_master_rdq = rqp;
506 putnext(rqp, mop);
514 queue_t *rqp, /* pointer to the read side queue */
531 ASSERT((rqp != NULL) && (WR(rqp)->q_ptr == zcs));
562 WR(rqp)
453 zc_master_open(zc_state_t *zcs, queue_t *rqp, dev_t *devp, int oflag, int sflag, cred_t *credp) argument
513 zc_slave_open(zc_state_t *zcs, queue_t *rqp, dev_t *devp, int oflag, int sflag, cred_t *credp) argument
590 zc_open(queue_t *rqp, dev_t *devp, int oflag, int sflag, cred_t *credp) argument
626 zc_close(queue_t *rqp, int flag, cred_t *credp) argument
[all...]
H A Dpipemod.c49 pipeopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) argument
51 qprocson(rqp);
H A Dptm.c310 queue_t *rqp, /* pointer to the read side queue */
322 if (rqp->q_ptr != NULL)
363 WR(rqp)->q_ptr = rqp->q_ptr = ptmp;
365 qprocson(rqp);
369 ptmp->ptm_rdq = rqp;
385 putnext(rqp, mop);
406 ptmclose(queue_t *rqp, int flag, cred_t *credp) argument
411 ASSERT(rqp->q_ptr);
413 ptmp = (struct pt_ttys *)rqp
309 ptmopen( queue_t *rqp, dev_t *devp, int oflag, int sflag, cred_t *credp) argument
[all...]
/illumos-gate/usr/src/cmd/fm/fmd/common/
H A Dfmd_rpc.c240 fmd_rpc_deny(struct svc_req *rqp) argument
253 if (svc_getcallerucred(rqp->rq_xprt, &ucp) != 0 ||
262 if (rqp->rq_proc == FMD_ADM_MODLOAD)
/illumos-gate/usr/src/uts/common/rpc/
H A Dib.h375 #define qptoc(rqp) ((CONN *)&((rqp)->rdmaconn))
/illumos-gate/usr/src/uts/common/io/lvm/md/
H A Dmd_subr.c1762 md_requestq_entry_t *rqp; local
1788 rqp = &md_daemon_queues[0];
1790 while (!NULL_REQUESTQ_ENTRY(rqp)) {
1791 cv_broadcast(&rqp->dispq_headp->a_cv);
1792 rqp = &md_daemon_queues[++i];
2130 md_requestq_entry_t *rqp; local
2141 rqp = &md_daemon_queues[0];
2143 while (!NULL_REQUESTQ_ENTRY(rqp)) {
2144 cnt = init_requestq(rqp, start_daemon,
2145 (caddr_t)rqp
[all...]
/illumos-gate/usr/src/uts/common/sys/lvm/
H A Dmdvar.h394 #define NULL_REQUESTQ_ENTRY(rqp)\
395 ((rqp)->dispq_headp == NULL || (rqp)->num_threadsp == NULL)
/illumos-gate/usr/src/uts/common/os/
H A Dstrsubr.c7715 reset_nfsrv_ptr(queue_t *rqp, queue_t *wqp) argument
7720 if ((rqp->q_flag & _QREMOVING) && (wqp->q_qinfo->qi_srvp != NULL)) {
7729 if (rqp->q_qinfo->qi_srvp) {
7732 while (tmp_qp && tmp_qp->q_nfsrv == rqp) {
7733 /* Note that rqp->q_next cannot be NULL */
7734 ASSERT(rqp->q_next != NULL);
7735 tmp_qp->q_nfsrv = rqp->q_next->q_nfsrv;

Completed in 1307 milliseconds

12