272 static bool tsk_peer_msg(struct tipc_sock *tsk, struct tipc_msg *msg)  in tsk_peer_msg()  argument
282 	if (unlikely(msg_origport(msg) != peer_port))  in tsk_peer_msg()
285 	orig_node = msg_orignode(msg);  in tsk_peer_msg()
320 	struct tipc_msg *msg;  in tipc_sk_create()  local
352 	msg = &tsk->phdr;  in tipc_sk_create()
354 	tipc_msg_init(tn->own_addr, msg, TIPC_LOW_IMPORTANCE, TIPC_NAMED_MSG,  in tipc_sk_create()
365 	msg_set_origport(msg, tsk->portid);  in tipc_sk_create()
663 			  struct msghdr *msg, size_t dsz, long timeo)  in tipc_sendmcast()  argument
670 	struct iov_iter save = msg->msg_iter;  in tipc_sendmcast()
685 	rc = tipc_msg_build(mhdr, msg, 0, dsz, mtu, pktchain);  in tipc_sendmcast()
696 			msg->msg_iter = save;  in tipc_sendmcast()
719 	struct tipc_msg *msg;  in tipc_sk_mcast_rcv()  local
732 		msg = buf_msg(skb);  in tipc_sk_mcast_rcv()
733 		hsz = skb_headroom(skb) + msg_hdr_sz(msg);  in tipc_sk_mcast_rcv()
735 		if (in_own_node(net, msg_orignode(msg)))  in tipc_sk_mcast_rcv()
740 					  msg_nametype(msg), msg_namelower(msg),  in tipc_sk_mcast_rcv()
741 					  msg_nameupper(msg), scope, &dports);  in tipc_sk_mcast_rcv()
772 	struct tipc_msg *msg = buf_msg(*skb);  in tipc_sk_proto_rcv()  local
777 	if (!tsk_peer_msg(tsk, msg))  in tipc_sk_proto_rcv()
782 	if (msg_type(msg) == CONN_ACK) {  in tipc_sk_proto_rcv()
784 		tsk->sent_unacked -= msg_msgcnt(msg);  in tipc_sk_proto_rcv()
787 	} else if (msg_type(msg) == CONN_PROBE) {  in tipc_sk_proto_rcv()
789 			msg_set_type(msg, CONN_PROBE_REPLY);  in tipc_sk_proto_rcv()
1099 	struct tipc_msg *msg = &tsk->phdr;  in tipc_sk_finish_conn()  local
1101 	msg_set_destnode(msg, peer_node);  in tipc_sk_finish_conn()
1102 	msg_set_destport(msg, peer_port);  in tipc_sk_finish_conn()
1103 	msg_set_type(msg, TIPC_CONN_MSG);  in tipc_sk_finish_conn()
1104 	msg_set_lookup_scope(msg, 0);  in tipc_sk_finish_conn()
1105 	msg_set_hdr_sz(msg, SHORT_H_SIZE);  in tipc_sk_finish_conn()
1122 static void set_orig_addr(struct msghdr *m, struct tipc_msg *msg)  in set_orig_addr()  argument
1130 		addr->addr.id.ref = msg_origport(msg);  in set_orig_addr()
1131 		addr->addr.id.node = msg_orignode(msg);  in set_orig_addr()
1148 static int tipc_sk_anc_data_recv(struct msghdr *m, struct tipc_msg *msg,  in tipc_sk_anc_data_recv()  argument
1161 	err = msg ? msg_errcode(msg) : 0;  in tipc_sk_anc_data_recv()
1164 		anc_data[1] = msg_data_sz(msg);  in tipc_sk_anc_data_recv()
1170 				       msg_data(msg));  in tipc_sk_anc_data_recv()
1177 	dest_type = msg ? msg_type(msg) : TIPC_DIRECT_MSG;  in tipc_sk_anc_data_recv()
1181 		anc_data[0] = msg_nametype(msg);  in tipc_sk_anc_data_recv()
1182 		anc_data[1] = msg_namelower(msg);  in tipc_sk_anc_data_recv()
1183 		anc_data[2] = msg_namelower(msg);  in tipc_sk_anc_data_recv()
1187 		anc_data[0] = msg_nametype(msg);  in tipc_sk_anc_data_recv()
1188 		anc_data[1] = msg_namelower(msg);  in tipc_sk_anc_data_recv()
1189 		anc_data[2] = msg_nameupper(msg);  in tipc_sk_anc_data_recv()
1213 	struct tipc_msg *msg;  in tipc_sk_send_ack()  local
1224 	msg = buf_msg(skb);  in tipc_sk_send_ack()
1225 	msg_set_msgcnt(msg, ack);  in tipc_sk_send_ack()
1226 	tipc_link_xmit_skb(net, skb, dnode, msg_link_selector(msg));  in tipc_sk_send_ack()
1279 	struct tipc_msg *msg;  in tipc_recvmsg()  local
1306 	msg = buf_msg(buf);  in tipc_recvmsg()
1307 	sz = msg_data_sz(msg);  in tipc_recvmsg()
1308 	err = msg_errcode(msg);  in tipc_recvmsg()
1317 	set_orig_addr(m, msg);  in tipc_recvmsg()
1320 	res = tipc_sk_anc_data_recv(m, msg, tsk);  in tipc_recvmsg()
1330 		res = skb_copy_datagram_msg(buf, msg_hdr_sz(msg), m, sz);  in tipc_recvmsg()
1373 	struct tipc_msg *msg;  in tipc_recv_stream()  local
1403 	msg = buf_msg(buf);  in tipc_recv_stream()
1404 	sz = msg_data_sz(msg);  in tipc_recv_stream()
1405 	err = msg_errcode(msg);  in tipc_recv_stream()
1415 		set_orig_addr(m, msg);  in tipc_recv_stream()
1416 		res = tipc_sk_anc_data_recv(m, msg, tsk);  in tipc_recv_stream()
1429 		res = skb_copy_datagram_msg(buf, msg_hdr_sz(msg) + offset,  in tipc_recv_stream()
1519 	struct tipc_msg *msg = buf_msg(*skb);  in filter_connect()  local
1522 	if (msg_mcast(msg))  in filter_connect()
1528 		if (tsk_peer_msg(tsk, msg)) {  in filter_connect()
1529 			if (unlikely(msg_errcode(msg))) {  in filter_connect()
1542 		if (unlikely(!msg_connected(msg)))  in filter_connect()
1545 		if (unlikely(msg_errcode(msg))) {  in filter_connect()
1552 		if (unlikely(msg_importance(msg) > TIPC_CRITICAL_IMPORTANCE)) {  in filter_connect()
1559 		tipc_sk_finish_conn(tsk, msg_origport(msg), msg_orignode(msg));  in filter_connect()
1560 		msg_set_importance(&tsk->phdr, msg_importance(msg));  in filter_connect()
1568 		if (msg_data_sz(msg) == 0) {  in filter_connect()
1579 		if (!msg_connected(msg) && !(msg_errcode(msg)))  in filter_connect()
1610 	struct tipc_msg *msg = buf_msg(buf);  in rcvbuf_limit()  local
1612 	if (msg_connected(msg))  in rcvbuf_limit()
1616 		msg_importance(msg);  in rcvbuf_limit()
1635 	struct tipc_msg *msg = buf_msg(*skb);  in filter_rcv()  local
1639 	if (unlikely(msg_user(msg) == CONN_MANAGER)) {  in filter_rcv()
1644 	if (unlikely(msg_user(msg) == SOCK_WAKEUP)) {  in filter_rcv()
1653 	if (msg_type(msg) > TIPC_DIRECT_MSG)  in filter_rcv()
1657 		if (msg_connected(msg))  in filter_rcv()
1992 	struct tipc_msg *msg;  in tipc_accept()  local
2016 	msg = buf_msg(buf);  in tipc_accept()
2028 	tipc_sk_finish_conn(new_tsock, msg_origport(msg), msg_orignode(msg));  in tipc_accept()
2031 	tsk_set_importance(new_tsock, msg_importance(msg));  in tipc_accept()
2032 	if (msg_named(msg)) {  in tipc_accept()
2033 		new_tsock->conn_type = msg_nametype(msg);  in tipc_accept()
2034 		new_tsock->conn_instance = msg_nameinst(msg);  in tipc_accept()
2041 	if (!msg_data_sz(msg)) {  in tipc_accept()
2236 	struct tipc_msg *msg;  in tipc_sk_reinit()  local
2244 			msg = &tsk->phdr;  in tipc_sk_reinit()
2245 			msg_set_prevnode(msg, tn->own_addr);  in tipc_sk_reinit()
2246 			msg_set_orignode(msg, tn->own_addr);  in tipc_sk_reinit()