190 void tipc_bclink_acknowledge(struct tipc_node *n_ptr, u32 acked)  in tipc_bclink_acknowledge()  argument
194 	struct net *net = n_ptr->net;  in tipc_bclink_acknowledge()
197 	if (unlikely(!n_ptr->bclink.recv_permitted))  in tipc_bclink_acknowledge()
225 		    less_eq(acked, n_ptr->bclink.acked))  in tipc_bclink_acknowledge()
231 		if (more(buf_seqno(skb), n_ptr->bclink.acked))  in tipc_bclink_acknowledge()
247 	n_ptr->bclink.acked = acked;  in tipc_bclink_acknowledge()
255 		n_ptr->action_flags |= TIPC_WAKEUP_BCAST_USERS;  in tipc_bclink_acknowledge()
265 void tipc_bclink_update_link_state(struct tipc_node *n_ptr,  in tipc_bclink_update_link_state()  argument
269 	struct net *net = n_ptr->net;  in tipc_bclink_update_link_state()
273 	if (less_eq(last_sent, n_ptr->bclink.last_in))  in tipc_bclink_update_link_state()
277 	bclink_update_last_sent(n_ptr, last_sent);  in tipc_bclink_update_link_state()
279 	if (n_ptr->bclink.last_sent == n_ptr->bclink.last_in)  in tipc_bclink_update_link_state()
283 	if ((++n_ptr->bclink.oos_state) == 1) {  in tipc_bclink_update_link_state()
284 		if (n_ptr->bclink.deferred_size < (TIPC_MIN_LINK_WIN / 2))  in tipc_bclink_update_link_state()
286 		n_ptr->bclink.oos_state++;  in tipc_bclink_update_link_state()
290 	if (n_ptr->bclink.oos_state & 0x1)  in tipc_bclink_update_link_state()
297 		struct sk_buff *skb = skb_peek(&n_ptr->bclink.deferdq);  in tipc_bclink_update_link_state()
298 		u32 to = skb ? buf_seqno(skb) - 1 : n_ptr->bclink.last_sent;  in tipc_bclink_update_link_state()
301 			      INT_H_SIZE, n_ptr->addr);  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()
314 		n_ptr->bclink.oos_state++;  in tipc_bclink_update_link_state()
326 	struct tipc_node *n_ptr = tipc_node_find(net, msg_destnode(msg));  in bclink_peek_nack()  local
328 	if (unlikely(!n_ptr))  in bclink_peek_nack()
331 	tipc_node_lock(n_ptr);  in bclink_peek_nack()
332 	if (n_ptr->bclink.recv_permitted &&  in bclink_peek_nack()
333 	    (n_ptr->bclink.last_in != n_ptr->bclink.last_sent) &&  in bclink_peek_nack()
334 	    (n_ptr->bclink.last_in == msg_bcgap_after(msg)))  in bclink_peek_nack()
335 		n_ptr->bclink.oos_state = 2;  in bclink_peek_nack()
336 	tipc_node_unlock(n_ptr);  in bclink_peek_nack()
337 	tipc_node_put(n_ptr);  in bclink_peek_nack()
578 u32 tipc_bclink_acks_missing(struct tipc_node *n_ptr)  in tipc_bclink_acks_missing()  argument
580 	return (n_ptr->bclink.recv_permitted &&  in tipc_bclink_acks_missing()
581 		(tipc_bclink_get_last_sent(n_ptr->net) != n_ptr->bclink.acked));  in tipc_bclink_acks_missing()