52 static void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node);
53 static void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node);
133 static void bclink_update_last_sent(struct tipc_node *node, u32 seqno)  in bclink_update_last_sent()  argument
135 	node->bclink.last_sent = less_eq(node->bclink.last_sent, seqno) ?  in bclink_update_last_sent()
136 						seqno : node->bclink.last_sent;  in bclink_update_last_sent()
401 static void bclink_accept_pkt(struct tipc_node *node, u32 seqno)  in bclink_accept_pkt()  argument
403 	struct tipc_net *tn = net_generic(node->net, tipc_net_id);  in bclink_accept_pkt()
405 	bclink_update_last_sent(node, seqno);  in bclink_accept_pkt()
406 	node->bclink.last_in = seqno;  in bclink_accept_pkt()
407 	node->bclink.oos_state = 0;  in bclink_accept_pkt()
415 		tipc_link_proto_xmit(node->active_links[node->addr & 1],  in bclink_accept_pkt()
431 	struct tipc_node *node;  in tipc_bclink_rcv()  local
443 	node = tipc_node_find(net, msg_prevnode(msg));  in tipc_bclink_rcv()
444 	if (unlikely(!node))  in tipc_bclink_rcv()
447 	tipc_node_lock(node);  in tipc_bclink_rcv()
448 	if (unlikely(!node->bclink.recv_permitted))  in tipc_bclink_rcv()
456 			tipc_bclink_acknowledge(node, msg_bcast_ack(msg));  in tipc_bclink_rcv()
459 			tn->bclink->retransmit_to = node;  in tipc_bclink_rcv()
463 			tipc_node_unlock(node);  in tipc_bclink_rcv()
465 			tipc_node_unlock(node);  in tipc_bclink_rcv()
468 		tipc_node_put(node);  in tipc_bclink_rcv()
474 	next_in = mod(node->bclink.last_in + 1);  in tipc_bclink_rcv()
483 			bclink_accept_pkt(node, seqno);  in tipc_bclink_rcv()
487 			node->action_flags |= TIPC_BCAST_MSG_EVT;  in tipc_bclink_rcv()
489 			tipc_node_unlock(node);  in tipc_bclink_rcv()
492 			bclink_accept_pkt(node, seqno);  in tipc_bclink_rcv()
501 			node->action_flags |= TIPC_BCAST_MSG_EVT;  in tipc_bclink_rcv()
503 			tipc_node_unlock(node);  in tipc_bclink_rcv()
506 			bclink_accept_pkt(node, seqno);  in tipc_bclink_rcv()
507 			tipc_buf_append(&node->bclink.reasm_buf, &buf);  in tipc_bclink_rcv()
508 			if (unlikely(!buf && !node->bclink.reasm_buf)) {  in tipc_bclink_rcv()
520 			tipc_node_unlock(node);  in tipc_bclink_rcv()
523 			bclink_accept_pkt(node, seqno);  in tipc_bclink_rcv()
525 			tipc_node_unlock(node);  in tipc_bclink_rcv()
531 		tipc_node_lock(node);  in tipc_bclink_rcv()
532 		if (unlikely(!tipc_node_is_up(node)))  in tipc_bclink_rcv()
535 		if (node->bclink.last_in == node->bclink.last_sent)  in tipc_bclink_rcv()
538 		if (skb_queue_empty(&node->bclink.deferdq)) {  in tipc_bclink_rcv()
539 			node->bclink.oos_state = 1;  in tipc_bclink_rcv()
543 		msg = buf_msg(skb_peek(&node->bclink.deferdq));  in tipc_bclink_rcv()
550 		buf = __skb_dequeue(&node->bclink.deferdq);  in tipc_bclink_rcv()
556 		deferred = tipc_link_defer_pkt(&node->bclink.deferdq,  in tipc_bclink_rcv()
558 		bclink_update_last_sent(node, seqno);  in tipc_bclink_rcv()
572 	tipc_node_unlock(node);  in tipc_bclink_rcv()
573 	tipc_node_put(node);  in tipc_bclink_rcv()
664 			u32 node, bool action)  in tipc_bcbearer_sort()  argument
677 		tipc_nmap_add(nm_ptr, node);  in tipc_bcbearer_sort()
679 		tipc_nmap_remove(nm_ptr, node);  in tipc_bcbearer_sort()
897 	spin_lock_init(&bclink->node.lock);  in tipc_bclink_init()
900 	bcl->owner = &bclink->node;  in tipc_bclink_init()
933 static void tipc_nmap_add(struct tipc_node_map *nm_ptr, u32 node)  in tipc_nmap_add()  argument
935 	int n = tipc_node(node);  in tipc_nmap_add()
948 static void tipc_nmap_remove(struct tipc_node_map *nm_ptr, u32 node)  in tipc_nmap_remove()  argument
950 	int n = tipc_node(node);  in tipc_nmap_remove()