Lines Matching refs:bcl

117 	struct tipc_link *bcl = tn->bcl;  in bclink_set_last_sent()  local
118 struct sk_buff *skb = skb_peek(&bcl->backlogq); in bclink_set_last_sent()
121 bcl->fsm_msg_cnt = mod(buf_seqno(skb) - 1); in bclink_set_last_sent()
123 bcl->fsm_msg_cnt = mod(bcl->next_out_no - 1); in bclink_set_last_sent()
130 return tn->bcl->fsm_msg_cnt; in tipc_bclink_get_last_sent()
161 struct tipc_link *bcl = tn->bcl; in bclink_retransmit_pkt() local
163 skb_queue_walk(&bcl->transmq, skb) { in bclink_retransmit_pkt()
165 tipc_link_retransmit(bcl, skb, mod(to - after)); in bclink_retransmit_pkt()
203 skb = skb_peek(&tn->bcl->transmq); in tipc_bclink_acknowledge()
215 acked = tn->bcl->fsm_msg_cnt; in tipc_bclink_acknowledge()
217 acked = tn->bcl->next_out_no; in tipc_bclink_acknowledge()
224 less(tn->bcl->fsm_msg_cnt, acked) || in tipc_bclink_acknowledge()
230 skb_queue_walk(&tn->bcl->transmq, skb) { in tipc_bclink_acknowledge()
236 skb_queue_walk_from_safe(&tn->bcl->transmq, skb, tmp) { in tipc_bclink_acknowledge()
242 __skb_unlink(skb, &tn->bcl->transmq); in tipc_bclink_acknowledge()
250 if (unlikely(skb_peek(&tn->bcl->backlogq))) { in tipc_bclink_acknowledge()
251 tipc_link_push_packets(tn->bcl); in tipc_bclink_acknowledge()
254 if (unlikely(released && !skb_queue_empty(&tn->bcl->wakeupq))) in tipc_bclink_acknowledge()
310 tn->bcl->stats.sent_nacks++; in tipc_bclink_update_link_state()
350 struct tipc_link *bcl = tn->bcl; in tipc_bclink_xmit() local
368 rc = __tipc_link_xmit(net, bcl, list); in tipc_bclink_xmit()
370 u32 len = skb_queue_len(&bcl->transmq); in tipc_bclink_xmit()
373 bcl->stats.queue_sz_counts++; in tipc_bclink_xmit()
374 bcl->stats.accu_queue_sz += len; in tipc_bclink_xmit()
408 tn->bcl->stats.recv_info++; in bclink_accept_pkt()
417 tn->bcl->stats.sent_acks++; in bclink_accept_pkt()
429 struct tipc_link *bcl = tn->bcl; in tipc_bclink_rcv() local
458 bcl->stats.recv_nacks++; in tipc_bclink_rcv()
493 bcl->stats.recv_bundles++; in tipc_bclink_rcv()
494 bcl->stats.recv_bundled += msg_msgcnt(msg); in tipc_bclink_rcv()
512 bcl->stats.recv_fragments++; in tipc_bclink_rcv()
514 bcl->stats.recv_fragmented++; in tipc_bclink_rcv()
565 bcl->stats.deferred_recv++; in tipc_bclink_rcv()
567 bcl->stats.duplicates++; in tipc_bclink_rcv()
613 tn->bcl->stats.sent_info++; in tipc_bcbearer_send()
782 struct tipc_link *bcl = tn->bcl; in tipc_nl_add_bc_link() local
784 if (!bcl) in tipc_nl_add_bc_link()
804 if (nla_put_string(msg->skb, TIPC_NLA_LINK_NAME, bcl->name)) in tipc_nl_add_bc_link()
806 if (nla_put_u32(msg->skb, TIPC_NLA_LINK_RX, bcl->next_in_no)) in tipc_nl_add_bc_link()
808 if (nla_put_u32(msg->skb, TIPC_NLA_LINK_TX, bcl->next_out_no)) in tipc_nl_add_bc_link()
814 if (nla_put_u32(msg->skb, TIPC_NLA_PROP_WIN, bcl->window)) in tipc_nl_add_bc_link()
818 err = __tipc_nl_add_bc_link_stat(msg->skb, &bcl->stats); in tipc_nl_add_bc_link()
842 struct tipc_link *bcl = tn->bcl; in tipc_bclink_reset_stats() local
844 if (!bcl) in tipc_bclink_reset_stats()
848 memset(&bcl->stats, 0, sizeof(bcl->stats)); in tipc_bclink_reset_stats()
856 struct tipc_link *bcl = tn->bcl; in tipc_bclink_set_queue_limits() local
858 if (!bcl) in tipc_bclink_set_queue_limits()
864 tipc_link_set_queue_limits(bcl, limit); in tipc_bclink_set_queue_limits()
874 struct tipc_link *bcl; in tipc_bclink_init() local
886 bcl = &bclink->link; in tipc_bclink_init()
892 __skb_queue_head_init(&bcl->transmq); in tipc_bclink_init()
893 __skb_queue_head_init(&bcl->backlogq); in tipc_bclink_init()
894 __skb_queue_head_init(&bcl->deferdq); in tipc_bclink_init()
895 skb_queue_head_init(&bcl->wakeupq); in tipc_bclink_init()
896 bcl->next_out_no = 1; in tipc_bclink_init()
900 bcl->owner = &bclink->node; in tipc_bclink_init()
901 bcl->owner->net = net; in tipc_bclink_init()
902 bcl->mtu = MAX_PKT_DEFAULT_MCAST; in tipc_bclink_init()
903 tipc_link_set_queue_limits(bcl, BCLINK_WIN_DEFAULT); in tipc_bclink_init()
904 bcl->bearer_id = MAX_BEARERS; in tipc_bclink_init()
906 bcl->state = WORKING_WORKING; in tipc_bclink_init()
907 bcl->pmsg = (struct tipc_msg *)&bcl->proto_msg; in tipc_bclink_init()
908 msg_set_prevnode(bcl->pmsg, tn->own_addr); in tipc_bclink_init()
909 strlcpy(bcl->name, tipc_bclink_name, TIPC_MAX_LINK_NAME); in tipc_bclink_init()
912 tn->bcl = bcl; in tipc_bclink_init()
921 tipc_link_purge_queues(tn->bcl); in tipc_bclink_stop()