diff options
Diffstat (limited to 'net/rds/tcp_connect.c')
| -rw-r--r-- | net/rds/tcp_connect.c | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/net/rds/tcp_connect.c b/net/rds/tcp_connect.c index 211522f9a9a2..c519939e8da9 100644 --- a/net/rds/tcp_connect.c +++ b/net/rds/tcp_connect.c | |||
| @@ -43,7 +43,7 @@ void rds_tcp_state_change(struct sock *sk) | |||
| 43 | struct rds_connection *conn; | 43 | struct rds_connection *conn; |
| 44 | struct rds_tcp_connection *tc; | 44 | struct rds_tcp_connection *tc; |
| 45 | 45 | ||
| 46 | read_lock(&sk->sk_callback_lock); | 46 | read_lock_bh(&sk->sk_callback_lock); |
| 47 | conn = sk->sk_user_data; | 47 | conn = sk->sk_user_data; |
| 48 | if (conn == NULL) { | 48 | if (conn == NULL) { |
| 49 | state_change = sk->sk_state_change; | 49 | state_change = sk->sk_state_change; |
| @@ -68,7 +68,7 @@ void rds_tcp_state_change(struct sock *sk) | |||
| 68 | break; | 68 | break; |
| 69 | } | 69 | } |
| 70 | out: | 70 | out: |
| 71 | read_unlock(&sk->sk_callback_lock); | 71 | read_unlock_bh(&sk->sk_callback_lock); |
| 72 | state_change(sk); | 72 | state_change(sk); |
| 73 | } | 73 | } |
| 74 | 74 | ||
| @@ -90,8 +90,8 @@ int rds_tcp_conn_connect(struct rds_connection *conn) | |||
| 90 | 90 | ||
| 91 | ret = sock->ops->bind(sock, (struct sockaddr *)&src, sizeof(src)); | 91 | ret = sock->ops->bind(sock, (struct sockaddr *)&src, sizeof(src)); |
| 92 | if (ret) { | 92 | if (ret) { |
| 93 | rdsdebug("bind failed with %d at address %u.%u.%u.%u\n", | 93 | rdsdebug("bind failed with %d at address %pI4\n", |
| 94 | ret, NIPQUAD(conn->c_laddr)); | 94 | ret, &conn->c_laddr); |
| 95 | goto out; | 95 | goto out; |
| 96 | } | 96 | } |
| 97 | 97 | ||
| @@ -108,8 +108,7 @@ int rds_tcp_conn_connect(struct rds_connection *conn) | |||
| 108 | O_NONBLOCK); | 108 | O_NONBLOCK); |
| 109 | sock = NULL; | 109 | sock = NULL; |
| 110 | 110 | ||
| 111 | rdsdebug("connect to address %u.%u.%u.%u returned %d\n", | 111 | rdsdebug("connect to address %pI4 returned %d\n", &conn->c_faddr, ret); |
| 112 | NIPQUAD(conn->c_faddr), ret); | ||
| 113 | if (ret == -EINPROGRESS) | 112 | if (ret == -EINPROGRESS) |
| 114 | ret = 0; | 113 | ret = 0; |
| 115 | 114 | ||
| @@ -142,7 +141,7 @@ void rds_tcp_conn_shutdown(struct rds_connection *conn) | |||
| 142 | 141 | ||
| 143 | release_sock(sock->sk); | 142 | release_sock(sock->sk); |
| 144 | sock_release(sock); | 143 | sock_release(sock); |
| 145 | }; | 144 | } |
| 146 | 145 | ||
| 147 | if (tc->t_tinc) { | 146 | if (tc->t_tinc) { |
| 148 | rds_inc_put(&tc->t_tinc->ti_inc); | 147 | rds_inc_put(&tc->t_tinc->ti_inc); |
