Lines Matching defs:dsp
92 * NFSDSP_SEQTHISSESSION - Use the nfsclds_sequence field of this dsp for new
114 struct nfsclds *dsp;
1043 struct nfsclds *dsp, *odsp;
1053 odsp = dsp = NULL;
1064 dsp = malloc(sizeof(struct nfsclds) +
1067 dsp->nfsclds_expire = NFSD_MONOSEC + clp->nfsc_renew;
1068 dsp->nfsclds_servownlen = odsp->nfsclds_servownlen;
1069 dsp->nfsclds_sess.nfsess_clientid =
1071 dsp->nfsclds_sess.nfsess_sequenceid =
1073 dsp->nfsclds_flags = odsp->nfsclds_flags;
1074 if (dsp->nfsclds_servownlen > 0)
1075 memcpy(dsp->nfsclds_serverown,
1077 dsp->nfsclds_servownlen + 1);
1078 mtx_init(&dsp->nfsclds_mtx, "nfsds", NULL, MTX_DEF);
1079 mtx_init(&dsp->nfsclds_sess.nfsess_mtx, "nfssession",
1081 nfscl_initsessionslots(&dsp->nfsclds_sess);
1082 error = nfsrpc_createsession(nmp, &dsp->nfsclds_sess,
1084 dsp->nfsclds_sess.nfsess_sequenceid, 1, cred, p);
1088 nfscl_freenfsclds(dsp);
1089 dsp = NULL;
1110 NFSV4EXCH_USEPNFSMDS | NFSV4EXCH_USENONPNFS, &dsp,
1115 &dsp->nfsclds_sess, &nmp->nm_sockreq, NULL,
1116 dsp->nfsclds_sess.nfsess_sequenceid, 1,
1130 dsp->nfsclds_sess.nfsess_sessionid,
1153 TAILQ_INSERT_HEAD(&nmp->nm_sess, dsp,
1167 } else if (dsp != NULL)
1168 nfscl_freenfsclds(dsp);
1186 dsp = malloc(sizeof(struct nfsclds), M_NFSCLDS, M_WAITOK | M_ZERO);
1187 mtx_init(&dsp->nfsclds_mtx, "nfsds", NULL, MTX_DEF);
1188 mtx_init(&dsp->nfsclds_sess.nfsess_mtx, "nfssession", NULL, MTX_DEF);
1190 TAILQ_INSERT_HEAD(&nmp->nm_sess, dsp, nfsclds_list);
5046 nfsrpc_renew(struct nfsclclient *clp, struct nfsclds *dsp, struct ucred *cred,
5060 if (dsp == NULL)
5065 &dsp->nfsclds_sess, 0, 0, NULL);
5074 if (dsp != NULL)
5075 nrp = dsp->nfsclds_sockp;
5080 if (dsp == NULL)
5085 NFS_PROG, NFS_VER4, NULL, 1, NULL, &dsp->nfsclds_sess);
5087 nfscl_cancelreqs(dsp);
5328 struct nfsclds *dsp;
5368 dsp = malloc(sizeof(struct nfsclds) + len + 1, M_NFSCLDS,
5370 dsp->nfsclds_expire = NFSD_MONOSEC + clp->nfsc_renew;
5371 dsp->nfsclds_servownlen = len;
5372 dsp->nfsclds_sess.nfsess_clientid.lval[0] = *tl++;
5373 dsp->nfsclds_sess.nfsess_clientid.lval[1] = *tl++;
5374 dsp->nfsclds_sess.nfsess_sequenceid =
5383 dsp->nfsclds_flags |= NFSCLDS_MDS;
5386 dsp->nfsclds_flags |= NFSCLDS_DS;
5388 dsp->nfsclds_flags |= NFSCLDS_MINORV2;
5391 dsp->nfsclds_serverown, len);
5393 mtx_init(&dsp->nfsclds_mtx, "nfsds", NULL, MTX_DEF);
5394 mtx_init(&dsp->nfsclds_sess.nfsess_mtx, "nfssession",
5396 nfscl_initsessionslots(&dsp->nfsclds_sess);
5397 *dspp = dsp;
5399 free(dsp, M_NFSCLDS);
5412 struct nfssockreq *nrp, struct nfsclds *dsp, uint32_t sequenceid, int mds,
5425 if (dsp == NULL)
5427 else if ((dsp->nfsclds_flags & NFSCLDS_MINORV2) != 0)
5622 struct nfsclds *dsp = NULL, **dspp, **gotdspp;
5827 gotvers, gotminor, &dsp, p);
5831 *gotdspp = dsp;
6101 struct nfsclds *dsp, *tdsp;
6249 dsp = NULL;
6256 minorvers, NFSV4EXCH_USEPNFSDS, &dsp,
6266 dsp = malloc(sizeof(struct nfsclds), M_NFSCLDS,
6268 dsp->nfsclds_flags |= NFSCLDS_DS;
6269 dsp->nfsclds_expire = INT32_MAX; /* No renews needed. */
6270 mtx_init(&dsp->nfsclds_mtx, "nfsds", NULL, MTX_DEF);
6271 mtx_init(&dsp->nfsclds_sess.nfsess_mtx, "nfssession",
6276 dsp->nfsclds_sockp = nrp;
6279 retv = nfscl_getsameserver(nmp, dsp, &tdsp,
6293 nfscl_freenfsclds(dsp);
6299 dsp->nfsclds_sess.nfsess_sequenceid;
6301 error = nfsrpc_createsession(nmp, &dsp->nfsclds_sess,
6302 nrp, dsp, sequenceid, 0, nrp->nr_cred, p);
6320 TAILQ_INSERT_TAIL(&nmp->nm_sess, dsp, nfsclds_list);
6322 *dspp = dsp;
6323 } else if (dsp != NULL) {
6325 nfscl_freenfsclds(dsp);
6956 struct nfsclds *dsp, uint64_t io_off, int len, struct nfsfh *fhp, int flex,
6970 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
6980 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
6989 nrp = dsp->nfsclds_sockp;
6995 NFS_PROG, vers, NULL, 1, NULL, &dsp->nfsclds_sess);
7031 nfsv4stateid_t *stateidp, struct nfsclds *dsp, uint64_t io_off, int len,
7048 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
7059 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
7077 nrp = dsp->nfsclds_sockp;
7082 NFS_PROG, vers, NULL, 1, NULL, &dsp->nfsclds_sess);
7144 NFSLOCKDS(dsp);
7145 if ((dsp->nfsclds_flags & NFSCLDS_HASWRITEVERF) == 0) {
7146 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
7147 dsp->nfsclds_flags |= NFSCLDS_HASWRITEVERF;
7148 } else if (NFSBCMP(tl, dsp->nfsclds_verf, NFSX_VERF) &&
7151 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
7153 NFSUNLOCKDS(dsp);
7172 nfsv4stateid_t *stateidp, struct nfsclds *dsp, uint64_t io_off, int len,
7187 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
7196 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
7213 nrp = dsp->nfsclds_sockp;
7218 NFS_PROG, vers, NULL, 1, NULL, &dsp->nfsclds_sess);
7255 NFSLOCKDS(dsp);
7256 if ((dsp->nfsclds_flags & NFSCLDS_HASWRITEVERF) == 0) {
7257 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
7258 dsp->nfsclds_flags |= NFSCLDS_HASWRITEVERF;
7259 } else if (NFSBCMP(tl, dsp->nfsclds_verf, NFSX_VERF) &&
7262 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
7264 NFSUNLOCKDS(dsp);
7285 &drpc->must_commit, drpc->stateidp, drpc->dsp, drpc->off, drpc->len,
7298 nfsv4stateid_t *stateidp, struct nfsclds *dsp, uint64_t off, int len,
7310 drpc->dsp = dsp;
7327 stateidp, dsp, off, len, fhp, m, vers, minorvers, cred, p);
7338 nfscl_freenfsclds(struct nfsclds *dsp)
7342 if (dsp == NULL)
7344 if (dsp->nfsclds_sockp != NULL) {
7345 NFSFREECRED(dsp->nfsclds_sockp->nr_cred);
7346 NFSFREEMUTEX(&dsp->nfsclds_sockp->nr_mtx);
7347 free(dsp->nfsclds_sockp->nr_nam, M_SONAME);
7348 free(dsp->nfsclds_sockp, M_NFSSOCKREQ);
7350 NFSFREEMUTEX(&dsp->nfsclds_mtx);
7351 NFSFREEMUTEX(&dsp->nfsclds_sess.nfsess_mtx);
7353 if (dsp->nfsclds_sess.nfsess_cbslots[i].nfssl_reply != NULL)
7355 dsp->nfsclds_sess.nfsess_cbslots[i].nfssl_reply);
7357 free(dsp, M_NFSCLDS);
7364 struct nfsclds *dsp;
7372 TAILQ_FOREACH(dsp, &nmp->nm_sess, nfsclds_list) {
7373 if (dsp->nfsclds_servownlen == newdsp->nfsclds_servownlen &&
7374 dsp->nfsclds_servownlen != 0 &&
7375 !NFSBCMP(dsp->nfsclds_serverown, newdsp->nfsclds_serverown,
7376 dsp->nfsclds_servownlen) &&
7377 dsp->nfsclds_sess.nfsess_defunct == 0) {
7378 NFSCL_DEBUG(4, "fnd same fdsp=%p dsp=%p flg=0x%x\n",
7379 TAILQ_FIRST(&nmp->nm_sess), dsp,
7380 dsp->nfsclds_flags);
7384 dsp->nfsclds_sess.nfsess_sequenceid;
7388 if ((dsp->nfsclds_flags & NFSCLDS_DS) != 0) {
7389 *retdspp = dsp;
7403 nfsrpc_commitds(vnode_t vp, uint64_t offset, int cnt, struct nfsclds *dsp,
7417 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
7422 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers,
7433 nrp = dsp->nfsclds_sockp;
7438 NFS_PROG, vers, NULL, 1, NULL, &dsp->nfsclds_sess);
7452 NFSLOCKDS(dsp);
7453 if (NFSBCMP(tl, dsp->nfsclds_verf, NFSX_VERF)) {
7454 NFSBCOPY(tl, dsp->nfsclds_verf, NFSX_VERF);
7457 NFSUNLOCKDS(dsp);
7476 drpc->dsp, drpc->fhp, drpc->vers, drpc->minorvers, drpc->cred,
7487 nfsio_commitds(vnode_t vp, uint64_t offset, int cnt, struct nfsclds *dsp,
7498 drpc->dsp = dsp;
7511 error = nfsrpc_commitds(vp, offset, cnt, dsp, fhp, vers,
7560 struct nfsclds *dsp, struct nfsfh *fhp, int vers, int minorvers,
7582 fhp->nfh_len, NULL, &dsp->nfsclds_sess, vers, minorvers, NULL);
7592 nrp = dsp->nfsclds_sockp;
7597 NFS_PROG, vers, NULL, 1, NULL, &dsp->nfsclds_sess);
7618 drpc->advise, drpc->dsp, drpc->fhp, drpc->vers, drpc->minorvers,
7630 struct nfsclds *dsp, struct nfsfh *fhp, int vers, int minorvers,
7641 drpc->dsp = dsp;
7654 error = nfsrpc_adviseds(vp, offset, cnt, advise, dsp, fhp, vers,