mirror of
https://gitee.com/mirrors_PX4/PX4-Autopilot.git
synced 2026-10-29 17:23:34 +08:00
NFS update; fix STM32 enabling of CAN2 clock
git-svn-id: https://nuttx.svn.sourceforge.net/svnroot/nuttx/trunk@4494 7fd9a85b-ad96-42d3-883c-3090e2eb8679
This commit is contained in:
patacongo
@@ -0,0 +1,230 @@
|
||||
/*
|
||||
* copyright (c) 2004
|
||||
* the regents of the university of michigan
|
||||
* all rights reserved
|
||||
*
|
||||
* permission is granted to use, copy, create derivative works and redistribute
|
||||
* this software and such derivative works for any purpose, so long as the name
|
||||
* of the university of michigan is not used in any advertising or publicity
|
||||
* pertaining to the use or distribution of this software without specific,
|
||||
* written prior authorization. if the above copyright notice or any other
|
||||
* identification of the university of michigan is included in any copy of any
|
||||
* portion of this software, then the disclaimer below must also be included.
|
||||
*
|
||||
* this software is provided as is, without representation from the university
|
||||
* of michigan as to its fitness for any purpose, and without warranty by the
|
||||
* university of michigan of any kind, either express or implied, including
|
||||
* without limitation the implied warranties of merchantability and fitness for
|
||||
* a particular purpose. the regents of the university of michigan shall not be
|
||||
* liable for any damages, including special, indirect, incidental, or
|
||||
* consequential damages, with respect to any claim arising out of or in
|
||||
* connection with the use of the software, even if it has been or is hereafter
|
||||
* advised of the possibility of such damages.
|
||||
*/
|
||||
|
||||
/* wrappers around rpcclnt */
|
||||
|
||||
/* XXX add tryagain code in nfs_request_xx */
|
||||
|
||||
/*
|
||||
* Socket operations for use by nfs
|
||||
*/
|
||||
|
||||
#include <sys/param.h>
|
||||
#include <sys/systm.h>
|
||||
#include <sys/kernel.h>
|
||||
#include <sys/malloc.h>
|
||||
#include <sys/mbuf.h>
|
||||
#include <sys/mount.h>
|
||||
#include <sys/socket.h>
|
||||
|
||||
#include "rpc_clnt.h"
|
||||
#include "rpc_v2.h"
|
||||
#include "nfs_proto.h
|
||||
#include "nfs.h"
|
||||
#include "xdr_subs.h"
|
||||
#include "nfsmount.h"
|
||||
//#include <nfsx/nfs_common.h>
|
||||
#include "nfs_socket.h"
|
||||
|
||||
/* Flag translations */
|
||||
#define nfsmnt_to_rpcclnt(nf, rf, name) do { \
|
||||
if (nf & NFSMNT_##name)) { \
|
||||
rf |= RPCCLNT_##name \
|
||||
} \
|
||||
} while(0)
|
||||
|
||||
static struct rpc_program nfs2_program =
|
||||
{
|
||||
NFS_PROG, NFS_VER2, "NFSv2"
|
||||
};
|
||||
|
||||
static struct rpc_program nfs3_program =
|
||||
{
|
||||
NFS_PROG, NFS_VER3, "NFSv3"
|
||||
};
|
||||
|
||||
static struct rpc_program nfs4_program =
|
||||
{
|
||||
NFS_PROG, NFS_VER4, "NFSv4"
|
||||
};
|
||||
|
||||
/* XXXMARIUS: name collision */
|
||||
int nfsx_connect(struct nfsmount *nmp)
|
||||
{
|
||||
struct rpcclnt *rpc;
|
||||
int error = 0;
|
||||
|
||||
if (nmp == NULL)
|
||||
return EFAULT;
|
||||
|
||||
rpc = &nmp->nm_rpcclnt;
|
||||
|
||||
rpc->rc_prog = &nfs3_program;
|
||||
|
||||
printf("nfsxconnect!\n");
|
||||
|
||||
/* translate nfsmnt flags -> rpcclnt flags */
|
||||
rpc->rc_flag = 0;
|
||||
nfsmnt_to_rpcclnt(nmp->nm_flag, rpc->rc_flag, SOFT);
|
||||
nfsmnt_to_rpcclnt(nmp->nm_flag, rpc->rc_flag, INT);
|
||||
nfsmnt_to_rpcclnt(nmp->nm_flag, rpc->rc_flag, NOCONN);
|
||||
nfsmnt_to_rpcclnt(nmp->nm_flag, rpc->rc_flag, DUMBTIMR);
|
||||
|
||||
rpc->rc_flag |= RPCCLNT_REDIRECT; /* Make this a mount option. */
|
||||
|
||||
rpc->rc_authtype = RPCAUTH_NULL; /* for now */
|
||||
rpc->rc_servername = nmp->nm_mountp->mnt_stat.f_mntfromname;
|
||||
rpc->rc_name = (struct sockaddr *)nmp->nm_nam;
|
||||
|
||||
rpc->rc_sotype = nmp->nm_sotype;
|
||||
rpc->rc_soproto = nmp->nm_soproto;
|
||||
rpc->rc_rsize = (nmp->nm_rsize > nmp->nm_readdirsize) ?
|
||||
nmp->nm_rsize : nmp->nm_readdirsize;
|
||||
rpc->rc_wsize = nmp->nm_wsize;
|
||||
rpc->rc_deadthresh = nmp->nm_deadthresh;
|
||||
rpc->rc_timeo = nmp->nm_timeo;
|
||||
rpc->rc_retry = nmp->nm_retry;
|
||||
|
||||
/* XXX v2,3 need to use this */
|
||||
rpc->rc_proctlen = 0;
|
||||
rpc->rc_proct = NULL;
|
||||
|
||||
if (error)
|
||||
return error;
|
||||
|
||||
return rpcclnt_connect(rpc);
|
||||
}
|
||||
|
||||
/* NFS disconnect. Clean up and unlink. */
|
||||
|
||||
/* XXXMARIUS: name collision */
|
||||
|
||||
void nfsx_disconnect(struct nfsmount *nmp)
|
||||
{
|
||||
rpcclnt_disconnect(&nmp->nm_rpcclnt);
|
||||
}
|
||||
|
||||
#ifdef CONFIG_NFS_TCPIP
|
||||
void nfsx_safedisconnect(struct nfsmount *nmp)
|
||||
{
|
||||
rpcclnt_safedisconnect(&nmp->nm_rpcclnt);
|
||||
}
|
||||
#endif
|
||||
|
||||
int
|
||||
nfsx_request_xx(struct nfsmount *nm, struct vnode *vp, struct mbuf *mrest,
|
||||
int procnum, cthread_t * td, struct ucred *cred,
|
||||
struct mbuf **mrp, struct mbuf **mdp, caddr_t * dposp)
|
||||
{
|
||||
int error;
|
||||
u_int32_t *tl;
|
||||
struct nfsmount *nmp;
|
||||
struct rpcclnt *clnt;
|
||||
struct mbuf *md, *mrep;
|
||||
caddr_t dpos;
|
||||
struct rpc_reply reply;
|
||||
#if 0
|
||||
int t1;
|
||||
#endif /* 0 */
|
||||
|
||||
if (vp != NULL)
|
||||
nmp = VFSTONFS(vp->v_mount);
|
||||
else
|
||||
nmp = nm;
|
||||
|
||||
clnt = &nmp->nm_rpcclnt;
|
||||
|
||||
#if 0
|
||||
tryagain:
|
||||
#endif
|
||||
|
||||
memset(&reply, 0, sizeof(reply));
|
||||
|
||||
if ((error = rpcclnt_request(clnt, mrest, procnum, td, cred, &reply)) != 0)
|
||||
goto out;
|
||||
|
||||
mrep = reply.mrep;
|
||||
md = reply.result_md;
|
||||
dpos = reply.result_dpos;
|
||||
|
||||
tl = nfsm_dissect(u_int32_t *, NFSX_UNSIGNED);
|
||||
if (*tl != 0)
|
||||
{
|
||||
error = fxdr_unsigned(int, *tl);
|
||||
#if 0
|
||||
if ((nmp->nm_flag & NFSMNT_NFSV3) && error == NFSERR_TRYLATER)
|
||||
{
|
||||
m_freem(mrep);
|
||||
error = 0;
|
||||
waituntil = time_second + trylater_delay;
|
||||
while (time_second < waituntil)
|
||||
(void)tsleep(&lbolt, PSOCK, "nqnfstry", 0);
|
||||
trylater_delay *= nfs_backoff[trylater_cnt];
|
||||
if (trylater_cnt < NFS_NBACKOFF - 1)
|
||||
trylater_cnt++;
|
||||
goto tryagain;
|
||||
}
|
||||
#endif
|
||||
|
||||
/*
|
||||
** If the File Handle was stale, invalidate the
|
||||
** lookup cache, just in case.
|
||||
**/
|
||||
if (error == ESTALE)
|
||||
if (vp != NULL)
|
||||
cache_purge(vp);
|
||||
else
|
||||
printf("%s: ESTALE on mount from server %s\n",
|
||||
nmp->nm_rpcclnt.rc_prog->prog_name,
|
||||
nmp->nm_rpcclnt.rc_servername);
|
||||
else
|
||||
printf("%s: unknown error %d from server %s\n",
|
||||
nmp->nm_rpcclnt.rc_prog->prog_name, error,
|
||||
nmp->nm_rpcclnt.rc_servername);
|
||||
goto out;
|
||||
}
|
||||
|
||||
m_freem(mrest);
|
||||
|
||||
*mrp = mrep;
|
||||
*mdp = md;
|
||||
*dposp = dpos;
|
||||
return (0);
|
||||
nfsmout:
|
||||
out:
|
||||
/* XXX: don't free mrest if an error occured, to allow caller to retry */
|
||||
m_freem(mrest);
|
||||
m_freem(reply.mrep);
|
||||
*mrp = NULL;
|
||||
*mdp = NULL;
|
||||
|
||||
return (error);
|
||||
}
|
||||
|
||||
/* terminate any outstanding RPCs. */
|
||||
|
||||
int nfsx_nmcancelreqs(struct nfsmount *nmp)
|
||||
{
|
||||
return rpcclnt_cancelreqs(&nmp->nm_rpcclnt);
|
||||
}
|
||||
Reference in New Issue
Block a user