Lines Matching refs:dsp
84 * NFSDSP_SEQTHISSESSION - Use the nfsclds_sequence field of this dsp for new
835 struct nfsclds *dsp, *ndsp, *tdsp;
843 NFSV4EXCH_USEPNFSMDS | NFSV4EXCH_USENONPNFS, &dsp, cred, p);
846 error = nfsrpc_createsession(nmp, &dsp->nfsclds_sess,
848 dsp->nfsclds_sess.nfsess_sequenceid, 1, cred, p);
855 TAILQ_INSERT_HEAD(&nmp->nm_sess, dsp,
859 nfscl_freenfsclds(dsp);
877 dsp = malloc(sizeof(struct nfsclds), M_NFSCLDS, M_WAITOK | M_ZERO);
878 mtx_init(&dsp->nfsclds_mtx, "nfsds", NULL, MTX_DEF);
879 mtx_init(&dsp->nfsclds_sess.nfsess_mtx, "nfssession", NULL, MTX_DEF);
881 TAILQ_INSERT_HEAD(&nmp->nm_sess, dsp, nfsclds_list);
4226 nfsrpc_renew(struct nfsclclient *clp, struct nfsclds *dsp, struct ucred *cred,
4240 &dsp->nfsclds_sess);
4247 nrp = dsp->nfsclds_sockp;
4253 NFS_PROG, NFS_VER4, NULL, 1, NULL, &dsp->nfsclds_sess);
4484 struct nfsclds *dsp;
4521 dsp = malloc(sizeof(struct nfsclds) + len, M_NFSCLDS,
4523 dsp->nfsclds_expire = NFSD_MONOSEC + clp->nfsc_renew;
4524 dsp->nfsclds_servownlen = len;
4525 dsp->nfsclds_sess.nfsess_clientid.lval[0] = *tl++;
4526 dsp->nfsclds_sess.nfsess_clientid.lval[1] = *tl++;
4527 dsp->nfsclds_sess.nfsess_sequenceid =
4536 dsp->nfsclds_flags |= NFSCLDS_MDS;
4539 dsp->nfsclds_flags |= NFSCLDS_DS;
4542 dsp->nfsclds_serverown, len);
4544 mtx_init(&dsp->nfsclds_mtx, "nfsds", NULL, MTX_DEF);
4545 mtx_init(&dsp->nfsclds_sess.nfsess_mtx, "nfssession",
4547 nfscl_initsessionslots(&dsp->nfsclds_sess);
4548 *dspp = dsp;
4550 free(dsp, M_NFSCLDS);
4872 struct nfsclds *dsp = NULL, **dspp;
4981 &dsp, p);
4983 *dspp = dsp;
5244 struct nfsclds *dsp, *tdsp;
5357 &dsp, nrp->nr_cred, p);
5360 dsp->nfsclds_sockp = nrp;
5362 retv = nfscl_getsameserver(nmp, dsp, &tdsp);
5371 nfscl_freenfsclds(dsp);
5378 sequenceid = dsp->nfsclds_sess.nfsess_sequenceid;
5380 error = nfsrpc_createsession(nmp, &dsp->nfsclds_sess,
5398 TAILQ_INSERT_TAIL(&nmp->nm_sess, dsp, nfsclds_list);
5400 *dspp = dsp;
5401 } else if (dsp != NULL)
5402 nfscl_freenfsclds(dsp);
5682 struct nfsclds *dsp, uint64_t io_off, int len, struct nfsfh *fhp,
5694 NULL, &dsp->nfsclds_sess);
5699 nrp = dsp->nfsclds_sockp;
5704 NFS_PROG, NFS_VER4, NULL, 1, NULL, &dsp->nfsclds_sess);
5725 nfsv4stateid_t *stateidp, struct nfsclds *dsp, uint64_t io_off, int len,
5739 NULL, &dsp->nfsclds_sess);
5747 nrp = dsp->nfsclds_sockp;
5752 NFS_PROG, NFS_VER4, NULL, 1, NULL, &dsp->nfsclds_sess);
5802 NFSLOCKDS(dsp);
5803 if ((dsp->nfsclds_flags & NFSCLDS_HASWRITEVERF) == 0) {
5804 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
5805 dsp->nfsclds_flags |= NFSCLDS_HASWRITEVERF;
5806 } else if (NFSBCMP(tl, dsp->nfsclds_verf, NFSX_VERF)) {
5808 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
5810 NFSUNLOCKDS(dsp);
5825 nfscl_freenfsclds(struct nfsclds *dsp)
5829 if (dsp == NULL)
5831 if (dsp->nfsclds_sockp != NULL) {
5832 NFSFREECRED(dsp->nfsclds_sockp->nr_cred);
5833 NFSFREEMUTEX(&dsp->nfsclds_sockp->nr_mtx);
5834 free(dsp->nfsclds_sockp->nr_nam, M_SONAME);
5835 free(dsp->nfsclds_sockp, M_NFSSOCKREQ);
5837 NFSFREEMUTEX(&dsp->nfsclds_mtx);
5838 NFSFREEMUTEX(&dsp->nfsclds_sess.nfsess_mtx);
5840 m_freem(dsp->nfsclds_sess.nfsess_cbslots[i].nfssl_reply);
5842 free(dsp, M_NFSCLDS);
5849 struct nfsclds *dsp, *cur_dsp;
5856 TAILQ_FOREACH(dsp, &nmp->nm_sess, nfsclds_list) {
5857 if (dsp->nfsclds_servownlen == newdsp->nfsclds_servownlen &&
5858 dsp->nfsclds_servownlen != 0 &&
5859 !NFSBCMP(dsp->nfsclds_serverown, newdsp->nfsclds_serverown,
5860 dsp->nfsclds_servownlen)) {
5861 NFSCL_DEBUG(4, "fnd same fdsp=%p dsp=%p flg=0x%x\n",
5862 TAILQ_FIRST(&nmp->nm_sess), dsp,
5863 dsp->nfsclds_flags);
5865 if ((dsp->nfsclds_flags & NFSCLDS_DS) != 0) {
5866 *retdspp = dsp;
5875 cur_dsp = dsp;
5890 nfsrpc_commitds(vnode_t vp, uint64_t offset, int cnt, struct nfsclds *dsp,
5900 NULL, &dsp->nfsclds_sess);
5905 nrp = dsp->nfsclds_sockp;
5910 NFS_PROG, NFS_VER4, NULL, 1, NULL, &dsp->nfsclds_sess);
5915 NFSLOCKDS(dsp);
5916 if (NFSBCMP(tl, dsp->nfsclds_verf, NFSX_VERF)) {
5917 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
5920 NFSUNLOCKDS(dsp);
Indexes created Mon Oct 20 16:09:52 GMT 2025