sergiotarxz/nuttx
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

NFS update

Browse Source 
git-svn-id: svn://svn.code.sf.net/p/nuttx/code/trunk@4749 42af7a65-404d-4744-a932-0658087f49c3
This commit is contained in:
patacongo 2012-05-19 01:46:02 +00:00
parent 9efa4813ac
commit 61d0babe77
2 changed files with 232 additions and 93 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
fs/nfs/rpc.h
View File

@ -126,20 +126,20 @@ struct call_args_pmap
struct call_result_pmap struct call_result_pmap
{ {
uint16_t port; uint32_t port;
}; };
/* MOUNTD headers */ /* MOUNTD headers */
struct call_args_mount struct call_args_mount
{ {
uint32_t len;
char *rpath; char *rpath;
uint8_t len;
}; };
struct call_result_mount struct call_result_mount
{ {
uint16_t problem; uint32_t problem;
nfsfh_t fhandle; nfsfh_t fhandle;
}; };
@ -251,31 +251,63 @@ struct rpc_call_fs
/* Generic RPC reply headers */ /* Generic RPC reply headers */
enum msg_type
{
CALL = 0,
REPLY = 1
};
enum reply_stat
{
MSG_ACCEPTED = 0,
MSG_DENIED = 1
};
enum accept_stat
{
SUCCESS = 0, /* RPC executed successfully */
PROG_UNAVAIL = 1, /* remote hasn't exported program */
PROG_MISMATCH = 2, /* remote can't support version # */
PROC_UNAVAIL = 3, /* program can't support procedure */
GARBAGE_ARGS = 4, /* procedure can't decode params */
SYSTEM_ERR = 5 /* e.g. memory allocation failure */
};
enum reject_stat
{
RPC_MISMATCH = 0, /* RPC version number != 2 */
AUTH_ERROR = 1 /* remote can't authenticate caller */
};
struct rpc_reply_header struct rpc_reply_header
{ {
uint32_t rp_xid; /* request transaction id */ uint32_t rp_xid; /* request transaction id */
int32_t rp_direction; /* call direction (1) */ int32_t rp_direction; /* call direction (1) */
uint32_t type;
struct rpc_auth_info rpc_verfi;
uint32_t status;
//enum msg_type rp_direction; /* call direction (1) */
//enum reply_stat type;
//enum accept_stat status;
/*
struct struct
{ {
uint32_t type; uint32_t type;
uint32_t status; uint32_t status;
*/
/* used only when reply == RPC_MSGDENIED and status == RPC_AUTHERR */ /* used only when reply == RPC_MSGDENIED and status == RPC_AUTHERR */
uint32_t autherr; //uint32_t autherr;
/* rpc mismatch info if reply == RPC_MSGDENIED and status == RPC_MISMATCH */ /* rpc mismatch info if reply == RPC_MSGDENIED and status == RPC_MISMATCH */
/*
struct struct
{ {
uint32_t low; uint32_t low;
uint32_t high; uint32_t high;
} mismatch_info; } mismatch_info;
} stat; } stat;
*/
unsigned char *where;
struct rpc_auth_info rpc_verfi;
}; };
struct rpc_reply_pmap struct rpc_reply_pmap

265
fs/nfs/rpc_clnt.c
View File

