Lines Matching refs:transmq
167 l_ptr->stats.accu_queue_sz += skb_queue_len(&l_ptr->transmq); in link_timeout()
170 skb = skb_peek(&l_ptr->transmq); in link_timeout()
284 __skb_queue_head_init(&l_ptr->transmq); in tipc_link_create()
424 __skb_queue_purge(&l_ptr->transmq); in tipc_link_purge_queues()
462 __skb_queue_purge(&l_ptr->transmq); in tipc_link_reset()
710 struct sk_buff_head *transmq = &link->transmq; in __tipc_link_xmit() local
730 if (likely(skb_queue_len(transmq) < maxwin)) { in __tipc_link_xmit()
731 __skb_queue_tail(transmq, skb); in __tipc_link_xmit()
882 while (skb_queue_len(&link->transmq) < link->window) { in tipc_link_push_packets()
891 __skb_queue_tail(&link->transmq, skb); in tipc_link_push_packets()
977 skb_queue_walk_from(&l_ptr->transmq, skb) { in tipc_link_retransmit()
1103 skb_queue_walk_safe(&l_ptr->transmq, skb1, tmp) { in tipc_rcv()
1106 __skb_unlink(skb1, &l_ptr->transmq); in tipc_rcv()
1525 tipc_link_retransmit(l_ptr, skb_peek(&l_ptr->transmq), in tipc_link_proto_rcv()
1583 skb_queue_splice_tail_init(&l_ptr->backlogq, &l_ptr->transmq); in tipc_link_failover_send_queue()
1585 msgcount = skb_queue_len(&l_ptr->transmq); in tipc_link_failover_send_queue()
1589 if (skb_queue_empty(&l_ptr->transmq)) { in tipc_link_failover_send_queue()
1605 skb_queue_walk(&l_ptr->transmq, skb) { in tipc_link_failover_send_queue()
1641 struct sk_buff_head *queue = &link->transmq; in tipc_link_dup_queue_xmit()
1646 mcnt = skb_queue_len(&link->transmq) + skb_queue_len(&link->backlogq); in tipc_link_dup_queue_xmit()