diff -u --recursive --new-file linux-2.4.19-call_reserve2/fs/nfs/inode.c linux-2.4.19-rpcbuf/fs/nfs/inode.c --- linux-2.4.19-call_reserve2/fs/nfs/inode.c Tue Jun 25 19:40:36 2002 +++ linux-2.4.19-rpcbuf/fs/nfs/inode.c Thu Aug 1 12:24:30 2002 @@ -472,7 +472,8 @@ goto failure_kill_reqlist; } - /* We're airborne */ + /* We're airborne Set socket buffersize */ + rpc_setbufsize(clnt, server->wsize + 100, server->rsize + 100); /* Check whether to start the lockd process */ if (!(server->flags & NFS_MOUNT_NONLM)) diff -u --recursive --new-file linux-2.4.19-call_reserve2/include/linux/sunrpc/clnt.h linux-2.4.19-rpcbuf/include/linux/sunrpc/clnt.h --- linux-2.4.19-call_reserve2/include/linux/sunrpc/clnt.h Thu Aug 1 12:11:29 2002 +++ linux-2.4.19-rpcbuf/include/linux/sunrpc/clnt.h Thu Aug 1 12:24:30 2002 @@ -126,6 +126,7 @@ void rpc_restart_call(struct rpc_task *); void rpc_clnt_sigmask(struct rpc_clnt *clnt, sigset_t *oldset); void rpc_clnt_sigunmask(struct rpc_clnt *clnt, sigset_t *oldset); +void rpc_setbufsize(struct rpc_clnt *, unsigned int, unsigned int); static __inline__ int rpc_call(struct rpc_clnt *clnt, u32 proc, void *argp, void *resp, int flags) diff -u --recursive --new-file linux-2.4.19-call_reserve2/include/linux/sunrpc/xprt.h linux-2.4.19-rpcbuf/include/linux/sunrpc/xprt.h --- linux-2.4.19-call_reserve2/include/linux/sunrpc/xprt.h Thu Aug 1 12:23:48 2002 +++ linux-2.4.19-rpcbuf/include/linux/sunrpc/xprt.h Thu Aug 1 12:24:30 2002 @@ -121,6 +121,9 @@ unsigned long cong; /* current congestion */ unsigned long cwnd; /* congestion window */ + unsigned int rcvsize, /* socket receive buffer size */ + sndsize; /* socket send buffer size */ + struct rpc_wait_queue sending; /* requests waiting to send */ struct rpc_wait_queue resend; /* requests waiting to resend */ struct rpc_wait_queue pending; /* requests in flight */ @@ -176,6 +179,7 @@ void xprt_release(struct rpc_task *); void xprt_reconnect(struct rpc_task *); int xprt_clear_backlog(struct rpc_xprt *); +void xprt_sock_setbufsize(struct rpc_xprt *); #define XPRT_CONNECT 0 diff -u --recursive --new-file linux-2.4.19-call_reserve2/net/sunrpc/clnt.c linux-2.4.19-rpcbuf/net/sunrpc/clnt.c --- linux-2.4.19-call_reserve2/net/sunrpc/clnt.c Thu Aug 1 12:23:48 2002 +++ linux-2.4.19-rpcbuf/net/sunrpc/clnt.c Thu Aug 1 12:24:30 2002 @@ -336,6 +336,20 @@ task->tk_action = NULL; } +void +rpc_setbufsize(struct rpc_clnt *clnt, unsigned int sndsize, unsigned int rcvsize) +{ + struct rpc_xprt *xprt = clnt->cl_xprt; + + xprt->sndsize = 0; + if (sndsize) + xprt->sndsize = sndsize + RPC_SLACK_SPACE; + xprt->rcvsize = 0; + if (rcvsize) + xprt->rcvsize = rcvsize + RPC_SLACK_SPACE; + xprt_sock_setbufsize(xprt); +} + /* * Restart an (async) RPC call. Usually called from within the * exit handler. diff -u --recursive --new-file linux-2.4.19-call_reserve2/net/sunrpc/sunrpc_syms.c linux-2.4.19-rpcbuf/net/sunrpc/sunrpc_syms.c --- linux-2.4.19-call_reserve2/net/sunrpc/sunrpc_syms.c Thu Aug 1 11:07:56 2002 +++ linux-2.4.19-rpcbuf/net/sunrpc/sunrpc_syms.c Thu Aug 1 12:24:30 2002 @@ -50,6 +50,7 @@ EXPORT_SYMBOL(rpc_clnt_sigunmask); EXPORT_SYMBOL(rpc_delay); EXPORT_SYMBOL(rpc_restart_call); +EXPORT_SYMBOL(rpc_setbufsize); /* Client transport */ EXPORT_SYMBOL(xprt_create_proto); diff -u --recursive --new-file linux-2.4.19-call_reserve2/net/sunrpc/xprt.c linux-2.4.19-rpcbuf/net/sunrpc/xprt.c --- linux-2.4.19-call_reserve2/net/sunrpc/xprt.c Thu Aug 1 12:23:48 2002 +++ linux-2.4.19-rpcbuf/net/sunrpc/xprt.c Thu Aug 1 12:24:30 2002 @@ -1405,6 +1405,27 @@ } /* + * Set socket buffer length + */ +void +xprt_sock_setbufsize(struct rpc_xprt *xprt) +{ + struct sock *sk = xprt->inet; + + if (xprt->stream) + return; + if (xprt->rcvsize) { + sk->userlocks |= SOCK_RCVBUF_LOCK; + sk->rcvbuf = xprt->rcvsize * RPC_MAXCONG * 2; + } + if (xprt->sndsize) { + sk->userlocks |= SOCK_SNDBUF_LOCK; + sk->sndbuf = xprt->sndsize * RPC_MAXCONG * 2; + sk->write_space(sk); + } +} + +/* * Create a client socket given the protocol and peer address. */ static struct socket *