diff options
author | Glenn Elliott <gelliott@cs.unc.edu> | 2012-03-04 19:47:13 -0500 |
---|---|---|
committer | Glenn Elliott <gelliott@cs.unc.edu> | 2012-03-04 19:47:13 -0500 |
commit | c71c03bda1e86c9d5198c5d83f712e695c4f2a1e (patch) | |
tree | ecb166cb3e2b7e2adb3b5e292245fefd23381ac8 /net/rds/recv.c | |
parent | ea53c912f8a86a8567697115b6a0d8152beee5c8 (diff) | |
parent | 6a00f206debf8a5c8899055726ad127dbeeed098 (diff) |
Merge branch 'mpi-master' into wip-k-fmlpwip-k-fmlp
Conflicts:
litmus/sched_cedf.c
Diffstat (limited to 'net/rds/recv.c')
-rw-r--r-- | net/rds/recv.c | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/net/rds/recv.c b/net/rds/recv.c index c93588c2d553..596689e59272 100644 --- a/net/rds/recv.c +++ b/net/rds/recv.c | |||
@@ -36,7 +36,6 @@ | |||
36 | #include <linux/in.h> | 36 | #include <linux/in.h> |
37 | 37 | ||
38 | #include "rds.h" | 38 | #include "rds.h" |
39 | #include "rdma.h" | ||
40 | 39 | ||
41 | void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, | 40 | void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, |
42 | __be32 saddr) | 41 | __be32 saddr) |
@@ -49,12 +48,11 @@ void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, | |||
49 | } | 48 | } |
50 | EXPORT_SYMBOL_GPL(rds_inc_init); | 49 | EXPORT_SYMBOL_GPL(rds_inc_init); |
51 | 50 | ||
52 | void rds_inc_addref(struct rds_incoming *inc) | 51 | static void rds_inc_addref(struct rds_incoming *inc) |
53 | { | 52 | { |
54 | rdsdebug("addref inc %p ref %d\n", inc, atomic_read(&inc->i_refcount)); | 53 | rdsdebug("addref inc %p ref %d\n", inc, atomic_read(&inc->i_refcount)); |
55 | atomic_inc(&inc->i_refcount); | 54 | atomic_inc(&inc->i_refcount); |
56 | } | 55 | } |
57 | EXPORT_SYMBOL_GPL(rds_inc_addref); | ||
58 | 56 | ||
59 | void rds_inc_put(struct rds_incoming *inc) | 57 | void rds_inc_put(struct rds_incoming *inc) |
60 | { | 58 | { |
@@ -210,7 +208,7 @@ void rds_recv_incoming(struct rds_connection *conn, __be32 saddr, __be32 daddr, | |||
210 | } | 208 | } |
211 | 209 | ||
212 | rs = rds_find_bound(daddr, inc->i_hdr.h_dport); | 210 | rs = rds_find_bound(daddr, inc->i_hdr.h_dport); |
213 | if (rs == NULL) { | 211 | if (!rs) { |
214 | rds_stats_inc(s_recv_drop_no_sock); | 212 | rds_stats_inc(s_recv_drop_no_sock); |
215 | goto out; | 213 | goto out; |
216 | } | 214 | } |
@@ -251,7 +249,7 @@ static int rds_next_incoming(struct rds_sock *rs, struct rds_incoming **inc) | |||
251 | { | 249 | { |
252 | unsigned long flags; | 250 | unsigned long flags; |
253 | 251 | ||
254 | if (*inc == NULL) { | 252 | if (!*inc) { |
255 | read_lock_irqsave(&rs->rs_recv_lock, flags); | 253 | read_lock_irqsave(&rs->rs_recv_lock, flags); |
256 | if (!list_empty(&rs->rs_recv_queue)) { | 254 | if (!list_empty(&rs->rs_recv_queue)) { |
257 | *inc = list_entry(rs->rs_recv_queue.next, | 255 | *inc = list_entry(rs->rs_recv_queue.next, |
@@ -334,10 +332,10 @@ int rds_notify_queue_get(struct rds_sock *rs, struct msghdr *msghdr) | |||
334 | 332 | ||
335 | if (msghdr) { | 333 | if (msghdr) { |
336 | cmsg.user_token = notifier->n_user_token; | 334 | cmsg.user_token = notifier->n_user_token; |
337 | cmsg.status = notifier->n_status; | 335 | cmsg.status = notifier->n_status; |
338 | 336 | ||
339 | err = put_cmsg(msghdr, SOL_RDS, RDS_CMSG_RDMA_STATUS, | 337 | err = put_cmsg(msghdr, SOL_RDS, RDS_CMSG_RDMA_STATUS, |
340 | sizeof(cmsg), &cmsg); | 338 | sizeof(cmsg), &cmsg); |
341 | if (err) | 339 | if (err) |
342 | break; | 340 | break; |
343 | } | 341 | } |