296 		struct tipc_msg *msg = buf_msg(buf);  in tipc_bclink_update_link_state()  local
300 		tipc_msg_init(tn->own_addr, msg, BCAST_PROTOCOL, STATE_MSG,  in tipc_bclink_update_link_state()
302 		msg_set_non_seq(msg, 1);  in tipc_bclink_update_link_state()
303 		msg_set_mc_netid(msg, tn->net_id);  in tipc_bclink_update_link_state()
304 		msg_set_bcast_ack(msg, n_ptr->bclink.last_in);  in tipc_bclink_update_link_state()
305 		msg_set_bcgap_after(msg, n_ptr->bclink.last_in);  in tipc_bclink_update_link_state()
306 		msg_set_bcgap_to(msg, to);  in tipc_bclink_update_link_state()
324 static void bclink_peek_nack(struct net *net, struct tipc_msg *msg)  in bclink_peek_nack()  argument
326 	struct tipc_node *n_ptr = tipc_node_find(net, msg_destnode(msg));  in bclink_peek_nack()
334 	    (n_ptr->bclink.last_in == msg_bcgap_after(msg)))  in bclink_peek_nack()
430 	struct tipc_msg *msg = buf_msg(buf);  in tipc_bclink_rcv()  local
440 	if (msg_mc_netid(msg) != tn->net_id)  in tipc_bclink_rcv()
443 	node = tipc_node_find(net, msg_prevnode(msg));  in tipc_bclink_rcv()
452 	if (unlikely(msg_user(msg) == BCAST_PROTOCOL)) {  in tipc_bclink_rcv()
453 		if (msg_type(msg) != STATE_MSG)  in tipc_bclink_rcv()
455 		if (msg_destnode(msg) == tn->own_addr) {  in tipc_bclink_rcv()
456 			tipc_bclink_acknowledge(node, msg_bcast_ack(msg));  in tipc_bclink_rcv()
460 			bclink_retransmit_pkt(tn, msg_bcgap_after(msg),  in tipc_bclink_rcv()
461 					      msg_bcgap_to(msg));  in tipc_bclink_rcv()
466 			bclink_peek_nack(net, msg);  in tipc_bclink_rcv()
473 	seqno = msg_seqno(msg);  in tipc_bclink_rcv()
481 		if (likely(msg_isdata(msg))) {  in tipc_bclink_rcv()
490 		} else if (msg_user(msg) == MSG_BUNDLER) {  in tipc_bclink_rcv()
494 			bcl->stats.recv_bundled += msg_msgcnt(msg);  in tipc_bclink_rcv()
504 		} else if (msg_user(msg) == MSG_FRAGMENTER) {  in tipc_bclink_rcv()
515 				msg = buf_msg(buf);  in tipc_bclink_rcv()
543 		msg = buf_msg(skb_peek(&node->bclink.deferdq));  in tipc_bclink_rcv()
544 		seqno = msg_seqno(msg);  in tipc_bclink_rcv()
599 	struct tipc_msg *msg = buf_msg(buf);  in tipc_bcbearer_send()  local
611 		msg_set_non_seq(msg, 1);  in tipc_bcbearer_send()
612 		msg_set_mc_netid(msg, tn->net_id);  in tipc_bcbearer_send()
627 		struct tipc_bearer *b = bp[msg_link_selector(msg)];  in tipc_bcbearer_send()
775 int tipc_nl_add_bc_link(struct net *net, struct tipc_nl_msg *msg)  in tipc_nl_add_bc_link()  argument
789 	hdr = genlmsg_put(msg->skb, msg->portid, msg->seq, &tipc_genl_family,  in tipc_nl_add_bc_link()
794 	attrs = nla_nest_start(msg->skb, TIPC_NLA_LINK);  in tipc_nl_add_bc_link()
799 	if (nla_put_flag(msg->skb, TIPC_NLA_LINK_UP))  in tipc_nl_add_bc_link()
802 	if (nla_put_flag(msg->skb, TIPC_NLA_LINK_BROADCAST))  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()
811 	prop = nla_nest_start(msg->skb, TIPC_NLA_LINK_PROP);  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()
816 	nla_nest_end(msg->skb, prop);  in tipc_nl_add_bc_link()
818 	err = __tipc_nl_add_bc_link_stat(msg->skb, &bcl->stats);  in tipc_nl_add_bc_link()
823 	nla_nest_end(msg->skb, attrs);  in tipc_nl_add_bc_link()
824 	genlmsg_end(msg->skb, hdr);  in tipc_nl_add_bc_link()
829 	nla_nest_cancel(msg->skb, prop);  in tipc_nl_add_bc_link()
831 	nla_nest_cancel(msg->skb, attrs);  in tipc_nl_add_bc_link()
834 	genlmsg_cancel(msg->skb, hdr);  in tipc_nl_add_bc_link()