/illumos-gate/usr/src/lib/libsmbfs/smb/ |
H A D | negprot.c | 110 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 D | signing.c | 146 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 D | ssnsetup.c | 291 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 D | rq.c | 78 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 D | nbns_rq.c | 99 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...] |
/illumos-gate/usr/src/uts/common/io/ |
H A D | connld.c | 150 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 D | pipemod.c | 49 pipeopen(queue_t *rqp, dev_t *devp, int flag, int sflag, cred_t *crp) argument 51 qprocson(rqp);
|
H A D | ptm.c | 310 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...] |
H A D | pts.c | 288 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 D | zcons.c | 454 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...] |
/illumos-gate/usr/src/cmd/fm/fmd/common/ |
H A D | fmd_rpc.c | 240 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/fs/smbclnt/netsmb/ |
H A D | smb_sign.c | 192 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 D | smb_iod.c | 115 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 D | smb_usr.c | 124 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...] |
H A D | smb_rq.c | 71 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 D | smb_smb.c | 156 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...] |
/illumos-gate/usr/src/uts/common/fs/smbclnt/smbfs/ |
H A D | smbfs_smb.c | 104 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/lvm/md/ |
H A D | md_subr.c | 1762 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/inet/nca/ |
H A D | nca.h | 1043 queue_t *rqp; /* our read-side STREAMS queue */ member in struct:if_s
|
/illumos-gate/usr/src/uts/common/os/ |
H A D | strsubr.c | 7715 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;
|
/illumos-gate/usr/src/uts/common/sys/ib/adapters/hermon/ |
H A D | hermon_hw.h | 4462 uint32_t rqp :24; member in struct:hermon_hw_fcmd_o_ib_s
|