aboutsummaryrefslogtreecommitdiffstats
path: root/net/tipc
diff options
context:
space:
mode:
authorParthasarathy Bhuvaragan <parthasarathy.bhuvaragan@ericsson.com>2016-11-01 09:02:37 -0400
committerDavid S. Miller <davem@davemloft.net>2016-11-01 11:53:23 -0400
commitba8aebe9431a79c627214ddc782c3be9f2617e8d (patch)
tree7f45c657219c78bf69bf565cd6b6fcfde30db56e /net/tipc
parentcb5da847af4418f91d0e83fc91c2fcb1def5537d (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.h2
-rw-r--r--net/tipc/socket.c18
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
97struct tipc_skb_cb { 97struct 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 }