167 		struct tipc_msg *msg = buf_msg(l_ptr->first_out);  in link_timeout()  local
168 		u32 length = msg_size(msg);  in link_timeout()
170 		if ((msg_user(msg) == MSG_FRAGMENTER) &&  in link_timeout()
171 		    (msg_type(msg) == FIRST_FRAGMENT)) {  in link_timeout()
172 			length = msg_size(msg_get_wrapped(msg));  in link_timeout()
222 	struct tipc_msg *msg;  in tipc_link_create()  local
263 	msg = l_ptr->pmsg;  in tipc_link_create()
264 	tipc_msg_init(msg, LINK_PROTOCOL, RESET_MSG, INT_H_SIZE, l_ptr->addr);  in tipc_link_create()
265 	msg_set_size(msg, sizeof(l_ptr->proto_msg));  in tipc_link_create()
266 	msg_set_session(msg, (tipc_random & 0xffff));  in tipc_link_create()
267 	msg_set_bearer_id(msg, b_ptr->identity);  in tipc_link_create()
268 	strcpy((char *)msg_data(msg), if_name);  in tipc_link_create()
672 	struct tipc_msg *msg = buf_msg(buf);  in tipc_link_cong()  local
673 	uint imp = tipc_msg_tot_importance(msg);  in tipc_link_cong()
674 	u32 oport = msg_tot_origport(msg);  in tipc_link_cong()
681 	if (unlikely(msg_errcode(msg)))  in tipc_link_cong()
683 	if (unlikely(msg_reroute_cnt(msg)))  in tipc_link_cong()
706 	struct tipc_msg *msg = buf_msg(buf);  in __tipc_link_xmit()  local
707 	uint psz = msg_size(msg);  in __tipc_link_xmit()
710 	uint imp = tipc_msg_tot_importance(msg);  in __tipc_link_xmit()
731 		msg = buf_msg(buf);  in __tipc_link_xmit()
732 		msg_set_word(msg, 2, ((ack << 16) | mod(seqno)));  in __tipc_link_xmit()
733 		msg_set_bcast_ack(msg, bc_last_in);  in __tipc_link_xmit()
816 	struct tipc_msg *msg;  in tipc_link_sync_xmit()  local
822 	msg = buf_msg(buf);  in tipc_link_sync_xmit()
823 	tipc_msg_init(msg, BCAST_PROTOCOL, STATE_MSG, INT_H_SIZE, link->addr);  in tipc_link_sync_xmit()
824 	msg_set_last_bcast(msg, link->owner->bclink.acked);  in tipc_link_sync_xmit()
838 	struct tipc_msg *msg = buf_msg(buf);  in tipc_link_sync_rcv()  local
840 	n->bclink.last_sent = n->bclink.last_in = msg_last_bcast(msg);  in tipc_link_sync_rcv()
895 		struct tipc_msg *msg = buf_msg(buf);  in tipc_link_push_packet()  local
896 		u32 next = msg_seqno(msg);  in tipc_link_push_packet()
900 			msg_set_ack(msg, mod(l_ptr->next_in_no - 1));  in tipc_link_push_packet()
901 			msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in);  in tipc_link_push_packet()
904 			if (msg_user(msg) == MSG_BUNDLER)  in tipc_link_push_packet()
905 				msg_set_type(msg, BUNDLE_CLOSED);  in tipc_link_push_packet()
949 	struct tipc_msg *msg = buf_msg(buf);  in link_retransmit_failure()  local
963 		pr_info("Msg seq number: %u,  ", msg_seqno(msg));  in link_retransmit_failure()
990 	struct tipc_msg *msg;  in tipc_link_retransmit()  local
995 	msg = buf_msg(buf);  in tipc_link_retransmit()
998 	if (l_ptr->last_retransmitted == msg_seqno(msg)) {  in tipc_link_retransmit()
1004 		l_ptr->last_retransmitted = msg_seqno(msg);  in tipc_link_retransmit()
1009 		msg = buf_msg(buf);  in tipc_link_retransmit()
1010 		msg_set_ack(msg, mod(l_ptr->next_in_no - 1));  in tipc_link_retransmit()
1011 		msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in);  in tipc_link_retransmit()
1061 	struct tipc_msg *msg;  in link_recv_buf_validate()  local
1076 	msg = skb_header_pointer(buf, 0, sizeof(tipc_hdr), tipc_hdr);  in link_recv_buf_validate()
1077 	if (msg == NULL)  in link_recv_buf_validate()
1080 	if (unlikely(msg_version(msg) != TIPC_VERSION))  in link_recv_buf_validate()
1083 	size = msg_size(msg);  in link_recv_buf_validate()
1084 	hdr_size = msg_hdr_sz(msg);  in link_recv_buf_validate()
1085 	min_hdr_size = msg_isdata(msg) ?  in link_recv_buf_validate()
1086 		min_data_hdr_size[msg_type(msg)] : INT_H_SIZE;  in link_recv_buf_validate()
1112 		struct tipc_msg *msg;  in tipc_rcv()  local
1129 		msg = buf_msg(buf);  in tipc_rcv()
1131 		if (unlikely(msg_non_seq(msg))) {  in tipc_rcv()
1132 			if (msg_user(msg) ==  LINK_CONFIG)  in tipc_rcv()
1140 		if (unlikely(!msg_short(msg) &&  in tipc_rcv()
1141 			     (msg_destnode(msg) != tipc_own_addr)))  in tipc_rcv()
1145 		n_ptr = tipc_node_find(msg_prevnode(msg));  in tipc_rcv()
1157 		    msg_user(msg) == LINK_PROTOCOL &&  in tipc_rcv()
1158 		    (msg_type(msg) == RESET_MSG ||  in tipc_rcv()
1159 		    msg_type(msg) == ACTIVATE_MSG) &&  in tipc_rcv()
1160 		    !msg_redundant_link(msg))  in tipc_rcv()
1167 		seq_no = msg_seqno(msg);  in tipc_rcv()
1168 		ackd = msg_ack(msg);  in tipc_rcv()
1172 			tipc_bclink_acknowledge(n_ptr, msg_bcast_ack(msg));  in tipc_rcv()
1198 			if (msg_user(msg) == LINK_PROTOCOL) {  in tipc_rcv()
1239 		msg = buf_msg(buf);  in tipc_rcv()
1260 	struct tipc_msg *msg;  in tipc_link_prepare_input()  local
1264 	msg = buf_msg(*buf);  in tipc_link_prepare_input()
1265 	switch (msg_user(msg)) {  in tipc_link_prepare_input()
1281 		l->stats.recv_bundled += msg_msgcnt(msg);  in tipc_link_prepare_input()
1301 	struct tipc_msg *msg = buf_msg(buf);  in tipc_link_input()  local
1304 	switch (msg_user(msg)) {  in tipc_link_input()
1418 	struct tipc_msg *msg = l_ptr->pmsg;  in tipc_link_proto_xmit()  local
1437 	msg_set_type(msg, msg_typ);  in tipc_link_proto_xmit()
1438 	msg_set_net_plane(msg, l_ptr->net_plane);  in tipc_link_proto_xmit()
1439 	msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in);  in tipc_link_proto_xmit()
1440 	msg_set_last_bcast(msg, tipc_bclink_get_last_sent());  in tipc_link_proto_xmit()
1449 		msg_set_next_sent(msg, next_sent);  in tipc_link_proto_xmit()
1454 		msg_set_seq_gap(msg, gap);  in tipc_link_proto_xmit()
1457 		msg_set_link_tolerance(msg, tolerance);  in tipc_link_proto_xmit()
1458 		msg_set_linkprio(msg, priority);  in tipc_link_proto_xmit()
1459 		msg_set_max_pkt(msg, ack_mtu);  in tipc_link_proto_xmit()
1460 		msg_set_ack(msg, mod(l_ptr->next_in_no - 1));  in tipc_link_proto_xmit()
1461 		msg_set_probe(msg, probe_msg != 0);  in tipc_link_proto_xmit()
1481 		msg_set_ack(msg, mod(l_ptr->reset_checkpoint - 1));  in tipc_link_proto_xmit()
1482 		msg_set_seq_gap(msg, 0);  in tipc_link_proto_xmit()
1483 		msg_set_next_sent(msg, 1);  in tipc_link_proto_xmit()
1484 		msg_set_probe(msg, 0);  in tipc_link_proto_xmit()
1485 		msg_set_link_tolerance(msg, l_ptr->tolerance);  in tipc_link_proto_xmit()
1486 		msg_set_linkprio(msg, l_ptr->priority);  in tipc_link_proto_xmit()
1487 		msg_set_max_pkt(msg, l_ptr->max_pkt_target);  in tipc_link_proto_xmit()
1491 	msg_set_redundant_link(msg, r_flag);  in tipc_link_proto_xmit()
1492 	msg_set_linkprio(msg, l_ptr->priority);  in tipc_link_proto_xmit()
1493 	msg_set_size(msg, msg_size);  in tipc_link_proto_xmit()
1495 	msg_set_seqno(msg, mod(l_ptr->next_out_no + (0xffff/2)));  in tipc_link_proto_xmit()
1501 	skb_copy_to_linear_data(buf, msg, sizeof(l_ptr->proto_msg));  in tipc_link_proto_xmit()
1520 	struct tipc_msg *msg = buf_msg(buf);  in tipc_link_proto_rcv()  local
1526 	if (l_ptr->net_plane != msg_net_plane(msg))  in tipc_link_proto_rcv()
1527 		if (tipc_own_addr > msg_prevnode(msg))  in tipc_link_proto_rcv()
1528 			l_ptr->net_plane = msg_net_plane(msg);  in tipc_link_proto_rcv()
1530 	switch (msg_type(msg)) {  in tipc_link_proto_rcv()
1535 			if (less_eq(msg_session(msg), l_ptr->peer_session))  in tipc_link_proto_rcv()
1539 		if (!msg_redundant_link(msg) && (link_working_working(l_ptr) ||  in tipc_link_proto_rcv()
1553 		strcpy((strrchr(l_ptr->name, ':') + 1), (char *)msg_data(msg));  in tipc_link_proto_rcv()
1555 		msg_tol = msg_link_tolerance(msg);  in tipc_link_proto_rcv()
1559 		if (msg_linkprio(msg) > l_ptr->priority)  in tipc_link_proto_rcv()
1560 			l_ptr->priority = msg_linkprio(msg);  in tipc_link_proto_rcv()
1562 		max_pkt_info = msg_max_pkt(msg);  in tipc_link_proto_rcv()
1576 				msg_last_bcast(msg);  in tipc_link_proto_rcv()
1580 		l_ptr->peer_session = msg_session(msg);  in tipc_link_proto_rcv()
1581 		l_ptr->peer_bearer_id = msg_bearer_id(msg);  in tipc_link_proto_rcv()
1583 		if (msg_type(msg) == ACTIVATE_MSG)  in tipc_link_proto_rcv()
1588 		msg_tol = msg_link_tolerance(msg);  in tipc_link_proto_rcv()
1592 		if (msg_linkprio(msg) &&  in tipc_link_proto_rcv()
1593 		    (msg_linkprio(msg) != l_ptr->priority)) {  in tipc_link_proto_rcv()
1596 				msg_linkprio(msg));  in tipc_link_proto_rcv()
1597 			l_ptr->priority = msg_linkprio(msg);  in tipc_link_proto_rcv()
1610 		if (less_eq(mod(l_ptr->next_in_no), msg_next_sent(msg))) {  in tipc_link_proto_rcv()
1611 			rec_gap = mod(msg_next_sent(msg) -  in tipc_link_proto_rcv()
1615 		max_pkt_ack = msg_max_pkt(msg);  in tipc_link_proto_rcv()
1622 		if (msg_probe(msg)) {  in tipc_link_proto_rcv()
1624 			if (msg_size(msg) > sizeof(l_ptr->proto_msg))  in tipc_link_proto_rcv()
1625 				max_pkt_ack = msg_size(msg);  in tipc_link_proto_rcv()
1631 						      msg_last_bcast(msg));  in tipc_link_proto_rcv()
1633 		if (rec_gap || (msg_probe(msg))) {  in tipc_link_proto_rcv()
1637 		if (msg_seq_gap(msg)) {  in tipc_link_proto_rcv()
1640 					     msg_seq_gap(msg));  in tipc_link_proto_rcv()
1654 				  struct tipc_msg *msg,  in tipc_link_tunnel_xmit()  argument
1659 	u32 length = msg_size(msg);  in tipc_link_tunnel_xmit()
1673 	skb_copy_to_linear_data_offset(buf, INT_H_SIZE, msg, length);  in tipc_link_tunnel_xmit()
1719 		struct tipc_msg *msg = buf_msg(crs);  in tipc_link_failover_send_queue()  local
1721 		if ((msg_user(msg) == MSG_BUNDLER) && split_bundles) {  in tipc_link_failover_send_queue()
1722 			struct tipc_msg *m = msg_get_wrapped(msg);  in tipc_link_failover_send_queue()
1725 			msgcount = msg_msgcnt(msg);  in tipc_link_failover_send_queue()
1727 				msg_set_seqno(m, msg_seqno(msg));  in tipc_link_failover_send_queue()
1734 			tipc_link_tunnel_xmit(l_ptr, &tunnel_hdr, msg,  in tipc_link_failover_send_queue()
1735 					      msg_link_selector(msg));  in tipc_link_failover_send_queue()
1763 		struct tipc_msg *msg = buf_msg(iter);  in tipc_link_dup_queue_xmit()  local
1764 		u32 length = msg_size(msg);  in tipc_link_dup_queue_xmit()
1766 		if (msg_user(msg) == MSG_BUNDLER)  in tipc_link_dup_queue_xmit()
1767 			msg_set_type(msg, CLOSED_MSG);  in tipc_link_dup_queue_xmit()
1768 		msg_set_ack(msg, mod(l_ptr->next_in_no - 1));	/* Update */  in tipc_link_dup_queue_xmit()
1769 		msg_set_bcast_ack(msg, l_ptr->owner->bclink.last_in);  in tipc_link_dup_queue_xmit()
1797 	struct tipc_msg *msg = (struct tipc_msg *)(skb->data + from_pos);  in buf_extract()  local
1798 	u32 size = msg_size(msg);  in buf_extract()
1803 		skb_copy_to_linear_data(eb, msg, size);  in buf_extract()
1838 	struct tipc_msg *msg;  in tipc_link_failover_rcv()  local
1855 		msg = buf_msg(buf);  in tipc_link_failover_rcv()
1857 		if (less(msg_seqno(msg), l_ptr->reset_checkpoint)) {  in tipc_link_failover_rcv()
1862 		if (msg_user(msg) == MSG_FRAGMENTER) {  in tipc_link_failover_rcv()