aboutsummaryrefslogtreecommitdiffstats
path: root/net/tipc
diff options
context:
space:
mode:
Diffstat (limited to 'net/tipc')
-rw-r--r--net/tipc/link.c22
-rw-r--r--net/tipc/link.h2
2 files changed, 0 insertions, 24 deletions
diff --git a/net/tipc/link.c b/net/tipc/link.c
index 4738cb1bf7c0..450ed0ce9071 100644
--- a/net/tipc/link.c
+++ b/net/tipc/link.c
@@ -421,8 +421,6 @@ void tipc_link_purge_queues(struct tipc_link *l_ptr)
421 kfree_skb_list(l_ptr->oldest_deferred_in); 421 kfree_skb_list(l_ptr->oldest_deferred_in);
422 kfree_skb_list(l_ptr->first_out); 422 kfree_skb_list(l_ptr->first_out);
423 tipc_link_reset_fragments(l_ptr); 423 tipc_link_reset_fragments(l_ptr);
424 kfree_skb(l_ptr->proto_msg_queue);
425 l_ptr->proto_msg_queue = NULL;
426} 424}
427 425
428void tipc_link_reset(struct tipc_link *l_ptr) 426void tipc_link_reset(struct tipc_link *l_ptr)
@@ -455,8 +453,6 @@ void tipc_link_reset(struct tipc_link *l_ptr)
455 453
456 /* Clean up all queues: */ 454 /* Clean up all queues: */
457 link_release_outqueue(l_ptr); 455 link_release_outqueue(l_ptr);
458 kfree_skb(l_ptr->proto_msg_queue);
459 l_ptr->proto_msg_queue = NULL;
460 kfree_skb_list(l_ptr->oldest_deferred_in); 456 kfree_skb_list(l_ptr->oldest_deferred_in);
461 if (!skb_queue_empty(&l_ptr->waiting_sks)) { 457 if (!skb_queue_empty(&l_ptr->waiting_sks)) {
462 skb_queue_splice_init(&l_ptr->waiting_sks, &owner->waiting_sks); 458 skb_queue_splice_init(&l_ptr->waiting_sks, &owner->waiting_sks);
@@ -904,18 +900,6 @@ static u32 tipc_link_push_packet(struct tipc_link *l_ptr)
904 return 0; 900 return 0;
905 } 901 }
906 902
907 /* Send deferred protocol message, if any: */
908 buf = l_ptr->proto_msg_queue;
909 if (buf) {
910 msg_set_ack(buf_msg(buf), mod(l_ptr->next_in_no - 1));
911 msg_set_bcast_ack(buf_msg(buf), l_ptr->owner->bclink.last_in);
912 tipc_bearer_send(l_ptr->bearer_id, buf, &l_ptr->media_addr);
913 l_ptr->unacked_window = 0;
914 kfree_skb(buf);
915 l_ptr->proto_msg_queue = NULL;
916 return 0;
917 }
918
919 /* Send one deferred data message, if send window not full: */ 903 /* Send one deferred data message, if send window not full: */
920 buf = l_ptr->next_out; 904 buf = l_ptr->next_out;
921 if (buf) { 905 if (buf) {
@@ -1446,12 +1430,6 @@ void tipc_link_proto_xmit(struct tipc_link *l_ptr, u32 msg_typ, int probe_msg,
1446 u32 msg_size = sizeof(l_ptr->proto_msg); 1430 u32 msg_size = sizeof(l_ptr->proto_msg);
1447 int r_flag; 1431 int r_flag;
1448 1432
1449 /* Discard any previous message that was deferred due to congestion */
1450 if (l_ptr->proto_msg_queue) {
1451 kfree_skb(l_ptr->proto_msg_queue);
1452 l_ptr->proto_msg_queue = NULL;
1453 }
1454
1455 /* Don't send protocol message during link changeover */ 1433 /* Don't send protocol message during link changeover */
1456 if (l_ptr->exp_msg_count) 1434 if (l_ptr->exp_msg_count)
1457 return; 1435 return;
diff --git a/net/tipc/link.h b/net/tipc/link.h
index f463e7be801c..fb3f99b6e928 100644
--- a/net/tipc/link.h
+++ b/net/tipc/link.h
@@ -130,7 +130,6 @@ struct tipc_stats {
130 * @oldest_deferred_in: ptr to first inbound message in queue 130 * @oldest_deferred_in: ptr to first inbound message in queue
131 * @newest_deferred_in: ptr to last inbound message in queue 131 * @newest_deferred_in: ptr to last inbound message in queue
132 * @unacked_window: # of inbound messages rx'd without ack'ing back to peer 132 * @unacked_window: # of inbound messages rx'd without ack'ing back to peer
133 * @proto_msg_queue: ptr to (single) outbound control message
134 * @retransm_queue_size: number of messages to retransmit 133 * @retransm_queue_size: number of messages to retransmit
135 * @retransm_queue_head: sequence number of first message to retransmit 134 * @retransm_queue_head: sequence number of first message to retransmit
136 * @next_out: ptr to first unsent outbound message in queue 135 * @next_out: ptr to first unsent outbound message in queue
@@ -191,7 +190,6 @@ struct tipc_link {
191 u32 unacked_window; 190 u32 unacked_window;
192 191
193 /* Congestion handling */ 192 /* Congestion handling */
194 struct sk_buff *proto_msg_queue;
195 u32 retransm_queue_size; 193 u32 retransm_queue_size;
196 u32 retransm_queue_head; 194 u32 retransm_queue_head;
197 struct sk_buff *next_out; 195 struct sk_buff *next_out;