Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history 
yaml
---
r: 42543
b: refs/heads/master
c: ee0ac0c
h: refs/heads/master
i:
  42541: 973a9f9
  42539: 5e9db8d
  42535: cce256a
  42527: ce11723
v: v3
  • Loading branch information
Chuck Lever authored and Trond Myklebust committed Dec 6, 2006
1 parent dbe3799 commit d32e417
Show file tree
Hide file tree
Showing 3 changed files with 42 additions and 26 deletions.
2 changes: 1 addition & 1 deletion [refs]
View file
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: ffc2e518c91942b7ed45fb0ab7deba1ba0c8594a
refs/heads/master: ee0ac0c227c2a2b6dd1b33c23831100ee895dacf
4 changes: 2 additions & 2 deletions trunk/include/linux/sunrpc/xprt.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,8 @@
#include <linux/sunrpc/xdr.h>
#include <linux/sunrpc/msg_prot.h>

#include <net/sock.h>

extern unsigned int xprt_udp_slot_table_entries;
extern unsigned int xprt_tcp_slot_table_entries;

Expand Down Expand Up @@ -126,8 +128,6 @@ struct rpc_xprt_ops {
struct rpc_xprt {
struct kref kref; /* Reference count */
struct rpc_xprt_ops * ops; /* transport methods */
struct socket * sock; /* BSD socket layer */
struct sock * inet; /* INET layer */

struct rpc_timeout timeout; /* timeout parms */
struct sockaddr_storage addr; /* server address */
Expand Down
62 changes: 39 additions & 23 deletions trunk/net/sunrpc/xprtsock.c
View file
Original file line number Diff line number Diff line change
Expand Up @@ -127,6 +127,12 @@ static inline void xs_pktdump(char *msg, u32 *packet, unsigned int count)

struct sock_xprt {
struct rpc_xprt xprt;

/*
* Network layer
*/
struct socket * sock;
struct sock * inet;
};

static void xs_format_peer_addresses(struct rpc_xprt *xprt)
Expand Down Expand Up @@ -285,19 +291,20 @@ static void xs_nospace(struct rpc_task *task)
{
struct rpc_rqst *req = task->tk_rqstp;
struct rpc_xprt *xprt = req->rq_xprt;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);

dprintk("RPC: %4d xmit incomplete (%u left of %u)\n",
task->tk_pid, req->rq_slen - req->rq_bytes_sent,
req->rq_slen);

if (test_bit(SOCK_ASYNC_NOSPACE, &xprt->sock->flags)) {
if (test_bit(SOCK_ASYNC_NOSPACE, &transport->sock->flags)) {
/* Protect against races with write_space */
spin_lock_bh(&xprt->transport_lock);

/* Don't race with disconnect */
if (!xprt_connected(xprt))
task->tk_status = -ENOTCONN;
else if (test_bit(SOCK_NOSPACE, &xprt->sock->flags))
else if (test_bit(SOCK_NOSPACE, &transport->sock->flags))
xprt_wait_for_buffer_space(task);

spin_unlock_bh(&xprt->transport_lock);
Expand All @@ -321,6 +328,7 @@ static int xs_udp_send_request(struct rpc_task *task)
{
struct rpc_rqst *req = task->tk_rqstp;
struct rpc_xprt *xprt = req->rq_xprt;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct xdr_buf *xdr = &req->rq_snd_buf;
int status;

Expand All @@ -329,8 +337,10 @@ static int xs_udp_send_request(struct rpc_task *task)
req->rq_svec->iov_len);

req->rq_xtime = jiffies;
status = xs_sendpages(xprt->sock, (struct sockaddr *) &xprt->addr,
xprt->addrlen, xdr, req->rq_bytes_sent);
status = xs_sendpages(transport->sock,
(struct sockaddr *) &xprt->addr,
xprt->addrlen, xdr,
req->rq_bytes_sent);

dprintk("RPC: xs_udp_send_request(%u) = %d\n",
xdr->len - req->rq_bytes_sent, status);
Expand Down Expand Up @@ -386,6 +396,7 @@ static int xs_tcp_send_request(struct rpc_task *task)
{
struct rpc_rqst *req = task->tk_rqstp;
struct rpc_xprt *xprt = req->rq_xprt;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct xdr_buf *xdr = &req->rq_snd_buf;
int status, retry = 0;

Expand All @@ -400,8 +411,8 @@ static int xs_tcp_send_request(struct rpc_task *task)
* called sendmsg(). */
while (1) {
req->rq_xtime = jiffies;
status = xs_sendpages(xprt->sock, NULL, 0, xdr,
req->rq_bytes_sent);
status = xs_sendpages(transport->sock,
NULL, 0, xdr, req->rq_bytes_sent);

dprintk("RPC: xs_tcp_send_request(%u) = %d\n",
xdr->len - req->rq_bytes_sent, status);
Expand Down Expand Up @@ -479,17 +490,18 @@ static void xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task)
*/
static void xs_close(struct rpc_xprt *xprt)
{
struct socket *sock = xprt->sock;
struct sock *sk = xprt->inet;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct socket *sock = transport->sock;
struct sock *sk = transport->inet;

if (!sk)
goto clear_close_wait;

dprintk("RPC: xs_close xprt %p\n", xprt);

write_lock_bh(&sk->sk_callback_lock);
xprt->inet = NULL;
xprt->sock = NULL;
transport->inet = NULL;
transport->sock = NULL;

sk->sk_user_data = NULL;
sk->sk_data_ready = xprt->old_data_ready;
Expand Down Expand Up @@ -946,7 +958,8 @@ static void xs_tcp_write_space(struct sock *sk)

static void xs_udp_do_set_buffer_size(struct rpc_xprt *xprt)
{
struct sock *sk = xprt->inet;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct sock *sk = transport->inet;

if (xprt->rcvsize) {
sk->sk_userlocks |= SOCK_RCVBUF_LOCK;
Expand Down Expand Up @@ -1062,7 +1075,8 @@ static int xs_bindresvport(struct rpc_xprt *xprt, struct socket *sock)
static void xs_udp_connect_worker(void *args)
{
struct rpc_xprt *xprt = (struct rpc_xprt *) args;
struct socket *sock = xprt->sock;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct socket *sock = transport->sock;
int err, status = -EIO;

if (xprt->shutdown || !xprt_bound(xprt))
Expand All @@ -1084,7 +1098,7 @@ static void xs_udp_connect_worker(void *args)
dprintk("RPC: worker connecting xprt %p to address: %s\n",
xprt, xs_print_peer_address(xprt, RPC_DISPLAY_ALL));

if (!xprt->inet) {
if (!transport->inet) {
struct sock *sk = sock->sk;

write_lock_bh(&sk->sk_callback_lock);
Expand All @@ -1101,8 +1115,8 @@ static void xs_udp_connect_worker(void *args)
xprt_set_connected(xprt);

/* Reset to new socket */
xprt->sock = sock;
xprt->inet = sk;
transport->sock = sock;
transport->inet = sk;

write_unlock_bh(&sk->sk_callback_lock);
}
Expand All @@ -1120,7 +1134,7 @@ static void xs_udp_connect_worker(void *args)
static void xs_tcp_reuse_connection(struct rpc_xprt *xprt)
{
int result;
struct socket *sock = xprt->sock;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct sockaddr any;

dprintk("RPC: disconnecting xprt %p to reuse port\n", xprt);
Expand All @@ -1131,7 +1145,7 @@ static void xs_tcp_reuse_connection(struct rpc_xprt *xprt)
*/
memset(&any, 0, sizeof(any));
any.sa_family = AF_UNSPEC;
result = kernel_connect(sock, &any, sizeof(any), 0);
result = kernel_connect(transport->sock, &any, sizeof(any), 0);
if (result)
dprintk("RPC: AF_UNSPEC connect return code %d\n",
result);
Expand All @@ -1146,13 +1160,14 @@ static void xs_tcp_reuse_connection(struct rpc_xprt *xprt)
static void xs_tcp_connect_worker(void *args)
{
struct rpc_xprt *xprt = (struct rpc_xprt *)args;
struct socket *sock = xprt->sock;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);
struct socket *sock = transport->sock;
int err, status = -EIO;

if (xprt->shutdown || !xprt_bound(xprt))
goto out;

if (!xprt->sock) {
if (!sock) {
/* start from scratch */
if ((err = sock_create_kern(PF_INET, SOCK_STREAM, IPPROTO_TCP, &sock)) < 0) {
dprintk("RPC: can't create TCP transport socket (%d).\n", -err);
Expand All @@ -1170,7 +1185,7 @@ static void xs_tcp_connect_worker(void *args)
dprintk("RPC: worker connecting xprt %p to address: %s\n",
xprt, xs_print_peer_address(xprt, RPC_DISPLAY_ALL));

if (!xprt->inet) {
if (!transport->inet) {
struct sock *sk = sock->sk;

write_lock_bh(&sk->sk_callback_lock);
Expand All @@ -1193,8 +1208,8 @@ static void xs_tcp_connect_worker(void *args)
xprt_clear_connected(xprt);

/* Reset to new socket */
xprt->sock = sock;
xprt->inet = sk;
transport->sock = sock;
transport->inet = sk;

write_unlock_bh(&sk->sk_callback_lock);
}
Expand Down Expand Up @@ -1243,11 +1258,12 @@ static void xs_tcp_connect_worker(void *args)
static void xs_connect(struct rpc_task *task)
{
struct rpc_xprt *xprt = task->tk_xprt;
struct sock_xprt *transport = container_of(xprt, struct sock_xprt, xprt);

if (xprt_test_and_set_connecting(xprt))
return;

if (xprt->sock != NULL) {
if (transport->sock != NULL) {
dprintk("RPC: xs_connect delayed xprt %p for %lu seconds\n",
xprt, xprt->reestablish_timeout / HZ);
schedule_delayed_work(&xprt->connect_worker,
Expand Down

0 comments on commit d32e417

Please sign in to comment.