diff options
author | David S. Miller <davem@davemloft.net> | 2016-06-30 05:03:36 -0400 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2016-06-30 05:03:36 -0400 |
commit | ee58b57100ca953da7320c285315a95db2f7053d (patch) | |
tree | 77b815a31240adc4d6326346908137fc6c2c3a96 /net/rds | |
parent | 6f30e8b022c8e3a722928ddb1a2ae0be852fcc0e (diff) | |
parent | e7bdea7750eb2a64aea4a08fa5c0a31719c8155d (diff) |
Merge git://git.kernel.org/pub/scm/linux/kernel/git/davem/net
Several cases of overlapping changes, except the packet scheduler
conflicts which deal with the addition of the free list parameter
to qdisc_enqueue().
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/rds')
-rw-r--r-- | net/rds/ib_cm.c | 2 | ||||
-rw-r--r-- | net/rds/loop.c | 5 | ||||
-rw-r--r-- | net/rds/sysctl.c | 3 | ||||
-rw-r--r-- | net/rds/tcp.h | 2 | ||||
-rw-r--r-- | net/rds/tcp_connect.c | 28 | ||||
-rw-r--r-- | net/rds/tcp_listen.c | 2 | ||||
-rw-r--r-- | net/rds/tcp_recv.c | 2 | ||||
-rw-r--r-- | net/rds/tcp_send.c | 14 | ||||
-rw-r--r-- | net/rds/transport.c | 3 |
9 files changed, 31 insertions, 30 deletions
diff --git a/net/rds/ib_cm.c b/net/rds/ib_cm.c index 334287602b78..e48bb1ba3dfc 100644 --- a/net/rds/ib_cm.c +++ b/net/rds/ib_cm.c | |||
@@ -112,7 +112,7 @@ void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_even | |||
112 | } | 112 | } |
113 | } | 113 | } |
114 | 114 | ||
115 | if (conn->c_version < RDS_PROTOCOL(3,1)) { | 115 | if (conn->c_version < RDS_PROTOCOL(3, 1)) { |
116 | printk(KERN_NOTICE "RDS/IB: Connection to %pI4 version %u.%u failed," | 116 | printk(KERN_NOTICE "RDS/IB: Connection to %pI4 version %u.%u failed," |
117 | " no longer supported\n", | 117 | " no longer supported\n", |
118 | &conn->c_faddr, | 118 | &conn->c_faddr, |
diff --git a/net/rds/loop.c b/net/rds/loop.c index 268f07faaa1a..15f83db78f0c 100644 --- a/net/rds/loop.c +++ b/net/rds/loop.c | |||
@@ -96,8 +96,9 @@ out: | |||
96 | */ | 96 | */ |
97 | static void rds_loop_inc_free(struct rds_incoming *inc) | 97 | static void rds_loop_inc_free(struct rds_incoming *inc) |
98 | { | 98 | { |
99 | struct rds_message *rm = container_of(inc, struct rds_message, m_inc); | 99 | struct rds_message *rm = container_of(inc, struct rds_message, m_inc); |
100 | rds_message_put(rm); | 100 | |
101 | rds_message_put(rm); | ||
101 | } | 102 | } |
102 | 103 | ||
103 | /* we need to at least give the thread something to succeed */ | 104 | /* we need to at least give the thread something to succeed */ |
diff --git a/net/rds/sysctl.c b/net/rds/sysctl.c index c173f69e1479..e381bbcd9cc1 100644 --- a/net/rds/sysctl.c +++ b/net/rds/sysctl.c | |||
@@ -102,7 +102,8 @@ int rds_sysctl_init(void) | |||
102 | rds_sysctl_reconnect_min = msecs_to_jiffies(1); | 102 | rds_sysctl_reconnect_min = msecs_to_jiffies(1); |
103 | rds_sysctl_reconnect_min_jiffies = rds_sysctl_reconnect_min; | 103 | rds_sysctl_reconnect_min_jiffies = rds_sysctl_reconnect_min; |
104 | 104 | ||
105 | rds_sysctl_reg_table = register_net_sysctl(&init_net,"net/rds", rds_sysctl_rds_table); | 105 | rds_sysctl_reg_table = |
106 | register_net_sysctl(&init_net, "net/rds", rds_sysctl_rds_table); | ||
106 | if (!rds_sysctl_reg_table) | 107 | if (!rds_sysctl_reg_table) |
107 | return -ENOMEM; | 108 | return -ENOMEM; |
108 | return 0; | 109 | return 0; |
diff --git a/net/rds/tcp.h b/net/rds/tcp.h index ec0602b0dc24..7940babf6c71 100644 --- a/net/rds/tcp.h +++ b/net/rds/tcp.h | |||
@@ -83,7 +83,7 @@ int rds_tcp_inc_copy_to_user(struct rds_incoming *inc, struct iov_iter *to); | |||
83 | void rds_tcp_xmit_prepare(struct rds_connection *conn); | 83 | void rds_tcp_xmit_prepare(struct rds_connection *conn); |
84 | void rds_tcp_xmit_complete(struct rds_connection *conn); | 84 | void rds_tcp_xmit_complete(struct rds_connection *conn); |
85 | int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, | 85 | int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, |
86 | unsigned int hdr_off, unsigned int sg, unsigned int off); | 86 | unsigned int hdr_off, unsigned int sg, unsigned int off); |
87 | void rds_tcp_write_space(struct sock *sk); | 87 | void rds_tcp_write_space(struct sock *sk); |
88 | 88 | ||
89 | /* tcp_stats.c */ | 89 | /* tcp_stats.c */ |
diff --git a/net/rds/tcp_connect.c b/net/rds/tcp_connect.c index ba9ec67f4e41..96c2c4d17909 100644 --- a/net/rds/tcp_connect.c +++ b/net/rds/tcp_connect.c | |||
@@ -55,20 +55,20 @@ void rds_tcp_state_change(struct sock *sk) | |||
55 | 55 | ||
56 | rdsdebug("sock %p state_change to %d\n", tc->t_sock, sk->sk_state); | 56 | rdsdebug("sock %p state_change to %d\n", tc->t_sock, sk->sk_state); |
57 | 57 | ||
58 | switch(sk->sk_state) { | 58 | switch (sk->sk_state) { |
59 | /* ignore connecting sockets as they make progress */ | 59 | /* ignore connecting sockets as they make progress */ |
60 | case TCP_SYN_SENT: | 60 | case TCP_SYN_SENT: |
61 | case TCP_SYN_RECV: | 61 | case TCP_SYN_RECV: |
62 | break; | 62 | break; |
63 | case TCP_ESTABLISHED: | 63 | case TCP_ESTABLISHED: |
64 | rds_connect_path_complete(&conn->c_path[0], | 64 | rds_connect_path_complete(&conn->c_path[0], |
65 | RDS_CONN_CONNECTING); | 65 | RDS_CONN_CONNECTING); |
66 | break; | 66 | break; |
67 | case TCP_CLOSE_WAIT: | 67 | case TCP_CLOSE_WAIT: |
68 | case TCP_CLOSE: | 68 | case TCP_CLOSE: |
69 | rds_conn_drop(conn); | 69 | rds_conn_drop(conn); |
70 | default: | 70 | default: |
71 | break; | 71 | break; |
72 | } | 72 | } |
73 | out: | 73 | out: |
74 | read_unlock_bh(&sk->sk_callback_lock); | 74 | read_unlock_bh(&sk->sk_callback_lock); |
diff --git a/net/rds/tcp_listen.c b/net/rds/tcp_listen.c index 22d9bb15f731..f9cc945a77b3 100644 --- a/net/rds/tcp_listen.c +++ b/net/rds/tcp_listen.c | |||
@@ -140,7 +140,7 @@ int rds_tcp_accept_one(struct socket *sock) | |||
140 | conn->c_path[0].cp_outgoing = 0; | 140 | conn->c_path[0].cp_outgoing = 0; |
141 | /* rds_connect_path_complete() marks RDS_CONN_UP */ | 141 | /* rds_connect_path_complete() marks RDS_CONN_UP */ |
142 | rds_connect_path_complete(&conn->c_path[0], | 142 | rds_connect_path_complete(&conn->c_path[0], |
143 | RDS_CONN_DISCONNECTING); | 143 | RDS_CONN_RESETTING); |
144 | } | 144 | } |
145 | } else { | 145 | } else { |
146 | rds_tcp_set_callbacks(new_sock, conn); | 146 | rds_tcp_set_callbacks(new_sock, conn); |
diff --git a/net/rds/tcp_recv.c b/net/rds/tcp_recv.c index 3f8fb38996c7..4a87d9ef3084 100644 --- a/net/rds/tcp_recv.c +++ b/net/rds/tcp_recv.c | |||
@@ -172,7 +172,7 @@ static int rds_tcp_data_recv(read_descriptor_t *desc, struct sk_buff *skb, | |||
172 | while (left) { | 172 | while (left) { |
173 | if (!tinc) { | 173 | if (!tinc) { |
174 | tinc = kmem_cache_alloc(rds_tcp_incoming_slab, | 174 | tinc = kmem_cache_alloc(rds_tcp_incoming_slab, |
175 | arg->gfp); | 175 | arg->gfp); |
176 | if (!tinc) { | 176 | if (!tinc) { |
177 | desc->error = -ENOMEM; | 177 | desc->error = -ENOMEM; |
178 | goto out; | 178 | goto out; |
diff --git a/net/rds/tcp_send.c b/net/rds/tcp_send.c index 2b3414f3c45c..710f1aae97ad 100644 --- a/net/rds/tcp_send.c +++ b/net/rds/tcp_send.c | |||
@@ -67,19 +67,19 @@ void rds_tcp_xmit_complete(struct rds_connection *conn) | |||
67 | static int rds_tcp_sendmsg(struct socket *sock, void *data, unsigned int len) | 67 | static int rds_tcp_sendmsg(struct socket *sock, void *data, unsigned int len) |
68 | { | 68 | { |
69 | struct kvec vec = { | 69 | struct kvec vec = { |
70 | .iov_base = data, | 70 | .iov_base = data, |
71 | .iov_len = len, | 71 | .iov_len = len, |
72 | }; | ||
73 | struct msghdr msg = { | ||
74 | .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, | ||
72 | }; | 75 | }; |
73 | struct msghdr msg = { | ||
74 | .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, | ||
75 | }; | ||
76 | 76 | ||
77 | return kernel_sendmsg(sock, &msg, &vec, 1, vec.iov_len); | 77 | return kernel_sendmsg(sock, &msg, &vec, 1, vec.iov_len); |
78 | } | 78 | } |
79 | 79 | ||
80 | /* the core send_sem serializes this with other xmit and shutdown */ | 80 | /* the core send_sem serializes this with other xmit and shutdown */ |
81 | int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, | 81 | int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, |
82 | unsigned int hdr_off, unsigned int sg, unsigned int off) | 82 | unsigned int hdr_off, unsigned int sg, unsigned int off) |
83 | { | 83 | { |
84 | struct rds_tcp_connection *tc = conn->c_transport_data; | 84 | struct rds_tcp_connection *tc = conn->c_transport_data; |
85 | int done = 0; | 85 | int done = 0; |
@@ -197,7 +197,7 @@ void rds_tcp_write_space(struct sock *sk) | |||
197 | tc->t_last_seen_una = rds_tcp_snd_una(tc); | 197 | tc->t_last_seen_una = rds_tcp_snd_una(tc); |
198 | rds_send_drop_acked(conn, rds_tcp_snd_una(tc), rds_tcp_is_acked); | 198 | rds_send_drop_acked(conn, rds_tcp_snd_una(tc), rds_tcp_is_acked); |
199 | 199 | ||
200 | if ((atomic_read(&sk->sk_wmem_alloc) << 1) <= sk->sk_sndbuf) | 200 | if ((atomic_read(&sk->sk_wmem_alloc) << 1) <= sk->sk_sndbuf) |
201 | queue_delayed_work(rds_wq, &conn->c_send_w, 0); | 201 | queue_delayed_work(rds_wq, &conn->c_send_w, 0); |
202 | 202 | ||
203 | out: | 203 | out: |
diff --git a/net/rds/transport.c b/net/rds/transport.c index f3afd1d60d3c..2ffd3e30c643 100644 --- a/net/rds/transport.c +++ b/net/rds/transport.c | |||
@@ -140,8 +140,7 @@ unsigned int rds_trans_stats_info_copy(struct rds_info_iterator *iter, | |||
140 | rds_info_iter_unmap(iter); | 140 | rds_info_iter_unmap(iter); |
141 | down_read(&rds_trans_sem); | 141 | down_read(&rds_trans_sem); |
142 | 142 | ||
143 | for (i = 0; i < RDS_TRANS_COUNT; i++) | 143 | for (i = 0; i < RDS_TRANS_COUNT; i++) { |
144 | { | ||
145 | trans = transports[i]; | 144 | trans = transports[i]; |
146 | if (!trans || !trans->stats_info_copy) | 145 | if (!trans || !trans->stats_info_copy) |
147 | continue; | 146 | continue; |