aboutsummaryrefslogtreecommitdiffstats
path: root/net/tipc/link.h
diff options
context:
space:
mode:
authorYing Xue <ying.xue@windriver.com>2014-11-25 22:41:53 -0500
committerDavid S. Miller <davem@davemloft.net>2014-11-26 12:30:17 -0500
commitbc6fecd4098df2d21b056486e5b418c84be95032 (patch)
tree4b37da9bbd5fda66bba92558de5e6c9dfe97b7f6 /net/tipc/link.h
parent58dc55f25631178ee74cd27185956a8f7dcb3e32 (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.h11
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);
224void tipc_link_proto_xmit(struct tipc_link *l_ptr, u32 msg_typ, int prob, 220void 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);
226void tipc_link_push_packets(struct tipc_link *l_ptr); 222void tipc_link_push_packets(struct tipc_link *l_ptr);
227u32 tipc_link_defer_pkt(struct sk_buff **head, struct sk_buff **tail, 223u32 tipc_link_defer_pkt(struct sk_buff_head *list, struct sk_buff *buf);
228 struct sk_buff *buf);
229void tipc_link_set_queue_limits(struct tipc_link *l_ptr, u32 window); 224void tipc_link_set_queue_limits(struct tipc_link *l_ptr, u32 window);
230void tipc_link_retransmit(struct tipc_link *l_ptr, 225void tipc_link_retransmit(struct tipc_link *l_ptr,
231 struct sk_buff *start, u32 retransmits); 226 struct sk_buff *start, u32 retransmits);