172 		struct tipc_msg *msg = buf_msg(skb);  in link_timeout()  local
173 		u32 length = msg_size(msg);  in link_timeout()
175 		if ((msg_user(msg) == MSG_FRAGMENTER) &&  in link_timeout()
176 		    (msg_type(msg) == FIRST_FRAGMENT)) {  in link_timeout()
177 			length = msg_size(msg_get_wrapped(msg));  in link_timeout()
229 	struct tipc_msg *msg;  in tipc_link_create()  local
271 	msg = l_ptr->pmsg;  in tipc_link_create()
272 	tipc_msg_init(tn->own_addr, msg, LINK_PROTOCOL, RESET_MSG, INT_H_SIZE,  in tipc_link_create()
274 	msg_set_size(msg, sizeof(l_ptr->proto_msg));  in tipc_link_create()
275 	msg_set_session(msg, (tn->random & 0xffff));  in tipc_link_create()
276 	msg_set_bearer_id(msg, b_ptr->identity);  in tipc_link_create()
277 	strcpy((char *)msg_data(msg), if_name);  in tipc_link_create()
341 	struct tipc_msg *msg = buf_msg(skb_peek(list));  in link_schedule_user()  local
342 	int imp = msg_importance(msg);  in link_schedule_user()
343 	u32 oport = msg_origport(msg);  in link_schedule_user()
702 	struct tipc_msg *msg = buf_msg(skb_peek(list));  in __tipc_link_xmit()  local
704 	unsigned int imp = msg_importance(msg);  in __tipc_link_xmit()
718 	if (unlikely(msg_size(msg) > mtu)) {  in __tipc_link_xmit()
725 		msg = buf_msg(skb);  in __tipc_link_xmit()
726 		msg_set_seqno(msg, seqno);  in __tipc_link_xmit()
727 		msg_set_ack(msg, ack);  in __tipc_link_xmit()
728 		msg_set_bcast_ack(msg, bc_last_in);  in __tipc_link_xmit()
838 	struct tipc_msg *msg;  in tipc_link_sync_xmit()  local
844 	msg = buf_msg(skb);  in tipc_link_sync_xmit()
845 	tipc_msg_init(link_own_addr(link), msg, BCAST_PROTOCOL, STATE_MSG,  in tipc_link_sync_xmit()
847 	msg_set_last_bcast(msg, link->owner->bclink.acked);  in tipc_link_sync_xmit()
861 	struct tipc_msg *msg = buf_msg(buf);  in tipc_link_sync_rcv()  local
863 	n->bclink.last_sent = n->bclink.last_in = msg_last_bcast(msg);  in tipc_link_sync_rcv()
879 	struct tipc_msg *msg;  in tipc_link_push_packets()  local
886 		msg = buf_msg(skb);  in tipc_link_push_packets()
887 		link->backlog[msg_importance(msg)].len--;  in tipc_link_push_packets()
888 		msg_set_ack(msg, ack);  in tipc_link_push_packets()
889 		msg_set_bcast_ack(msg, link->owner->bclink.last_in);  in tipc_link_push_packets()
920 	struct tipc_msg *msg = buf_msg(buf);  in link_retransmit_failure()  local
935 		pr_info("Msg seq number: %u,  ", msg_seqno(msg));  in link_retransmit_failure()
959 	struct tipc_msg *msg;  in tipc_link_retransmit()  local
964 	msg = buf_msg(skb);  in tipc_link_retransmit()
967 	if (l_ptr->last_retransmitted == msg_seqno(msg)) {  in tipc_link_retransmit()
973 		l_ptr->last_retransmitted = msg_seqno(msg);  in tipc_link_retransmit()
980 		msg = buf_msg(skb);  in tipc_link_retransmit()
981 		msg_set_ack(msg, mod(l_ptr->next_in_no - 1));  in tipc_link_retransmit()
982 		msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in);  in tipc_link_retransmit()
1045 	struct tipc_msg *msg;  in tipc_rcv()  local
1058 		msg = buf_msg(skb);  in tipc_rcv()
1059 		if (unlikely(msg_non_seq(msg))) {  in tipc_rcv()
1060 			if (msg_user(msg) ==  LINK_CONFIG)  in tipc_rcv()
1068 		if (unlikely(!msg_short(msg) &&  in tipc_rcv()
1069 			     (msg_destnode(msg) != tn->own_addr)))  in tipc_rcv()
1073 		n_ptr = tipc_node_find(net, msg_prevnode(msg));  in tipc_rcv()
1085 		    msg_user(msg) == LINK_PROTOCOL &&  in tipc_rcv()
1086 		    (msg_type(msg) == RESET_MSG ||  in tipc_rcv()
1087 		    msg_type(msg) == ACTIVATE_MSG) &&  in tipc_rcv()
1088 		    !msg_redundant_link(msg))  in tipc_rcv()
1095 		seq_no = msg_seqno(msg);  in tipc_rcv()
1096 		ackd = msg_ack(msg);  in tipc_rcv()
1099 		if (unlikely(n_ptr->bclink.acked != msg_bcast_ack(msg)))  in tipc_rcv()
1100 			tipc_bclink_acknowledge(n_ptr, msg_bcast_ack(msg));  in tipc_rcv()
1120 			if (msg_user(msg) == LINK_PROTOCOL) {  in tipc_rcv()
1147 		if (unlikely((l_ptr->flags & LINK_SYNCHING) && !msg_dup(msg))) {  in tipc_rcv()
1177 	struct tipc_msg *msg = buf_msg(skb);  in tipc_data_input()  local
1178 	u32 dport = msg_destport(msg);  in tipc_data_input()
1180 	switch (msg_user(msg)) {  in tipc_data_input()
1218 	struct tipc_msg *msg = buf_msg(skb);  in tipc_link_input()  local
1225 	switch (msg_user(msg)) {  in tipc_link_input()
1227 		if (msg_dup(msg)) {  in tipc_link_input()
1229 			link->synch_point = msg_seqno(msg_get_wrapped(msg));  in tipc_link_input()
1241 		link->stats.recv_bundled += msg_msgcnt(msg);  in tipc_link_input()
1344 	struct tipc_msg *msg = l_ptr->pmsg;  in tipc_link_proto_xmit()  local
1357 	msg_set_type(msg, msg_typ);  in tipc_link_proto_xmit()
1358 	msg_set_net_plane(msg, l_ptr->net_plane);  in tipc_link_proto_xmit()
1359 	msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in);  in tipc_link_proto_xmit()
1360 	msg_set_last_bcast(msg, tipc_bclink_get_last_sent(l_ptr->owner->net));  in tipc_link_proto_xmit()
1369 		msg_set_next_sent(msg, next_sent);  in tipc_link_proto_xmit()
1374 		msg_set_seq_gap(msg, gap);  in tipc_link_proto_xmit()
1377 		msg_set_link_tolerance(msg, tolerance);  in tipc_link_proto_xmit()
1378 		msg_set_linkprio(msg, priority);  in tipc_link_proto_xmit()
1379 		msg_set_max_pkt(msg, l_ptr->mtu);  in tipc_link_proto_xmit()
1380 		msg_set_ack(msg, mod(l_ptr->next_in_no - 1));  in tipc_link_proto_xmit()
1381 		msg_set_probe(msg, probe_msg != 0);  in tipc_link_proto_xmit()
1386 		msg_set_ack(msg, mod(l_ptr->failover_checkpt - 1));  in tipc_link_proto_xmit()
1387 		msg_set_seq_gap(msg, 0);  in tipc_link_proto_xmit()
1388 		msg_set_next_sent(msg, 1);  in tipc_link_proto_xmit()
1389 		msg_set_probe(msg, 0);  in tipc_link_proto_xmit()
1390 		msg_set_link_tolerance(msg, l_ptr->tolerance);  in tipc_link_proto_xmit()
1391 		msg_set_linkprio(msg, l_ptr->priority);  in tipc_link_proto_xmit()
1392 		msg_set_max_pkt(msg, l_ptr->advertised_mtu);  in tipc_link_proto_xmit()
1396 	msg_set_redundant_link(msg, r_flag);  in tipc_link_proto_xmit()
1397 	msg_set_linkprio(msg, l_ptr->priority);  in tipc_link_proto_xmit()
1398 	msg_set_size(msg, msg_size);  in tipc_link_proto_xmit()
1400 	msg_set_seqno(msg, mod(l_ptr->next_out_no + (0xffff/2)));  in tipc_link_proto_xmit()
1406 	skb_copy_to_linear_data(buf, msg, sizeof(l_ptr->proto_msg));  in tipc_link_proto_xmit()
1424 	struct tipc_msg *msg = buf_msg(buf);  in tipc_link_proto_rcv()  local
1429 	if (l_ptr->net_plane != msg_net_plane(msg))  in tipc_link_proto_rcv()
1430 		if (link_own_addr(l_ptr) > msg_prevnode(msg))  in tipc_link_proto_rcv()
1431 			l_ptr->net_plane = msg_net_plane(msg);  in tipc_link_proto_rcv()
1433 	switch (msg_type(msg)) {  in tipc_link_proto_rcv()
1438 			if (less_eq(msg_session(msg), l_ptr->peer_session))  in tipc_link_proto_rcv()
1442 		if (!msg_redundant_link(msg) && (link_working_working(l_ptr) ||  in tipc_link_proto_rcv()
1456 		strcpy((strrchr(l_ptr->name, ':') + 1), (char *)msg_data(msg));  in tipc_link_proto_rcv()
1458 		msg_tol = msg_link_tolerance(msg);  in tipc_link_proto_rcv()
1462 		if (msg_linkprio(msg) > l_ptr->priority)  in tipc_link_proto_rcv()
1463 			l_ptr->priority = msg_linkprio(msg);  in tipc_link_proto_rcv()
1465 		if (l_ptr->mtu > msg_max_pkt(msg))  in tipc_link_proto_rcv()
1466 			l_ptr->mtu = msg_max_pkt(msg);  in tipc_link_proto_rcv()
1472 				msg_last_bcast(msg);  in tipc_link_proto_rcv()
1476 		l_ptr->peer_session = msg_session(msg);  in tipc_link_proto_rcv()
1477 		l_ptr->peer_bearer_id = msg_bearer_id(msg);  in tipc_link_proto_rcv()
1479 		if (msg_type(msg) == ACTIVATE_MSG)  in tipc_link_proto_rcv()
1484 		msg_tol = msg_link_tolerance(msg);  in tipc_link_proto_rcv()
1488 		if (msg_linkprio(msg) &&  in tipc_link_proto_rcv()
1489 		    (msg_linkprio(msg) != l_ptr->priority)) {  in tipc_link_proto_rcv()
1492 				 l_ptr->priority, msg_linkprio(msg));  in tipc_link_proto_rcv()
1493 			l_ptr->priority = msg_linkprio(msg);  in tipc_link_proto_rcv()
1506 		if (less_eq(mod(l_ptr->next_in_no), msg_next_sent(msg))) {  in tipc_link_proto_rcv()
1507 			rec_gap = mod(msg_next_sent(msg) -  in tipc_link_proto_rcv()
1511 		if (msg_probe(msg))  in tipc_link_proto_rcv()
1517 						      msg_last_bcast(msg));  in tipc_link_proto_rcv()
1519 		if (rec_gap || (msg_probe(msg))) {  in tipc_link_proto_rcv()
1523 		if (msg_seq_gap(msg)) {  in tipc_link_proto_rcv()
1526 					     msg_seq_gap(msg));  in tipc_link_proto_rcv()
1540 				  struct tipc_msg *msg,  in tipc_link_tunnel_xmit()  argument
1545 	u32 length = msg_size(msg);  in tipc_link_tunnel_xmit()
1559 	skb_copy_to_linear_data_offset(skb, INT_H_SIZE, msg, length);  in tipc_link_tunnel_xmit()
1606 		struct tipc_msg *msg = buf_msg(skb);  in tipc_link_failover_send_queue()  local
1608 		if ((msg_user(msg) == MSG_BUNDLER) && split_bundles) {  in tipc_link_failover_send_queue()
1609 			struct tipc_msg *m = msg_get_wrapped(msg);  in tipc_link_failover_send_queue()
1612 			msgcount = msg_msgcnt(msg);  in tipc_link_failover_send_queue()
1614 				msg_set_seqno(m, msg_seqno(msg));  in tipc_link_failover_send_queue()
1621 			tipc_link_tunnel_xmit(l_ptr, &tunnel_hdr, msg,  in tipc_link_failover_send_queue()
1622 					      msg_link_selector(msg));  in tipc_link_failover_send_queue()
1653 		struct tipc_msg *msg = buf_msg(skb);  in tipc_link_dup_queue_xmit()  local
1654 		u32 len = msg_size(msg);  in tipc_link_dup_queue_xmit()
1656 		msg_set_ack(msg, mod(link->next_in_no - 1));  in tipc_link_dup_queue_xmit()
1657 		msg_set_bcast_ack(msg, link->owner->bclink.last_in);  in tipc_link_dup_queue_xmit()
1684 	struct tipc_msg *msg = buf_msg(*skb);  in tipc_link_failover_rcv()  local
1687 	int bearer_id = msg_bearer_id(msg);  in tipc_link_failover_rcv()
1690 	if (msg_type(msg) != FAILOVER_MSG) {  in tipc_link_failover_rcv()
1705 		link->failover_pkts = msg_msgcnt(msg);  in tipc_link_failover_rcv()
2012 static int __tipc_nl_add_link(struct net *net, struct tipc_nl_msg *msg,  in __tipc_nl_add_link()  argument
2021 	hdr = genlmsg_put(msg->skb, msg->portid, msg->seq, &tipc_genl_family,  in __tipc_nl_add_link()
2026 	attrs = nla_nest_start(msg->skb, TIPC_NLA_LINK);  in __tipc_nl_add_link()
2030 	if (nla_put_string(msg->skb, TIPC_NLA_LINK_NAME, link->name))  in __tipc_nl_add_link()
2032 	if (nla_put_u32(msg->skb, TIPC_NLA_LINK_DEST,  in __tipc_nl_add_link()
2035 	if (nla_put_u32(msg->skb, TIPC_NLA_LINK_MTU, link->mtu))  in __tipc_nl_add_link()
2037 	if (nla_put_u32(msg->skb, TIPC_NLA_LINK_RX, link->next_in_no))  in __tipc_nl_add_link()
2039 	if (nla_put_u32(msg->skb, TIPC_NLA_LINK_TX, link->next_out_no))  in __tipc_nl_add_link()
2043 		if (nla_put_flag(msg->skb, TIPC_NLA_LINK_UP))  in __tipc_nl_add_link()
2046 		if (nla_put_flag(msg->skb, TIPC_NLA_LINK_ACTIVE))  in __tipc_nl_add_link()
2049 	prop = nla_nest_start(msg->skb, TIPC_NLA_LINK_PROP);  in __tipc_nl_add_link()
2052 	if (nla_put_u32(msg->skb, TIPC_NLA_PROP_PRIO, link->priority))  in __tipc_nl_add_link()
2054 	if (nla_put_u32(msg->skb, TIPC_NLA_PROP_TOL, link->tolerance))  in __tipc_nl_add_link()
2056 	if (nla_put_u32(msg->skb, TIPC_NLA_PROP_WIN,  in __tipc_nl_add_link()
2059 	if (nla_put_u32(msg->skb, TIPC_NLA_PROP_PRIO, link->priority))  in __tipc_nl_add_link()
2061 	nla_nest_end(msg->skb, prop);  in __tipc_nl_add_link()
2063 	err = __tipc_nl_add_stats(msg->skb, &link->stats);  in __tipc_nl_add_link()
2067 	nla_nest_end(msg->skb, attrs);  in __tipc_nl_add_link()
2068 	genlmsg_end(msg->skb, hdr);  in __tipc_nl_add_link()
2073 	nla_nest_cancel(msg->skb, prop);  in __tipc_nl_add_link()
2075 	nla_nest_cancel(msg->skb, attrs);  in __tipc_nl_add_link()
2077 	genlmsg_cancel(msg->skb, hdr);  in __tipc_nl_add_link()
2083 static int __tipc_nl_add_node_links(struct net *net, struct tipc_nl_msg *msg,  in __tipc_nl_add_node_links()  argument
2095 		err = __tipc_nl_add_link(net, msg, node->links[i], NLM_F_MULTI);  in __tipc_nl_add_node_links()
2109 	struct tipc_nl_msg msg;  in tipc_nl_link_dump()  local
2118 	msg.skb = skb;  in tipc_nl_link_dump()
2119 	msg.portid = NETLINK_CB(cb->skb).portid;  in tipc_nl_link_dump()
2120 	msg.seq = cb->nlh->nlmsg_seq;  in tipc_nl_link_dump()
2140 			err = __tipc_nl_add_node_links(net, &msg, node,  in tipc_nl_link_dump()
2149 		err = tipc_nl_add_bc_link(net, &msg);  in tipc_nl_link_dump()
2155 			err = __tipc_nl_add_node_links(net, &msg, node,  in tipc_nl_link_dump()
2179 	struct tipc_nl_msg msg;  in tipc_nl_link_get()  local
2198 	msg.skb = ans_skb;  in tipc_nl_link_get()
2199 	msg.portid = info->snd_portid;  in tipc_nl_link_get()
2200 	msg.seq = info->snd_seq;  in tipc_nl_link_get()
2209 	err = __tipc_nl_add_link(net, &msg, link, 0);  in tipc_nl_link_get()