@ -208,9 +208,9 @@ static dq_queue_t rpctask_q;
static int rpcclnt_send(struct socket *, struct sockaddr *, int, int, void *, static int rpcclnt_send(struct socket *, struct sockaddr *, int, int, void *,
struct rpctask *); struct rpctask *);
static int rpcclnt_receive(struct rpctask *, struct sockaddr *, static int rpcclnt_receive(struct rpctask *, struct sockaddr *, int, int,
void *);//, struct rpc_call *); void *);//, struct rpc_call *);
static int rpcclnt_reply(struct rpctask *, struct rpc_reply_header *, void *); static int rpcclnt_reply(struct rpctask *, int, int, void *);
#ifdef CONFIG_NFS_TCPIP #ifdef CONFIG_NFS_TCPIP
static int rpcclnt_sndlock(int *, struct rpctask *); static int rpcclnt_sndlock(int *, struct rpctask *);
static void rpcclnt_sndunlock(int *); static void rpcclnt_sndunlock(int *);
@ -309,7 +309,6 @@ rpcclnt_send(struct socket *so, struct sockaddr *nam, int procid, int prog,
sendnam, sizeof(*sendnam)); sendnam, sizeof(*sendnam));
} }
} }
else if (prog == RPCPROG_MNT) else if (prog == RPCPROG_MNT)
{ {
if (procid == RPCMNT_UMOUNT) if (procid == RPCMNT_UMOUNT)
@ -325,7 +324,6 @@ rpcclnt_send(struct socket *so, struct sockaddr *nam, int procid, int prog,
sendnam, sizeof(*sendnam)); sendnam, sizeof(*sendnam));
} }
} }
else if (prog == NFS_PROG) else if (prog == NFS_PROG)
{ {
switch (procid) switch (procid)
@ -455,7 +453,7 @@ rpcclnt_send(struct socket *so, struct sockaddr *nam, int procid, int prog,
*/ */
static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname, static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname,
void *reply)//, struct rpc_call *call) int proc, int program, void *reply)//, struct rpc_call *call)
{ {
struct socket *so; struct socket *so;
#ifdef CONFIG_NFS_TCPIP #ifdef CONFIG_NFS_TCPIP
@ -648,8 +646,8 @@ static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname,
} }
} }
else else
{
#endif #endif
{
so = rep->r_rpcclnt->rc_so; so = rep->r_rpcclnt->rc_so;
if (so == NULL) if (so == NULL)
{ {
@ -658,17 +656,136 @@ static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname,
socklen_t fromlen = sizeof(*aname); socklen_t fromlen = sizeof(*aname);
rcvflg = 0; rcvflg = 0;
error = psock_recvfrom(so, reply, sizeof(*reply), rcvflg,
if (program == PMAPPROG)
{
if (proc == PMAPPROC_GETPORT)
{
struct rpc_reply_pmap *replymsg = (struct rpc_reply_pmap *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen); aname, &fromlen);
}
else if (proc == PMAPPROC_UNSET)
{
struct rpc_reply_pmap *replymsg = (struct rpc_reply_pmap *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
}
else if (program == RPCPROG_MNT)
{
if (proc== RPCMNT_UMOUNT)
{
struct rpc_reply_mount *replymsg = (struct rpc_reply_mount *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
else if (proc == RPCMNT_MOUNT)
{
struct rpc_reply_mount *replymsg = (struct rpc_reply_mount *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
}
else if (program == NFS_PROG)
{
switch (proc)
{
case NFSPROC_CREATE:
{
struct rpc_reply_create *replymsg = (struct rpc_reply_create *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_READ:
{
struct rpc_reply_read *replymsg = (struct rpc_reply_read *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_WRITE:
{
struct rpc_reply_write *replymsg = (struct rpc_reply_write *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_READDIR:
{
struct rpc_reply_readdir *replymsg = (struct rpc_reply_readdir *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_FSSTAT:
{
struct rpc_reply_fsstat *replymsg = (struct rpc_reply_fsstat *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_REMOVE:
{
struct rpc_reply_remove *replymsg = (struct rpc_reply_remove *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_MKDIR:
{
struct rpc_reply_mkdir *replymsg = (struct rpc_reply_mkdir *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_RMDIR:
{
struct rpc_reply_rmdir *replymsg = (struct rpc_reply_rmdir *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_RENAME:
{
struct rpc_reply_rename *replymsg = (struct rpc_reply_rename *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
case NFSPROC_FSINFO:
{
struct rpc_reply_fsinfo *replymsg = (struct rpc_reply_fsinfo *)reply;
error = psock_recvfrom(so, replymsg, sizeof(*replymsg), rcvflg,
aname, &fromlen);
}
break;
default:
break;
}
}
nvdbg("psock_recvfrom returns %d\n", error); nvdbg("psock_recvfrom returns %d\n", error);
if (error > 0) if (error > 0)
{ {
RPC_RETURN(0); RPC_RETURN(0);
} }
#ifdef CONFIG_NFS_TCPIP
} }
#endif
RPC_RETURN(ENONET); RPC_RETURN(ENONET);
} }
@ -677,11 +794,10 @@ static int rpcclnt_receive(struct rpctask *rep, struct sockaddr *aname,
* until ours is found. * until ours is found.
*/ */
static int static int rpcclnt_reply(struct rpctask *myrep, int procid, int prog, void *reply)
rpcclnt_reply(struct rpctask *myrep, struct rpc_reply_header *replyheader, //Here we need to make changes for debugging
void *reply)
{ {
struct rpctask *rep; struct rpctask *rep;
struct rpc_reply_header replyheader;
struct rpcclnt *rpc = myrep->r_rpcclnt; struct rpcclnt *rpc = myrep->r_rpcclnt;
int32_t t1; int32_t t1;
uint32_t rxid; uint32_t rxid;
@ -707,7 +823,7 @@ rpcclnt_reply(struct rpctask *myrep, struct rpc_reply_header *replyheader, //He
#endif #endif
/* Get the next Rpc reply off the socket */ /* Get the next Rpc reply off the socket */
error = rpcclnt_receive(myrep, rpc->rc_name, reply);//, call); error = rpcclnt_receive(myrep, rpc->rc_name, procid, prog, reply);
#ifdef CONFIG_NFS_TCPIP #ifdef CONFIG_NFS_TCPIP
rpcclnt_rcvunlock(&rpc->rc_flag); rpcclnt_rcvunlock(&rpc->rc_flag);
#endif #endif
@ -731,13 +847,12 @@ rpcclnt_reply(struct rpctask *myrep, struct rpc_reply_header *replyheader, //He
RPC_RETURN(error); RPC_RETURN(error);
} }
bcopy(reply, replyheader, sizeof(struct rpc_reply_header)); bcopy(reply, &replyheader, sizeof(struct rpc_reply_header));
/* Get the xid and check that it is an rpc replysvr */ /* Get the xid and check that it is an rpc replysvr */
rxid = replyheader->rp_xid; rxid = replyheader.rp_xid;
if (replyheader.rp_direction != rpc_reply)
if (replyheader->rp_direction != rpc_reply)
{ {
rpcstats.rpcinvalid++; rpcstats.rpcinvalid++;
if (myrep->r_flags & TASK_GETONEREP) if (myrep->r_flags & TASK_GETONEREP)
@ -1069,9 +1184,8 @@ int rpcclnt_connect(struct rpcclnt *rpc)
struct sockaddr_in *sa; struct sockaddr_in *sa;
struct call_args_pmap sdata; struct call_args_pmap sdata;
struct call_args_mount mountd; struct call_args_mount mountd;
struct rpc_reply_pmap *rdata; struct rpc_reply_pmap rdata;
struct rpc_reply_mount *mdata; struct rpc_reply_mount mdata;
void *reply = NULL;
struct timeval tv; struct timeval tv;
uint16_t tport; uint16_t tport;
@ -1089,9 +1203,7 @@ int rpcclnt_connect(struct rpcclnt *rpc)
return -ENOMEM; return -ENOMEM;
} }
error = error = psock_socket(saddr->sa_family, rpc->rc_sotype, rpc->rc_soproto, so);
psock_socket(saddr->sa_family, rpc->rc_sotype, rpc->rc_soproto, so);
if (error != 0) if (error != 0)
{ {
ndbg("error %d in psock_socket()", error); ndbg("error %d in psock_socket()", error);
@ -1166,57 +1278,55 @@ int rpcclnt_connect(struct rpcclnt *rpc)
*/ */
memset(&sdata, 0, sizeof(sdata)); memset(&sdata, 0, sizeof(sdata));
memset(&rdata, 0, sizeof(rdata));
sdata.prog = txdr_unsigned(RPCPROG_MNT); sdata.prog = txdr_unsigned(RPCPROG_MNT);
sdata.vers = txdr_unsigned(RPCMNT_VER1); sdata.vers = txdr_unsigned(RPCMNT_VER1);
sdata.proc = txdr_unsigned(IPPROTO_UDP); sdata.proc = txdr_unsigned(IPPROTO_UDP);
sdata.port = 0; sdata.port = 0;
error = rpcclnt_request(rpc, PMAPPROC_GETPORT, PMAPPROG, PMAPVERS, error = rpcclnt_request(rpc, PMAPPROC_GETPORT, PMAPPROG, PMAPVERS,
reply, (FAR const void *)&sdata); (void *)&rdata, (FAR const void *)&sdata);
if (error != 0) if (error != 0)
{ {
goto bad; goto bad;
} }
rdata = (struct rpc_reply_pmap *)reply;
nvdbg("Port from the server %d\n", rdata->pmap.port);
sa = (FAR struct sockaddr_in *)saddr; sa = (FAR struct sockaddr_in *)saddr;
sa->sin_port = rdata->pmap.port; sa->sin_port = htons(fxdr_unsigned(uint32_t, rdata.pmap.port));
nvdbg("Port in socket %d\n", sa->sin_port);
error = psock_connect(rpc->rc_so, saddr, sizeof(*saddr)); error = psock_connect(rpc->rc_so, saddr, sizeof(*saddr));
if (error) if (error)
{ {
ndbg("psock_connect NFS port returns %d\n", error); ndbg("psock_connect MOUNTD port returns %d\n", error);
goto bad; goto bad;
} }
/* Do RPC to mountd. */ /* Do RPC to mountd. */
//memset(&reply, 0, sizeof(reply));
nvdbg("remote path %s\n", rpc->rc_path); nvdbg("remote path %s\n", rpc->rc_path);
memset(&mountd, 0, sizeof(mountd)); memset(&mountd, 0, sizeof(mountd));
memset(&mdata, 0, sizeof(mdata));
//mountd.rpath = txdr_unsigned(rpc->rc_path);
mountd.rpath = rpc->rc_path; mountd.rpath = rpc->rc_path;
mountd.len = sizeof(mountd.rpath); mountd.len = txdr_unsigned(sizeof(mountd.rpath));
nvdbg("path %s\n", mountd.rpath ); nvdbg("path %s\n", mountd.rpath );
nvdbg("len %d\n", mountd.len); nvdbg("len %d\n", mountd.len);
error = rpcclnt_request(rpc, RPCMNT_MOUNT, RPCPROG_MNT, RPCMNT_VER1, error = rpcclnt_request(rpc, RPCMNT_MOUNT, RPCPROG_MNT, RPCMNT_VER1,
reply, (FAR const void *)&mountd); (void *)&mdata, (FAR const void *)&mountd);
if (error != 0) if (error != 0)
{ {
goto bad; goto bad;
} }
/*
rpc->rc_fh = fxdr_unsigned(nfsfh_t, mdata.mount.fhandle);
mdata = (struct rpc_reply_mount *)reply; if (fxdr_unsigned(uint32_t, mdata.mount.problem) =! 0)
rpc->rc_fh = mdata->mount.fhandle;
if (mdata->mount.problem)
{ {
ndbg("error mounting with the server %d\n", error); ndbg("error mounting with the server %d\n", error);
goto bad; goto bad;
} }
*/
/* NFS port in the socket*/ /* NFS port in the socket*/
sa->sin_port = htons(NFS_PORT); sa->sin_port = htons(NFS_PORT);
@ -1298,46 +1408,43 @@ int rpcclnt_umount(struct rpcclnt *rpc)
{ {
struct sockaddr *saddr; struct sockaddr *saddr;
struct sockaddr_in *sa; struct sockaddr_in *sa;
void *reply;
struct call_args_pmap sdata; struct call_args_pmap sdata;
struct rpc_reply_pmap *rdata; struct rpc_reply_pmap rdata;
int error; int error;
saddr = rpc->rc_name; saddr = rpc->rc_name;
/* Do the RPC to get a dynamic bounding with the server using ppmap*/ /* Do the RPC to get a dynamic bounding with the server using ppmap.
/* Get port number for MOUNTD. */ * Get port number for MOUNTD.
*/
memset(&sdata, 0, sizeof(sdata));
memset(&rdata, 0, sizeof(rdata));
sdata.prog = txdr_unsigned(RPCPROG_MNT); sdata.prog = txdr_unsigned(RPCPROG_MNT);
sdata.vers = txdr_unsigned(RPCMNT_VER1); sdata.vers = txdr_unsigned(RPCMNT_VER1);
sdata.proc = txdr_unsigned(IPPROTO_UDP); sdata.proc = txdr_unsigned(IPPROTO_UDP);
sdata.port = 0; sdata.port = 0;
memset(&reply, 0, sizeof(reply));
error = rpcclnt_request(rpc, PMAPPROC_GETPORT, PMAPPROG, PMAPVERS, error = rpcclnt_request(rpc, PMAPPROC_GETPORT, PMAPPROG, PMAPVERS,
&reply, &sdata); (void *)&rdata, (FAR const void *)&sdata);
if (error != 0) if (error != 0)
{ {
goto bad; goto bad;
} }
rdata = (struct rpc_reply_pmap *)reply;
sa = (FAR struct sockaddr_in *)saddr; sa = (FAR struct sockaddr_in *)saddr;
sa->sin_port = rdata->pmap.port; sa->sin_port = htons(fxdr_unsigned(uint32_t, rdata.pmap.port));
error = psock_connect(rpc->rc_so, saddr, sizeof(*saddr)); error = psock_connect(rpc->rc_so, saddr, sizeof(*saddr));
if (error) if (error)
{ {
ndbg("psock_connect umount port returns %d\n", error); ndbg("psock_connect MOUNTD port returns %d\n", error);
goto bad; goto bad;
} }
/* Do RPC to umountd. */ /* Do RPC to umountd. */
/*
//memset(&reply, 0, sizeof(reply)); memset(&reply, 0, sizeof(reply));
error = rpcclnt_request(rpc, RPCMNT_UMOUNT, RPCPROG_MNT, RPCMNT_VER1, error = rpcclnt_request(rpc, RPCMNT_UMOUNT, RPCPROG_MNT, RPCMNT_VER1,
reply, &rpc->rc_path); reply, &rpc->rc_path);
@ -1345,7 +1452,7 @@ int rpcclnt_umount(struct rpcclnt *rpc)
{ {
goto bad; goto bad;
} }
*/
RPC_RETURN(0); RPC_RETURN(0);
bad: bad:
@ -1379,7 +1486,7 @@ void rpcclnt_safedisconnect(struct rpcclnt *rpc)
int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version, int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version,
void *dataout, FAR const void *datain) void *dataout, FAR const void *datain)
{ {
struct rpc_reply_header *replymgs; struct rpc_reply_header replymgs;
struct rpc_reply_header replyheader; struct rpc_reply_header replyheader;
struct rpctask *task = NULL; struct rpctask *task = NULL;
struct xidr value; struct xidr value;
@ -1397,7 +1504,7 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version,
void *msgcall = NULL; void *msgcall = NULL;
int error = 0; int error = 0;
memset(&replyheader, 0, sizeof(replyheader)); //memset(&replyheader, 0, sizeof(replyheader));
if (prog == PMAPPROG) if (prog == PMAPPROG)
{ {
@ -1600,7 +1707,7 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version,
if (error == 0 || error == EPIPE) if (error == 0 || error == EPIPE)
{ {
error = rpcclnt_reply(task, &replyheader, dataout); error = rpcclnt_reply(task, procnum, prog, dataout);
} }
nvdbg("out for reply %d\n", error); nvdbg("out for reply %d\n", error);
@ -1623,26 +1730,26 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version,
/* Break down the rpc header and check if ok */ /* Break down the rpc header and check if ok */
nvdbg("Breakdown msg \n");
memset(&replymgs, 0, sizeof(replymgs)); memset(&replymgs, 0, sizeof(replymgs));
replymgs->stat.type = fxdr_unsigned(uint32_t, replyheader.stat.type); bcopy(dataout, &replyheader, sizeof(struct rpc_reply_header));
if (replymgs->stat.type == RPC_MSGDENIED) replymgs.type = fxdr_unsigned(uint32_t, replyheader.type);
if (replymgs.type == RPC_MSGDENIED)
{ {
replymgs->stat.status = fxdr_unsigned(uint32_t, replyheader.stat.status); replymgs.status = fxdr_unsigned(uint32_t, replyheader.status);
switch (replymgs->stat.status) switch (replymgs.status)
{ {
case RPC_MISMATCH: case RPC_MISMATCH:
replymgs->stat.mismatch_info.low = /*replymgs.stat.mismatch_info.low =
fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.low); fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.low);
replymgs->stat.mismatch_info.high = replymgs.stat.mismatch_info.high =
fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.high); fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.high);
ndbg("RPC_MSGDENIED: RPC_MISMATCH error"); ndbg("RPC_MSGDENIED: RPC_MISMATCH error");*/
error = EOPNOTSUPP; error = EOPNOTSUPP;
break; break;
case RPC_AUTHERR: case RPC_AUTHERR:
replymgs->stat.autherr = fxdr_unsigned(uint32_t, replyheader.stat.autherr); //replymgs.stat.autherr = fxdr_unsigned(uint32_t, replyheader.stat.autherr);
ndbg("RPC_MSGDENIED: RPC_AUTHERR error"); ndbg("RPC_MSGDENIED: RPC_AUTHERR error\n");
error = EACCES; error = EACCES;
break; break;
@ -1652,7 +1759,7 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version,
} }
goto rpcmout; goto rpcmout;
} }
else if (replymgs->stat.type != RPC_MSGACCEPTED) else if (replymgs.type != RPC_MSGACCEPTED)
{ {
error = EOPNOTSUPP; error = EOPNOTSUPP;
goto rpcmout; goto rpcmout;
@ -1660,26 +1767,26 @@ int rpcclnt_request(struct rpcclnt *rpc, int procnum, int prog, int version,
/* Verifier */ /* Verifier */
replymgs->rpc_verfi.authtype = /*replymgs.rpc_verfi.authtype =
fxdr_unsigned(enum auth_flavor, replyheader.rpc_verfi.authtype); fxdr_unsigned(enum auth_flavor, replyheader.rpc_verfi.authtype);
replymgs->rpc_verfi.authlen = replymgs.rpc_verfi.authlen =
fxdr_unsigned(uint32_t, replyheader.rpc_verfi.authlen); fxdr_unsigned(uint32_t, replyheader.rpc_verfi.authlen);*/
if (replymgs->stat.status == RPC_SUCCESS) if (replymgs.status == RPC_SUCCESS)
{ {
nvdbg("RPC_SUCCESS"); nvdbg("RPC_SUCCESS\n");
} }
else if (replymgs->stat.status == RPC_PROGMISMATCH) else if (replymgs.status == RPC_PROGMISMATCH)
{ {
replymgs->stat.mismatch_info.low = /*replymgs.stat.mismatch_info.low =
fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.low); fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.low);
replymgs->stat.mismatch_info.high = replymgs.stat.mismatch_info.high =
fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.high); fxdr_unsigned(uint32_t, replyheader.stat.mismatch_info.high);*/
ndbg("RPC_MSGACCEPTED: RPC_PROGMISMATCH error"); ndbg("RPC_MSGACCEPTED: RPC_PROGMISMATCH error\n");
error = EOPNOTSUPP; error = EOPNOTSUPP;
} }
else if (replymgs->stat.status > 5) else if (replymgs.status > 5)
{ {
error = EOPNOTSUPP; error = EOPNOTSUPP;
goto rpcmout; goto rpcmout;
@ -1746,7 +1853,7 @@ void rpcclnt_timer(void *arg, struct rpc_call *call)
if ((rep->r_flags & TASK_TPRINTFMSG) == 0 && if ((rep->r_flags & TASK_TPRINTFMSG) == 0 &&
rep->r_rexmit > rpc->rc_deadthresh) rep->r_rexmit > rpc->rc_deadthresh)
{ {
ndbg("Server is not responding"); ndbg("Server is not responding\n");
rep->r_flags |= TASK_TPRINTFMSG; rep->r_flags |= TASK_TPRINTFMSG;
} }