Lines Matching defs:msg

78  * @maxnagle: maximum size of msg which can be subject to nagle
334 static bool tsk_peer_msg(struct tipc_sock *tsk, struct tipc_msg *msg)
344 	if (unlikely(msg_origport(msg) != peer_port))
347 	orig_node = msg_orignode(msg);
464 	struct tipc_msg *msg;
496 	msg = &tsk->phdr;
511 	tipc_msg_init(tipc_own_addr(net), msg, TIPC_LOW_IMPORTANCE,
514 	msg_set_origport(msg, tsk->portid);
834  * @msg: message to send
842 			  struct msghdr *msg, size_t dlen, long timeout)
879 	rc = tipc_msg_build(hdr, msg, 0, dlen, mtu, &pkts);
1347 		 * - convert msg to abort msg and add to inqueue
1373 		pr_warn("Received unknown CONN_PROTO msg\n");
1662 	struct tipc_msg *msg = &tsk->phdr;
1664 	msg_set_syn(msg, 0);
1665 	msg_set_destnode(msg, peer_node);
1666 	msg_set_destport(msg, peer_port);
1667 	msg_set_type(msg, TIPC_CONN_MSG);
1668 	msg_set_lookup_scope(msg, 0);
1669 	msg_set_hdr_sz(msg, SHORT_H_SIZE);
1793 	struct tipc_msg *msg;
1804 	msg = buf_msg(skb);
1805 	msg_set_conn_ack(msg, tsk->rcv_unacked);
1811 		msg_set_adv_win(msg, tsk->rcv_win);
1906 	/* Step rcv queue to first msg with data or error; wait if necessary */
1923 	/* Collect msg meta data, including error code and rejected data */
1930 	/* Capture data if non-error msg, otherwise just set return value */
2037 		/* Look at first msg in receive queue; wait if necessary */
2054 		/* Collect msg meta data, incl. error code and rejected data */
2063 		/* Copy data if msg ok, otherwise return error/partial data */
2720 	struct tipc_msg *msg;
2745 	msg = buf_msg(buf);
2757 	tipc_sk_finish_conn(new_tsock, msg_origport(msg), msg_orignode(msg));
2759 	tsk_set_importance(new_sk, msg_importance(msg));
2760 	if (msg_named(msg)) {
2762 		msg_set_nametype(&new_tsock->phdr, msg_nametype(msg));
2763 		msg_set_nameinst(&new_tsock->phdr, msg_nameinst(msg));
2770 	if (!msg_data_sz(msg)) {
2967 	struct tipc_msg *msg;
2978 			msg = &tsk->phdr;
2979 			msg_set_prevnode(msg, tipc_own_addr(net));
2980 			msg_set_orignode(msg, tipc_own_addr(net));
3894  * @skb: tipc msg to be checked
3912  * @skb: tipc msg to be checked