diff options
author | Ying Xue <ying.xue@windriver.com> | 2014-11-25 22:41:53 -0500 |
---|---|---|
committer | David S. Miller <davem@davemloft.net> | 2014-11-26 12:30:17 -0500 |
commit | bc6fecd4098df2d21b056486e5b418c84be95032 (patch) | |
tree | 4b37da9bbd5fda66bba92558de5e6c9dfe97b7f6 /net/tipc/link.h | |
parent | 58dc55f25631178ee74cd27185956a8f7dcb3e32 (diff) |
tipc: use generic SKB list APIs to manage deferred queue of link
Use standard SKB list APIs associated with struct sk_buff_head to
manage link's deferred queue, simplifying relevant code.
Signed-off-by: Ying Xue <ying.xue@windriver.com>
Reviewed-by: Jon Maloy <jon.maloy@ericsson.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
Diffstat (limited to 'net/tipc/link.h')
-rw-r--r-- | net/tipc/link.h | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/net/tipc/link.h b/net/tipc/link.h index 96f1e1bf0798..de7b8833641a 100644 --- a/net/tipc/link.h +++ b/net/tipc/link.h | |||
@@ -124,9 +124,7 @@ struct tipc_stats { | |||
124 | * @last_retransmitted: sequence number of most recently retransmitted message | 124 | * @last_retransmitted: sequence number of most recently retransmitted message |
125 | * @stale_count: # of identical retransmit requests made by peer | 125 | * @stale_count: # of identical retransmit requests made by peer |
126 | * @next_in_no: next sequence number to expect for inbound messages | 126 | * @next_in_no: next sequence number to expect for inbound messages |
127 | * @deferred_inqueue_sz: # of messages in inbound message queue | 127 | * @deferred_queue: deferred queue saved OOS b'cast message received from node |
128 | * @oldest_deferred_in: ptr to first inbound message in queue | ||
129 | * @newest_deferred_in: ptr to last inbound message in queue | ||
130 | * @unacked_window: # of inbound messages rx'd without ack'ing back to peer | 128 | * @unacked_window: # of inbound messages rx'd without ack'ing back to peer |
131 | * @next_out: ptr to first unsent outbound message in queue | 129 | * @next_out: ptr to first unsent outbound message in queue |
132 | * @waiting_sks: linked list of sockets waiting for link congestion to abate | 130 | * @waiting_sks: linked list of sockets waiting for link congestion to abate |
@@ -178,9 +176,7 @@ struct tipc_link { | |||
178 | 176 | ||
179 | /* Reception */ | 177 | /* Reception */ |
180 | u32 next_in_no; | 178 | u32 next_in_no; |
181 | u32 deferred_inqueue_sz; | 179 | struct sk_buff_head deferred_queue; |
182 | struct sk_buff *oldest_deferred_in; | ||
183 | struct sk_buff *newest_deferred_in; | ||
184 | u32 unacked_window; | 180 | u32 unacked_window; |
185 | 181 | ||
186 | /* Congestion handling */ | 182 | /* Congestion handling */ |
@@ -224,8 +220,7 @@ void tipc_link_bundle_rcv(struct sk_buff *buf); | |||
224 | void tipc_link_proto_xmit(struct tipc_link *l_ptr, u32 msg_typ, int prob, | 220 | void tipc_link_proto_xmit(struct tipc_link *l_ptr, u32 msg_typ, int prob, |
225 | u32 gap, u32 tolerance, u32 priority, u32 acked_mtu); | 221 | u32 gap, u32 tolerance, u32 priority, u32 acked_mtu); |
226 | void tipc_link_push_packets(struct tipc_link *l_ptr); | 222 | void tipc_link_push_packets(struct tipc_link *l_ptr); |
227 | u32 tipc_link_defer_pkt(struct sk_buff **head, struct sk_buff **tail, | 223 | u32 tipc_link_defer_pkt(struct sk_buff_head *list, struct sk_buff *buf); |
228 | struct sk_buff *buf); | ||
229 | void tipc_link_set_queue_limits(struct tipc_link *l_ptr, u32 window); | 224 | void tipc_link_set_queue_limits(struct tipc_link *l_ptr, u32 window); |
230 | void tipc_link_retransmit(struct tipc_link *l_ptr, | 225 | void tipc_link_retransmit(struct tipc_link *l_ptr, |
231 | struct sk_buff *start, u32 retransmits); | 226 | struct sk_buff *start, u32 retransmits); |