From 49ed802643ee651998141f1f410bab5b3a0839cb Mon Sep 17 00:00:00 2001 From: patacongo Date: Fri, 27 Apr 2012 23:29:24 +0000 Subject: NFS update git-svn-id: svn://svn.code.sf.net/p/nuttx/code/trunk@4667 42af7a65-404d-4744-a932-0658087f49c3 --- nuttx/fs/nfs/nfs_socket.c | 2 +- nuttx/fs/nfs/nfs_vfsops.c | 276 +++++++++++++++++++++++----------------------- nuttx/fs/nfs/rpc_clnt.c | 47 +++++--- nuttx/fs/nfs/xdr_subs.h | 4 +- 4 files changed, 172 insertions(+), 157 deletions(-) diff --git a/nuttx/fs/nfs/nfs_socket.c b/nuttx/fs/nfs/nfs_socket.c index 1ddfe63c3..5e130d3b5 100644 --- a/nuttx/fs/nfs/nfs_socket.c +++ b/nuttx/fs/nfs/nfs_socket.c @@ -176,7 +176,7 @@ int nfs_request(struct nfsmount *nmp, int procnum, void *datain, void *dataout) { int error; struct rpcclnt *clnt; - struct rpc_reply *reply = NULL; + struct rpc_reply *reply; int trylater_delay; clnt = nmp->nm_rpcclnt; diff --git a/nuttx/fs/nfs/nfs_vfsops.c b/nuttx/fs/nfs/nfs_vfsops.c index c889a603f..113df67b2 100644 --- a/nuttx/fs/nfs/nfs_vfsops.c +++ b/nuttx/fs/nfs/nfs_vfsops.c @@ -45,7 +45,7 @@ ****************************************************************************/ #include - + #include #include #include @@ -89,7 +89,7 @@ /**************************************************************************** * Private Type Definitions ****************************************************************************/ - + struct nfs_dirent { uint32_t cookie[2]; @@ -176,7 +176,7 @@ const struct mountpt_operations nfs_operations = ****************************************************************************/ static int -nfs_open(FAR struct file *filep, FAR const char *relpath, +nfs_open(FAR struct file *filep, FAR const char *relpath, int oflags, mode_t mode) { struct inode *in; @@ -184,9 +184,9 @@ nfs_open(FAR struct file *filep, FAR const char *relpath, struct nfsv3_sattr sp; struct nfsmount *nmp; struct nfsnode *np; - struct CREATE3args *create = NULL; - struct CREATE3resok *resok = NULL; - void *datareply = NULL; + struct CREATE3args create; + struct CREATE3resok *resok; + void *datareply; int error = 0; /* Sanity checks */ @@ -230,11 +230,11 @@ again: sp.sa_atime = vap.fa3_atime; sp.sa_mtime = vap.fa3_mtime; - create->how = sp; - create->where.dir = nmp->nm_fh; - create->where.name = relpath; + create.how = sp; + create.where.dir = nmp->nm_fh; + create.where.name = relpath; - error = nfs_request(nmp, NFSPROC_CREATE, create, datareply); + error = nfs_request(nmp, NFSPROC_CREATE, &create, datareply); if (!error) { /* Create an instance of the file private data to describe the opened @@ -352,16 +352,16 @@ static int nfs_close(FAR struct file *filep) done * Name: nfs_read ****************************************************************************/ -static ssize_t nfs_read(FAR struct file *filep, char *buffer, size_t buflen) +static ssize_t nfs_read(FAR struct file *filep, char *buffer, size_t buflen) { struct nfsmount *nmp; struct nfsnode *np; unsigned int readsize; int bytesleft; uint64_t offset; - void *datareply = NULL; - struct READ3args *read = NULL; - struct READ3resok *resok = NULL; + void *datareply; + struct READ3args read; + struct READ3resok *resok; uint8_t *userbuffer = (uint8_t*)buffer; int error = 0; int len; @@ -417,37 +417,38 @@ static ssize_t nfs_read(FAR struct file *filep, char *buffer, size_t buflen) buflen = bytesleft; } - len = nmp->nm_rsize; - if (len < buflen) - { - error = EFBIG; - goto errout_with_semaphore; - } + len = nmp->nm_rsize; + if (len < buflen) + { + error = EFBIG; + goto errout_with_semaphore; + } + + nfsstats.rpccnt[NFSPROC_READ]++; - nfsstats.rpccnt[NFSPROC_READ]++; again: - read->file = np->nfsv3_type; - read->count = buflen; - read->offset = offset; + read.file = np->nfsv3_type; + read.count = buflen; + read.offset = offset; - error = nfs_request(nmp, NFSPROC_READ, read, datareply); - if (error) - { - goto errout_with_semaphore; - } + error = nfs_request(nmp, NFSPROC_READ, &read, datareply); + if (error) + { + goto errout_with_semaphore; + } - resok = (struct READ3resok *) datareply; - eof = resok->eof; - if (eof == true) - { - readsize = resok->count; - np->n_fattr = resok->file_attributes; - memcpy(userbuffer, resok->data, readsize); - } - else - { - goto again; - } + resok = (struct READ3resok *) datareply; + eof = resok->eof; + if (eof == true) + { + readsize = resok->count; + np->n_fattr = resok->file_attributes; + memcpy(userbuffer, resok->data, readsize); + } + else + { + goto again; + } nfs_semgive(nmp); return readsize; @@ -462,15 +463,15 @@ errout_with_semaphore: ****************************************************************************/ static ssize_t -nfs_write(FAR struct file *filep, const char *buffer, size_t buflen) +nfs_write(FAR struct file *filep, const char *buffer, size_t buflen) { struct inode *inode; struct nfsmount *nmp; struct nfsnode *np; unsigned int writesize; - void *datareply = NULL; - struct WRITE3args *write = NULL; - struct WRITE3resok *resok =NULL; + void *datareply; + struct WRITE3args write; + struct WRITE3resok *resok; uint8_t *userbuffer = (uint8_t*)buffer; int error = 0; uint64_t offset; @@ -517,13 +518,13 @@ nfs_write(FAR struct file *filep, const char *buffer, size_t buflen) writesize = 0; nfsstats.rpccnt[NFSPROC_WRITE]++; - write->file = np->nfsv3_type; - write->offset = offset; - write->count = buflen; - write->stable = committed; - memcpy((void *)write->data, userbuffer, buflen); + write.file = np->nfsv3_type; + write.offset = offset; + write.count = buflen; + write.stable = committed; + memcpy((void *)write.data, userbuffer, buflen); - error = nfs_request(nmp, NFSPROC_WRITE, write, datareply); + error = nfs_request(nmp, NFSPROC_WRITE, &write, datareply); if (error) { goto errout_with_semaphore; @@ -578,12 +579,13 @@ errout_with_semaphore: * Description: The function below stuff the cookies in after the name. ****************************************************************************/ -int nfs_readdirrpc(struct nfsmount *nmp, struct nfsnode *np, bool end_of_directory, struct fs_dirent_s *dir) +int nfs_readdirrpc(struct nfsmount *nmp, struct nfsnode *np, + bool end_of_directory, struct fs_dirent_s *dir) { int error = 0; void *datareply = NULL; - struct READDIR3args *readir = NULL; - struct READDIR3resok *resok = NULL; + struct READDIR3args readir; + struct READDIR3resok *resok; /* Loop around doing readdir rpc's of size nm_readdirsize * truncated to a multiple of NFS_READDIRBLKSIZ. @@ -593,44 +595,44 @@ int nfs_readdirrpc(struct nfsmount *nmp, struct nfsnode *np, bool end_of_directo while (end_of_directory == false) { nfsstats.rpccnt[NFSPROC_READDIR]++; - readir->dir = np->n_fhp; - readir->count = nmp->nm_readdirsize; + readir.dir = np->n_fhp; + readir.count = nmp->nm_readdirsize; if (nfsstats.rpccnt[NFSPROC_READDIR] == 1) { - readir->cookie.nfsuquad[0] = 0; - readir->cookie.nfsuquad[1] = 0; - readir->cookieverf.nfsuquad[0] = 0; - readir->cookieverf.nfsuquad[1] = 0; + readir.cookie.nfsuquad[0] = 0; + readir.cookie.nfsuquad[1] = 0; + readir.cookieverf.nfsuquad[0] = 0; + readir.cookieverf.nfsuquad[1] = 0; } else { - readir->cookie.nfsuquad[0] = dir->u.nfs.cookie[0]; - readir->cookie.nfsuquad[1] = dir->u.nfs.cookie[1]; - readir->cookieverf.nfsuquad[0] = np->n_cookieverf.nfsuquad[0]; - readir->cookieverf.nfsuquad[1] = np->n_cookieverf.nfsuquad[1]; + readir.cookie.nfsuquad[0] = dir->u.nfs.cookie[0]; + readir.cookie.nfsuquad[1] = dir->u.nfs.cookie[1]; + readir.cookieverf.nfsuquad[0] = np->n_cookieverf.nfsuquad[0]; + readir.cookieverf.nfsuquad[1] = np->n_cookieverf.nfsuquad[1]; } - error = nfs_request(nmp, NFSPROC_READDIR, readir, datareply); + error = nfs_request(nmp, NFSPROC_READDIR, &readir, datareply); if (error) { goto nfsmout; } - resok = (struct READDIR3resok*) datareply; - np->n_fattr = resok->dir_attributes; - np->n_cookieverf.nfsuquad[0] = resok->cookieverf.nfsuquad[0]; - np->n_cookieverf.nfsuquad[1] = resok->cookieverf.nfsuquad[1]; - dir->fd_dir.d_type = resok->reply.entries->fileid; - memcpy(&dir->fd_dir.d_name[NAME_MAX], &resok->reply.entries->name, NAME_MAX); - //dir->fd_dir.d_name = resok->reply.entries->name;// - dir->u.nfs.cookie[0] = resok->reply.entries->cookie.nfsuquad[0]; - dir->u.nfs.cookie[1] = resok->reply.entries->cookie.nfsuquad[1]; - - if(resok->reply.eof == true) - { - end_of_directory = true; - } + resok = (struct READDIR3resok*) datareply; + np->n_fattr = resok->dir_attributes; + np->n_cookieverf.nfsuquad[0] = resok->cookieverf.nfsuquad[0]; + np->n_cookieverf.nfsuquad[1] = resok->cookieverf.nfsuquad[1]; + dir->fd_dir.d_type = resok->reply.entries->fileid; + memcpy(&dir->fd_dir.d_name[NAME_MAX], &resok->reply.entries->name, NAME_MAX); + //dir->fd_dir.d_name = resok->reply.entries->name;// + dir->u.nfs.cookie[0] = resok->reply.entries->cookie.nfsuquad[0]; + dir->u.nfs.cookie[1] = resok->reply.entries->cookie.nfsuquad[1]; + + if(resok->reply.eof == true) + { + end_of_directory = true; + } //more_dirs = fxdr_unsigned(int, *dp); @@ -675,7 +677,6 @@ nfsmout: return error; } - /**************************************************************************** * Name: nfs_readdir * @@ -683,7 +684,7 @@ nfsmout: * ****************************************************************************/ -static int nfs_readdir(struct inode *mountpt, struct fs_dirent_s *dir) +static int nfs_readdir(struct inode *mountpt, struct fs_dirent_s *dir) { int error = 0; struct nfsmount *nmp; @@ -741,7 +742,7 @@ static int nfs_readdir(struct inode *mountpt, struct fs_dirent_s *dir) { error = EINVAL; } - + if (!error && eof) { nfsstats.direofcache_misses++; @@ -758,7 +759,7 @@ errout_with_semaphore: * Name: nfs_decode_args ****************************************************************************/ -void nfs_decode_args(struct nfsmount *nmp, struct nfs_args *argp) +void nfs_decode_args(struct nfsmount *nmp, struct nfs_args *argp) { int adjsock = 0; int maxio; @@ -980,7 +981,7 @@ void nfs_decode_args(struct nfsmount *nmp, struct nfs_args *argp) * ****************************************************************************/ -int mountnfs(struct nfs_args *argp, struct sockaddr *nam, void **handle) +int mountnfs(struct nfs_args *argp, struct sockaddr *nam, void **handle) { struct nfsmount *nmp; int error; @@ -1041,7 +1042,7 @@ int mountnfs(struct nfs_args *argp, struct sockaddr *nam, void **handle) nmp->nm_mounted = true; nmp->nm_so = nmp->nm_rpcclnt->rc_so; - *handle = &nmp; + *handle = (void*)nmp; nfs_semgive(nmp); return 0; @@ -1064,7 +1065,7 @@ bad: * ****************************************************************************/ -static int nfs_bind(struct inode *blkdriver, const void *data, void **handle) +static int nfs_bind(struct inode *blkdriver, const void *data, void **handle) { int error; struct nfs_args args; @@ -1103,7 +1104,7 @@ static int nfs_bind(struct inode *blkdriver, const void *data, void **handle) * ****************************************************************************/ -int nfs_unbind(void *handle, struct inode **blkdriver) +int nfs_unbind(void *handle, struct inode **blkdriver) { struct nfsmount *nmp = (struct nfsmount *) handle ; int error; @@ -1146,12 +1147,11 @@ int nfs_unbind(void *handle, struct inode **blkdriver) { *blkdriver = inode; } - } } */ /* Release the mountpoint private data */ - + nfs_disconnect(nmp); sem_destroy(&nmp->nm_sem); kfree(nmp); @@ -1170,14 +1170,14 @@ int nfs_unbind(void *handle, struct inode **blkdriver) * ****************************************************************************/ -static int nfs_statfs(struct inode *mountpt, struct statfs *sbp) +static int nfs_statfs(struct inode *mountpt, struct statfs *sbp) { - struct nfs_statfs *sfp = NULL; + struct nfs_statfs *sfp; struct nfsmount *nmp; int error = 0; uint64_t tquad; - void *datareply = NULL; - struct FSSTAT3args *fsstat = NULL; + void *datareply; + struct FSSTAT3args fsstat; int info_v3; /* Sanity checks */ @@ -1210,8 +1210,8 @@ static int nfs_statfs(struct inode *mountpt, struct statfs *sbp) } nfsstats.rpccnt[NFSPROC_FSSTAT]++; - fsstat->fsroot = nmp->nm_fh; - error = nfs_request(nmp, NFSPROC_FSSTAT, fsstat, datareply); + fsstat.fsroot = nmp->nm_fh; + error = nfs_request(nmp, NFSPROC_FSSTAT, &fsstat, datareply); if (error) { goto errout_with_semaphore; @@ -1261,9 +1261,9 @@ static int nfs_remove(struct inode *mountpt, const char *relpath) { struct nfsmount *nmp; struct nfsnode *np; - void *datareply = NULL; - struct REMOVE3args *remove = NULL; - struct REMOVE3resok *resok = NULL; + void *datareply; + struct REMOVE3args remove; + struct REMOVE3resok *resok; int error = 0; /* Sanity checks */ @@ -1297,10 +1297,10 @@ static int nfs_remove(struct inode *mountpt, const char *relpath) /* Do the rpc */ nfsstats.rpccnt[NFSPROC_REMOVE]++; - remove->object.dir = np->n_fhp; - remove->object.name = relpath; + remove.object.dir = np->n_fhp; + remove.object.name = relpath; - error = nfs_request(nmp, NFSPROC_REMOVE, remove, datareply); + error = nfs_request(nmp, NFSPROC_REMOVE, &remove, datareply); /* Kludge City: If the first reply to the remove rpc is lost.. * the reply to the retransmitted request will be ENOENT @@ -1342,9 +1342,9 @@ static int nfs_mkdir(struct inode *mountpt, const char *relpath, mode_t mode) struct nfsv3_sattr sp; struct nfsmount *nmp; struct nfsnode *np; - struct MKDIR3args *mkir = NULL; - struct MKDIR3resok *resok = NULL; - void *datareply = NULL; + struct MKDIR3args mkir; + struct MKDIR3resok *resok; + void *datareply; int error = 0; /* Sanity checks */ @@ -1367,8 +1367,8 @@ static int nfs_mkdir(struct inode *mountpt, const char *relpath, mode_t mode) } nfsstats.rpccnt[NFSPROC_MKDIR]++; - mkir->where.dir = nmp->nm_fh; - mkir->where.name = relpath; + mkir.where.dir = nmp->nm_fh; + mkir.where.name = relpath; sp.sa_modetrue = nfs_true; sp.sa_mode = txdr_unsigned(vap.fa_mode); @@ -1381,9 +1381,9 @@ static int nfs_mkdir(struct inode *mountpt, const char *relpath, mode_t mode) fxdr_nfsv3time2(&vap.fa3_atime, &sp.sa_atime); fxdr_nfsv3time2(&vap.fa3_mtime, &sp.sa_mtime); - mkir->attributes = sp; + mkir.attributes = sp; - error = nfs_request(nmp, NFSPROC_MKDIR, mkdir, datareply); + error = nfs_request(nmp, NFSPROC_MKDIR, &mkir, datareply); if (error) { goto errout_with_semaphore; @@ -1392,7 +1392,7 @@ static int nfs_mkdir(struct inode *mountpt, const char *relpath, mode_t mode) resok = (struct MKDIR3resok *) datareply; np->nfsv3_type = NFDIR; np->n_fhp = resok->handle; - np->n_fattr = resok->obj_attributes; + np->n_fattr = resok->obj_attributes; np->n_flag |= NMODIFIED; NFS_INVALIDATE_ATTRCACHE(np); @@ -1412,9 +1412,9 @@ static int nfs_rmdir(struct inode *mountpt, const char *relpath) { struct nfsmount *nmp; struct nfsnode *np; - struct RMDIR3args *rmdir = NULL; - struct RMDIR3resok *resok = NULL; - void *datareply = NULL; + struct RMDIR3args rmdir; + struct RMDIR3resok *resok; + void *datareply; int error = 0; /* Sanity checks */ @@ -1441,12 +1441,12 @@ static int nfs_rmdir(struct inode *mountpt, const char *relpath) } /* Do the rpc */ - + nfsstats.rpccnt[NFSPROC_RMDIR]++; - rmdir->object.dir = np->n_fhp; - rmdir->object.name = relpath; - error = nfs_request(nmp, NFSPROC_RMDIR, rmdir, datareply); - + rmdir.object.dir = np->n_fhp; + rmdir.object.name = relpath; + error = nfs_request(nmp, NFSPROC_RMDIR, &rmdir, datareply); + if (error == ENOENT) { error = 0; @@ -1461,11 +1461,11 @@ static int nfs_rmdir(struct inode *mountpt, const char *relpath) np->n_fattr = resok->dir_wcc.after; np->n_flag |= NMODIFIED; } - NFS_INVALIDATE_ATTRCACHE(np); + NFS_INVALIDATE_ATTRCACHE(np); errout_with_semaphore: - nfs_semgive(nmp); - return error; + nfs_semgive(nmp); + return error; } /**************************************************************************** @@ -1475,14 +1475,14 @@ errout_with_semaphore: * ****************************************************************************/ -static int nfs_rename(struct inode *mountpt, const char *oldrelpath, +static int nfs_rename(struct inode *mountpt, const char *oldrelpath, const char *newrelpath) { struct nfsmount *nmp; struct nfsnode *np; - void *datareply = NULL; - struct RENAME3args *rename = NULL; - struct RENAME3resok *resok = NULL; + void *datareply; + struct RENAME3args rename; + struct RENAME3resok *resok; int error = 0; /* Sanity checks */ @@ -1511,12 +1511,12 @@ static int nfs_rename(struct inode *mountpt, const char *oldrelpath, } nfsstats.rpccnt[NFSPROC_RENAME]++; - rename->from.dir = np->n_fhp; - rename->from.name = oldrelpath; - rename->to.dir = np->n_fhp; - rename->to.name = newrelpath; + rename.from.dir = np->n_fhp; + rename.from.name = oldrelpath; + rename.to.dir = np->n_fhp; + rename.to.name = newrelpath; - error = nfs_request(nmp, NFSPROC_RENAME, rename, datareply); + error = nfs_request(nmp, NFSPROC_RENAME, &rename, datareply); /* Kludge: Map ENOENT => 0 assuming that it is a reply to a retry. */ @@ -1536,8 +1536,8 @@ static int nfs_rename(struct inode *mountpt, const char *oldrelpath, NFS_INVALIDATE_ATTRCACHE(np); errout_with_semaphore: - nfs_semgive(nmp); - return error; + nfs_semgive(nmp); + return error; } /**************************************************************************** @@ -1547,14 +1547,14 @@ errout_with_semaphore: * ****************************************************************************/ -static int nfs_fsinfo(struct inode *mountpt, const char *relpath, struct stat *buf) +static int nfs_fsinfo(struct inode *mountpt, const char *relpath, struct stat *buf) { struct nfsv3_fsinfo *fsp; - struct FSINFOargs *fsinfo = NULL; + struct FSINFOargs fsinfo; struct nfsmount *nmp; uint32_t pref, max; int error = 0; - void *datareply = NULL; + void *datareply; /* Sanity checks */ @@ -1575,8 +1575,8 @@ static int nfs_fsinfo(struct inode *mountpt, const char *relpath, struct stat *b memset(buf, 0, sizeof(struct stat)); nfsstats.rpccnt[NFSPROC_FSINFO]++; - fsinfo->fsroot = nmp->nm_fh; - error = nfs_request(nmp, NFSPROC_FSINFO, fsinfo, datareply); + fsinfo.fsroot = nmp->nm_fh; + error = nfs_request(nmp, NFSPROC_FSINFO, &fsinfo, datareply); if (error) { goto errout_with_semaphore; @@ -1651,7 +1651,7 @@ errout_with_semaphore: * ****************************************************************************/ -int nfs_sync(struct file *filep) +int nfs_sync(struct file *filep) { struct inode *inode; struct nfsmount *nmp; @@ -1685,7 +1685,7 @@ int nfs_sync(struct file *filep) if ((np->n_flag & NMODIFIED) != 0) { - //error = VOP_FSYNC(vp, cred, waitfor, p); + //error = VOP_FSYNC(vp, cred, waitfor, p); } return error; diff --git a/nuttx/fs/nfs/rpc_clnt.c b/nuttx/fs/nfs/rpc_clnt.c index 0e83a7519..86ceab169 100644 --- a/nuttx/fs/nfs/rpc_clnt.c +++ b/nuttx/fs/nfs/rpc_clnt.c @@ -179,8 +179,15 @@ static int rpcclnt_backoff[8] = { 2, 4, 8, 16, 32, 64, 128, 256, }; /* Static data, mostly RPC constants in XDR form */ -static uint32_t rpc_reply, rpc_call, rpc_vers, rpc_msgdenied, - rpc_mismatch, rpc_auth_unix, rpc_msgaccepted, rpc_autherr, rpc_auth_null; +static uint32_t rpc_reply; +static uint32_t rpc_call; +static uint32_t rpc_vers; +static uint32_t rpc_msgdenied; +static uint32_t rpc_mismatch; +static uint32_t rpc_auth_unix; +static uint32_t rpc_msgaccepted; +static uint32_t rpc_autherr; +static uint32_t rpc_auth_null; static uint32_t rpcclnt_xid = 0; static uint32_t rpcclnt_xid_touched = 0; @@ -236,7 +243,11 @@ rpcclnt_send(struct socket *so, struct sockaddr *nam, struct rpc_call *call, struct rpctask *rep) { struct sockaddr *sendnam; - int error, soflags, flags; + int error; +#ifdef CONFIG_NFS_TCPIP + int soflags; +#endif + int flags; if (rep != NULL) { @@ -252,14 +263,16 @@ rpcclnt_send(struct socket *so, struct sockaddr *nam, struct rpc_call *call, } rep->r_flags &= ~TASK_MUSTRESEND; +#ifdef CONFIG_NFS_TCPIP soflags = rep->r_rpcclnt->rc_soflags; +#endif } +#ifdef CONFIG_NFS_TCPIP else { soflags = so->s_flags; } -#ifdef CONFIG_NFS_TCPIP if ((soflags & PR_CONNREQUIRED)) { sendnam = NULL; @@ -330,9 +343,12 @@ static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname, struct socket *so; #ifdef CONFIG_NFS_TCPIP uint32_t len; + int sotype; #endif - int error, sotype, rcvflg; + int error; + int rcvflg; +#ifdef CONFIG_NFS_TCPIP /* Set up arguments for soreceive() */ sotype = rep->r_rpcclnt->rc_sotype; @@ -344,7 +360,6 @@ static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname, * rpc request/reply. */ -#ifdef CONFIG_NFS_TCPIP if (sotype != SOCK_DGRAM) { error = rpcclnt_sndlock(&rep->r_rpcclnt->rc_flag, rep); @@ -554,7 +569,7 @@ rpcclnt_reply(struct rpctask *myrep, struct rpc_call *call, struct rpctask *rep; struct rpcclnt *rpc = myrep->r_rpcclnt; int32_t t1; - struct sockaddr *nam = NULL; + struct sockaddr *nam; uint32_t rxid; int error; @@ -1110,26 +1125,25 @@ void rpcclnt_safedisconnect(struct rpcclnt *rpc) int rpcclnt_request(struct rpcclnt *rpc, int procnum, struct rpc_reply *reply, void *datain) { - struct rpc_call *call = NULL; - struct rpc_reply *replysvr = NULL; + struct rpc_call callhost; + struct rpc_reply replysvr; struct rpctask *task, _task; int error = 0; int xid = 0; task = &_task; - task->r_rpcclnt = rpc; task->r_procnum = procnum; - error = rpcclnt_buildheader(rpc, procnum, xid, datain, call); + error = rpcclnt_buildheader(rpc, procnum, xid, datain, &callhost); if (error) { ndbg("building call header error"); goto rpcmout; } - task->r_xid = fxdr_unsigned(uint32_t, xid); + task->r_xid = fxdr_unsigned(uint32_t,xid); if (rpc->rc_flag & RPCCLNT_SOFT) { @@ -1179,7 +1193,7 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, struct rpc_reply *reply, v if (error == 0) { - error = rpcclnt_send(rpc->rc_so, rpc->rc_name, call, task); + error = rpcclnt_send(rpc->rc_so, rpc->rc_name, &callhost, task); #ifdef CONFIG_NFS_TCPIP if (rpc->rc_soflags & PR_CONNREQUIRED) @@ -1203,7 +1217,7 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, struct rpc_reply *reply, v if (error == 0 || error == EPIPE) { - error = rpcclnt_reply(task, call, replysvr); + error = rpcclnt_reply(task, &callhost, replysvr); } /* RPC done, unlink the request. */ @@ -1276,8 +1290,9 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, struct rpc_reply *reply, v fxdr_unsigned(uint32_t, replysvr->stat.mismatch_info.low); reply->stat.mismatch_info.high = fxdr_unsigned(uint32_t, replysvr->stat.mismatch_info.high); + ndbg("RPC_MSGACCEPTED: RPC_PROGMISMATCH error"); - error = EOPNOTSUPP; + error = EOPNOTSUPP; } else if (reply->stat.status > 5) { @@ -1430,7 +1445,7 @@ void rpcclnt_timer(void *arg, struct rpc_call *call) int rpcclnt_buildheader(struct rpcclnt *rc, int procid, int xidp, void *datain, struct rpc_call *call) { - struct timeval *tv = NULL; + struct timeval *tv; srand(time(NULL)); /* The RPC header.*/ diff --git a/nuttx/fs/nfs/xdr_subs.h b/nuttx/fs/nfs/xdr_subs.h index 223f00fee..0d75b7281 100644 --- a/nuttx/fs/nfs/xdr_subs.h +++ b/nuttx/fs/nfs/xdr_subs.h @@ -64,8 +64,8 @@ * but we cannot count on their alignment anyway. */ -#define fxdr_unsigned(t, v) ((t)ntohl((int32_t)(v))) -#define txdr_unsigned(v) (htonl((int32_t)(v))) +#define fxdr_unsigned(t, v) ((t)ntohl(v)) +#define txdr_unsigned(v) (htonl(v)) #define fxdr_nfsv2time(f, t) { \ (t)->tv_sec = ntohl(((struct nfsv2_time *)(f))->nfsv2_sec); \ -- cgit v1.2.3