Lines Matching refs:bcl
108 static struct tipc_link *bcl = &bcast_link.link; variable
149 if (bcl->next_out) in bclink_set_last_sent()
150 bcl->fsm_msg_cnt = mod(buf_seqno(bcl->next_out) - 1); in bclink_set_last_sent()
152 bcl->fsm_msg_cnt = mod(bcl->next_out_no - 1); in bclink_set_last_sent()
157 return bcl->fsm_msg_cnt; in tipc_bclink_get_last_sent()
190 buf = bcl->first_out; in bclink_retransmit_pkt()
193 tipc_link_retransmit(bcl, buf, mod(to - after)); in bclink_retransmit_pkt()
213 crs = bcl->first_out; in tipc_bclink_acknowledge()
225 acked = bcl->fsm_msg_cnt; in tipc_bclink_acknowledge()
227 acked = bcl->next_out_no; in tipc_bclink_acknowledge()
234 less(bcl->fsm_msg_cnt, acked) || in tipc_bclink_acknowledge()
248 if (crs != bcl->next_out) in tipc_bclink_acknowledge()
252 bcl->next_out = next; in tipc_bclink_acknowledge()
257 bcl->first_out = next; in tipc_bclink_acknowledge()
258 bcl->out_queue_size--; in tipc_bclink_acknowledge()
268 if (unlikely(bcl->next_out)) { in tipc_bclink_acknowledge()
269 tipc_link_push_queue(bcl); in tipc_bclink_acknowledge()
272 if (unlikely(released && !list_empty(&bcl->waiting_ports))) in tipc_bclink_acknowledge()
273 tipc_link_wakeup_ports(bcl, 0); in tipc_bclink_acknowledge()
331 bcl->stats.sent_nacks++; in tipc_bclink_update_link_state()
381 res = tipc_link_send_buf(bcl, buf); in tipc_bclink_send_msg()
384 bcl->stats.queue_sz_counts++; in tipc_bclink_send_msg()
385 bcl->stats.accu_queue_sz += bcl->out_queue_size; in tipc_bclink_send_msg()
403 bcl->stats.recv_info++; in bclink_accept_pkt()
414 bcl->stats.sent_acks++; in bclink_accept_pkt()
454 bcl->stats.recv_nacks++; in tipc_bclink_recv_pkt()
487 bcl->stats.recv_bundles++; in tipc_bclink_recv_pkt()
488 bcl->stats.recv_bundled += msg_msgcnt(msg); in tipc_bclink_recv_pkt()
499 bcl->stats.recv_fragments++; in tipc_bclink_recv_pkt()
501 bcl->stats.recv_fragmented++; in tipc_bclink_recv_pkt()
563 bcl->stats.deferred_recv++; in tipc_bclink_recv_pkt()
565 bcl->stats.duplicates++; in tipc_bclink_recv_pkt()
612 bcl->stats.sent_info++; in tipc_bcbearer_send()
722 if (!bcl) in tipc_bclink_stats()
731 bcl->name, bcl->queue_limit[0]); in tipc_bclink_stats()
733 bcl->stats.recv_info, in tipc_bclink_stats()
734 bcl->stats.recv_fragments, in tipc_bclink_stats()
735 bcl->stats.recv_fragmented, in tipc_bclink_stats()
736 bcl->stats.recv_bundles, in tipc_bclink_stats()
737 bcl->stats.recv_bundled); in tipc_bclink_stats()
739 bcl->stats.sent_info, in tipc_bclink_stats()
740 bcl->stats.sent_fragments, in tipc_bclink_stats()
741 bcl->stats.sent_fragmented, in tipc_bclink_stats()
742 bcl->stats.sent_bundles, in tipc_bclink_stats()
743 bcl->stats.sent_bundled); in tipc_bclink_stats()
745 bcl->stats.recv_nacks, in tipc_bclink_stats()
746 bcl->stats.deferred_recv, in tipc_bclink_stats()
747 bcl->stats.duplicates); in tipc_bclink_stats()
749 bcl->stats.sent_nacks, in tipc_bclink_stats()
750 bcl->stats.sent_acks, in tipc_bclink_stats()
751 bcl->stats.retransmitted); in tipc_bclink_stats()
753 bcl->stats.bearer_congs, in tipc_bclink_stats()
754 bcl->stats.link_congs, in tipc_bclink_stats()
755 bcl->stats.max_queue_sz, in tipc_bclink_stats()
756 bcl->stats.queue_sz_counts in tipc_bclink_stats()
757 ? (bcl->stats.accu_queue_sz / bcl->stats.queue_sz_counts) in tipc_bclink_stats()
766 if (!bcl) in tipc_bclink_reset_stats()
770 memset(&bcl->stats, 0, sizeof(bcl->stats)); in tipc_bclink_reset_stats()
777 if (!bcl) in tipc_bclink_set_queue_limits()
783 tipc_link_set_queue_limits(bcl, limit); in tipc_bclink_set_queue_limits()
795 INIT_LIST_HEAD(&bcl->waiting_ports); in tipc_bclink_init()
796 bcl->next_out_no = 1; in tipc_bclink_init()
798 bcl->owner = &bclink->node; in tipc_bclink_init()
799 bcl->max_pkt = MAX_PKT_DEFAULT_MCAST; in tipc_bclink_init()
800 tipc_link_set_queue_limits(bcl, BCLINK_WIN_DEFAULT); in tipc_bclink_init()
801 bcl->b_ptr = &bcbearer->bearer; in tipc_bclink_init()
802 bcl->state = WORKING_WORKING; in tipc_bclink_init()
803 strlcpy(bcl->name, tipc_bclink_name, TIPC_MAX_LINK_NAME); in tipc_bclink_init()
809 tipc_link_stop(bcl); in tipc_bclink_stop()