/illumos-gate/usr/src/uts/common/fs/smbclnt/netsmb/ |
H A D | smb2_rq.c | 71 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 D | smb_rq.c | 102 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 D | smb_iod.c | 140 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 D | smb_smb.c | 165 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 D | smb2_smb.c | 333 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 D | smb_rq.h | 73 #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 D | smb2_rq.h | 37 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 D | smb_sign.c | 200 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 D | smb2_sign.c | 277 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 D | smb_conn.h | 442 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 D | smb_subr.h | 153 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 D | nbns_rq.c | 259 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 D | smbfs_smb1.c | 92 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 D | smbfs_smb2.c | 123 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 D | pts.c | 331 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 D | zcons.c | 487 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 D | ptm.c | 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() 446 rqp->q_ptr = NULL; in ptmclose() [all …]
|
H A D | connld.c | 147 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 D | pipemod.c | 46 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 D | fmd_rpc.c | 240 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 D | ib.h | 375 #define qptoc(rqp) ((CONN *)&((rqp)->rdmaconn)) argument
|
/illumos-gate/usr/src/uts/common/os/ |
H A D | strsubr.c | 7740 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 D | hermon_hw.h | 4462 uint32_t rqp :24; member
|