Cross Reference: /net/tipc/socket.c

Lines Matching refs:msg
755  * @msg: peer's response message
759 static int auto_connect(struct socket *sock, struct tipc_msg *msg)
764 	tsock->peer_name.ref = msg_origport(msg);
765 	tsock->peer_name.node = msg_orignode(msg);
772 	if (msg_importance(msg) > TIPC_CRITICAL_IMPORTANCE)
774 	msg_set_importance(&p_ptr->phdr, (u32)msg_importance(msg));
782  * @msg: received message header
786 static void set_orig_addr(struct msghdr *m, struct tipc_msg *msg)
794 		addr->addr.id.ref = msg_origport(msg);
795 		addr->addr.id.node = msg_orignode(msg);
805  * @msg: received message header
812 static int anc_data_recv(struct msghdr *m, struct tipc_msg *msg,
825 	err = msg ? msg_errcode(msg) : 0;
828 		anc_data[1] = msg_data_sz(msg);
834 				       msg_data(msg));
841 	dest_type = msg ? msg_type(msg) : TIPC_DIRECT_MSG;
845 		anc_data[0] = msg_nametype(msg);
846 		anc_data[1] = msg_namelower(msg);
847 		anc_data[2] = msg_namelower(msg);
851 		anc_data[0] = msg_nametype(msg);
852 		anc_data[1] = msg_namelower(msg);
853 		anc_data[2] = msg_nameupper(msg);
891 	struct tipc_msg *msg;
933 	msg = buf_msg(buf);
934 	sz = msg_data_sz(msg);
935 	err = msg_errcode(msg);
944 	set_orig_addr(m, msg);
947 	res = anc_data_recv(m, msg, tport);
957 		res = skb_copy_datagram_iovec(buf, msg_hdr_sz(msg),
1000 	struct tipc_msg *msg;
1046 	msg = buf_msg(buf);
1047 	sz = msg_data_sz(msg);
1048 	err = msg_errcode(msg);
1056 	/* Optionally capture sender's address & ancillary data of first msg */
1058 		set_orig_addr(m, msg);
1059 		res = anc_data_recv(m, msg, tport);
1072 		res = skb_copy_datagram_iovec(buf, msg_hdr_sz(msg) + offset,
1087 			goto exit; /* can't add error msg to valid data */
1151  * @msg: message
1159 	struct tipc_msg *msg = buf_msg(*buf);
1164 	if (msg_mcast(msg))
1170 		if (msg_connected(msg) && tipc_port_peer_msg(tsock->p, msg)) {
1171 			if (unlikely(msg_errcode(msg))) {
1180 		if (unlikely(msg_errcode(msg))) {
1187 		if (unlikely(!msg_connected(msg)))
1190 		res = auto_connect(sock, msg);
1203 		if (msg_data_sz(msg) == 0) {
1214 		if (!msg_connected(msg) && !(msg_errcode(msg)))
1245 	struct tipc_msg *msg = buf_msg(buf);
1248 	if (msg_connected(msg))
1251 		limit = sk->sk_rcvbuf << (msg_importance(msg) + 5);
1270 	struct tipc_msg *msg = buf_msg(buf);
1275 	if (msg_type(msg) > TIPC_DIRECT_MSG)
1279 		if (msg_connected(msg))
1507 	struct tipc_msg *msg;
1542 	msg = buf_msg(buf);
1554 	new_tsock->peer_name.ref = msg_origport(msg);
1555 	new_tsock->peer_name.node = msg_orignode(msg);
1559 	tipc_set_portimportance(new_ref, msg_importance(msg));
1560 	if (msg_named(msg)) {
1561 		new_tport->conn_type = msg_nametype(msg);
1562 		new_tport->conn_instance = msg_nameinst(msg);
1569 	if (!msg_data_sz(msg)) {