diff options
author | Parthasarathy Bhuvaragan <parthasarathy.bhuvaragan@ericsson.com> | 2016-11-01 09:02:37 -0400 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2016-11-01 11:53:23 -0400 |
commit | ba8aebe9431a79c627214ddc782c3be9f2617e8d (patch) | |
tree | 7f45c657219c78bf69bf565cd6b6fcfde30db56e /net/tipc | |
parent | cb5da847af4418f91d0e83fc91c2fcb1def5537d (diff) |
tipc: rename struct tipc_skb_cb member handle to bytes_read
In this commit, we rename handle to bytes_read indicating the
purpose of the member.
Signed-off-by: Parthasarathy Bhuvaragan <parthasarathy.bhuvaragan@ericsson.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/tipc')
-rw-r--r-- | net/tipc/msg.h | 2 | ||||
-rw-r--r-- | net/tipc/socket.c | 18 |
2 files changed, 11 insertions, 9 deletions
diff --git a/net/tipc/msg.h b/net/tipc/msg.h index 50a739860d37..8d408612ffa4 100644 --- a/net/tipc/msg.h +++ b/net/tipc/msg.h | |||
@@ -95,7 +95,7 @@ struct plist; | |||
95 | #define TIPC_MEDIA_INFO_OFFSET 5 | 95 | #define TIPC_MEDIA_INFO_OFFSET 5 |
96 | 96 | ||
97 | struct tipc_skb_cb { | 97 | struct tipc_skb_cb { |
98 | void *handle; | 98 | u32 bytes_read; |
99 | struct sk_buff *tail; | 99 | struct sk_buff *tail; |
100 | bool validated; | 100 | bool validated; |
101 | bool wakeup_pending; | 101 | bool wakeup_pending; |
diff --git a/net/tipc/socket.c b/net/tipc/socket.c index 82aec2eb8497..c543ae6cbf65 100644 --- a/net/tipc/socket.c +++ b/net/tipc/socket.c | |||
@@ -465,7 +465,7 @@ static int tipc_release(struct socket *sock) | |||
465 | skb = __skb_dequeue(&sk->sk_receive_queue); | 465 | skb = __skb_dequeue(&sk->sk_receive_queue); |
466 | if (skb == NULL) | 466 | if (skb == NULL) |
467 | break; | 467 | break; |
468 | if (TIPC_SKB_CB(skb)->handle != NULL) | 468 | if (TIPC_SKB_CB(skb)->bytes_read) |
469 | kfree_skb(skb); | 469 | kfree_skb(skb); |
470 | else { | 470 | else { |
471 | if ((sock->state == SS_CONNECTING) || | 471 | if ((sock->state == SS_CONNECTING) || |
@@ -1435,7 +1435,7 @@ static int tipc_recv_stream(struct socket *sock, struct msghdr *m, | |||
1435 | struct tipc_msg *msg; | 1435 | struct tipc_msg *msg; |
1436 | long timeo; | 1436 | long timeo; |
1437 | unsigned int sz; | 1437 | unsigned int sz; |
1438 | int sz_to_copy, target, needed; | 1438 | int target; |
1439 | int sz_copied = 0; | 1439 | int sz_copied = 0; |
1440 | u32 err; | 1440 | u32 err; |
1441 | int res = 0, hlen; | 1441 | int res = 0, hlen; |
@@ -1483,11 +1483,13 @@ restart: | |||
1483 | 1483 | ||
1484 | /* Capture message data (if valid) & compute return value (always) */ | 1484 | /* Capture message data (if valid) & compute return value (always) */ |
1485 | if (!err) { | 1485 | if (!err) { |
1486 | u32 offset = (u32)(unsigned long)(TIPC_SKB_CB(buf)->handle); | 1486 | u32 offset = TIPC_SKB_CB(buf)->bytes_read; |
1487 | u32 needed; | ||
1488 | int sz_to_copy; | ||
1487 | 1489 | ||
1488 | sz -= offset; | 1490 | sz -= offset; |
1489 | needed = (buf_len - sz_copied); | 1491 | needed = (buf_len - sz_copied); |
1490 | sz_to_copy = (sz <= needed) ? sz : needed; | 1492 | sz_to_copy = min(sz, needed); |
1491 | 1493 | ||
1492 | res = skb_copy_datagram_msg(buf, hlen + offset, m, sz_to_copy); | 1494 | res = skb_copy_datagram_msg(buf, hlen + offset, m, sz_to_copy); |
1493 | if (res) | 1495 | if (res) |
@@ -1497,8 +1499,8 @@ restart: | |||
1497 | 1499 | ||
1498 | if (sz_to_copy < sz) { | 1500 | if (sz_to_copy < sz) { |
1499 | if (!(flags & MSG_PEEK)) | 1501 | if (!(flags & MSG_PEEK)) |
1500 | TIPC_SKB_CB(buf)->handle = | 1502 | TIPC_SKB_CB(buf)->bytes_read = |
1501 | (void *)(unsigned long)(offset + sz_to_copy); | 1503 | offset + sz_to_copy; |
1502 | goto exit; | 1504 | goto exit; |
1503 | } | 1505 | } |
1504 | } else { | 1506 | } else { |
@@ -1742,7 +1744,7 @@ static bool filter_rcv(struct sock *sk, struct sk_buff *skb, | |||
1742 | } | 1744 | } |
1743 | 1745 | ||
1744 | /* Enqueue message */ | 1746 | /* Enqueue message */ |
1745 | TIPC_SKB_CB(skb)->handle = NULL; | 1747 | TIPC_SKB_CB(skb)->bytes_read = 0; |
1746 | __skb_queue_tail(&sk->sk_receive_queue, skb); | 1748 | __skb_queue_tail(&sk->sk_receive_queue, skb); |
1747 | skb_set_owner_r(skb, sk); | 1749 | skb_set_owner_r(skb, sk); |
1748 | 1750 | ||
@@ -2177,7 +2179,7 @@ restart: | |||
2177 | /* Disconnect and send a 'FIN+' or 'FIN-' message to peer */ | 2179 | /* Disconnect and send a 'FIN+' or 'FIN-' message to peer */ |
2178 | skb = __skb_dequeue(&sk->sk_receive_queue); | 2180 | skb = __skb_dequeue(&sk->sk_receive_queue); |
2179 | if (skb) { | 2181 | if (skb) { |
2180 | if (TIPC_SKB_CB(skb)->handle != NULL) { | 2182 | if (TIPC_SKB_CB(skb)->bytes_read) { |
2181 | kfree_skb(skb); | 2183 | kfree_skb(skb); |
2182 | goto restart; | 2184 | goto restart; |
2183 | } | 2185 | } |