net/tipc/node.c

174 static void __tipc_node_link_down(struct tipc_node *n, int *bearer_id,
177 static void tipc_node_link_down(struct tipc_node *n, int bearer_id,
197 	int bearer_id = n->active_links[sel & 1];
199 	if (unlikely(bearer_id == INVALID_BEARER_ID))
202 	return n->links[bearer_id].link;
208 	int bearer_id;
223 	bearer_id = n->active_links[sel & 1];
224 	if (likely(bearer_id != INVALID_BEARER_ID))
225 		mtu = n->links[bearer_id].mtu;
404 	u32 bearer_id, node;
416 	bearer_id = n->link_id & 0xffff;
431 		tipc_mon_peer_up(net, node, bearer_id);
435 		tipc_mon_peer_down(net, node, bearer_id);
476 	int bearer_id;
520 		for (bearer_id = 0; bearer_id < MAX_BEARERS; bearer_id++) {
521 			l = n->links[bearer_id].link;
807 	int bearer_id;
829 	for (bearer_id = 0; remains && (bearer_id < MAX_BEARERS); bearer_id++) {
831 		le = &n->links[bearer_id];
841 		tipc_bearer_xmit(n->net, bearer_id, &xmitq, &le->maddr, n);
843 			tipc_node_link_down(n, bearer_id, false);
851  * @bearer_id: id of the bearer
856 static void __tipc_node_link_up(struct tipc_node *n, int bearer_id,
862 	struct tipc_link *nl = n->links[bearer_id].link;
876 	n->links[bearer_id].mtu = tipc_link_mss(nl);
878 	tipc_bearer_add_dest(n->net, bearer_id, n->addr);
879 	tipc_bcast_inc_bearer_dst_cnt(n->net, bearer_id);
890 		*slot0 = bearer_id;
891 		*slot1 = bearer_id;
902 		*slot0 = bearer_id;
903 		*slot1 = bearer_id;
908 		*slot1 = bearer_id;
920  * @bearer_id: id of the bearer
925 static void tipc_node_link_up(struct tipc_node *n, int bearer_id,
931 	__tipc_node_link_up(n, bearer_id, xmitq);
932 	maddr = &n->links[bearer_id].maddr;
933 	tipc_bearer_xmit(n->net, bearer_id, xmitq, maddr, n);
984  * @bearer_id: id of the bearer
988 static void __tipc_node_link_down(struct tipc_node *n, int *bearer_id,
992 	struct tipc_link_entry *le = &n->links[*bearer_id];
998 	l = n->links[*bearer_id].link;
1006 	tipc_bearer_remove_dest(n->net, *bearer_id, n->addr);
1040 		*maddr = &n->links[*bearer_id].maddr;
1042 		tipc_bcast_dec_bearer_dst_cnt(n->net, *bearer_id);
1045 	tipc_bcast_dec_bearer_dst_cnt(n->net, *bearer_id);
1048 	*bearer_id = n->active_links[0];
1049 	tnl = n->links[*bearer_id].link;
1059 	*maddr = &n->links[*bearer_id].maddr;
1062 static void tipc_node_link_down(struct tipc_node *n, int bearer_id, bool delete)
1064 	struct tipc_link_entry *le = &n->links[bearer_id];
1067 	int old_bearer_id = bearer_id;
1077 		__tipc_node_link_down(n, &bearer_id, &xmitq, &maddr);
1093 		tipc_bearer_xmit(n->net, bearer_id, &xmitq, maddr, n);
1313 void tipc_node_delete_links(struct net *net, int bearer_id)
1320 		tipc_node_link_down(n, bearer_id, true);
1561  * @bearer_id: id of the bearer
1568 int tipc_node_get_linkname(struct net *net, u32 bearer_id, u32 addr,
1578 	if (bearer_id >= MAX_BEARERS)
1582 	link = node->links[bearer_id].link;
1695 	int bearer_id;
1728 	bearer_id = n->active_links[selector & 1];
1729 	if (unlikely(bearer_id == INVALID_BEARER_ID)) {
1737 	le = &n->links[bearer_id];
1744 		tipc_node_link_down(n, bearer_id, false);
1746 		tipc_bearer_xmit(net, bearer_id, &xmitq, &le->maddr, n);
1834 				  int bearer_id, struct sk_buff_head *xmitq)
1855 	ucl = n->links[bearer_id].link;
1865  * @bearer_id: id of bearer message arrived on
1869 static void tipc_node_bc_rcv(struct net *net, struct sk_buff *skb, int bearer_id)
1892 	le = &n->links[bearer_id];
1904 		tipc_bearer_xmit(net, bearer_id, &xmitq, &le->maddr, n);
1926  * @bearer_id: identity of bearer delivering the packet
1931 				  int bearer_id, struct sk_buff_head *xmitq)
1948 	l = n->links[bearer_id].link;
1959 		if ((pb_id != bearer_id) && n->links[pb_id].link) {
2040 			__tipc_node_link_up(n, bearer_id, xmitq);
2089 	int bearer_id = b->identity;
2127 			return tipc_node_bc_rcv(net, skb, bearer_id);
2138 	le = &n->links[bearer_id];
2147 		tipc_node_bc_sync_rcv(n, hdr, bearer_id, &xmitq);
2169 		if (tipc_node_check_state(n, skb, bearer_id, &xmitq)) {
2179 		tipc_node_link_up(n, bearer_id, &xmitq);
2182 		tipc_node_link_down(n, bearer_id, false);
2196 		tipc_bearer_xmit(net, bearer_id, &xmitq, &le->maddr, n);
2208 	int bearer_id = b->identity;
2219 		e = &n->links[bearer_id];
2232 		tipc_bearer_xmit(net, bearer_id, &xmitq, &e->maddr, NULL);
2380  * @bearer_id: pointer to index in 'node->links' array where the link was found.
2386 						unsigned int *bearer_id)
2394 	*bearer_id = 0;
2401 				*bearer_id = i;
2419 	int bearer_id;
2446 	node = tipc_node_find_by_name(net, name, &bearer_id);
2452 	link = node->links[bearer_id].link;
2491 	tipc_bearer_xmit(net, bearer_id, &xmitq, &node->links[bearer_id].maddr,
2530 		int bearer_id;
2534 		node = tipc_node_find_by_name(net, name, &bearer_id);
2541 		link = node->links[bearer_id].link;
2565 	unsigned int bearer_id;
2609 	node = tipc_node_find_by_name(net, link_name, &bearer_id);
2613 	le = &node->links[bearer_id];
2616 	link = node->links[bearer_id].link;
2838 	int bearer_id;
2849 	for (bearer_id = prev_bearer; bearer_id < MAX_BEARERS; bearer_id++) {
2850 		err = __tipc_nl_add_monitor(net, &msg, bearer_id);
2855 	cb->args[0] = bearer_id;
2865 	u32 bearer_id = cb->args[2];
2887 		bearer_id = nla_get_u32(mon[TIPC_NLA_MON_REF]);
2889 		if (bearer_id >= MAX_BEARERS)
2901 	err = tipc_nl_add_monitor_peer(net, &msg, bearer_id, &prev_node);
2908 	cb->args[2] = bearer_id;