28 			   struct msghdr *msg, size_t len);
33 static int rxrpc_sendmsg_cmsg(struct rxrpc_sock *rx, struct msghdr *msg,  in rxrpc_sendmsg_cmsg()  argument
44 	if (msg->msg_controllen == 0)  in rxrpc_sendmsg_cmsg()
47 	for_each_cmsghdr(cmsg, msg) {  in rxrpc_sendmsg_cmsg()
48 		if (!CMSG_OK(msg, cmsg))  in rxrpc_sendmsg_cmsg()
60 			if (msg->msg_flags & MSG_CMSG_COMPAT) {  in rxrpc_sendmsg_cmsg()
132 			 struct msghdr *msg, size_t len)  in rxrpc_client_sendmsg()  argument
147 	ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code,  in rxrpc_client_sendmsg()
155 		if (msg->msg_name) {  in rxrpc_client_sendmsg()
157 					 msg->msg_name);  in rxrpc_client_sendmsg()
192 		ret = rxrpc_send_data(rx, call, msg, len);  in rxrpc_client_sendmsg()
211 int rxrpc_kernel_send_data(struct rxrpc_call *call, struct msghdr *msg,  in rxrpc_kernel_send_data()  argument
218 	ASSERTCMP(msg->msg_name, ==, NULL);  in rxrpc_kernel_send_data()
219 	ASSERTCMP(msg->msg_control, ==, NULL);  in rxrpc_kernel_send_data()
233 		ret = rxrpc_send_data(call->socket, call, msg, len);  in rxrpc_kernel_send_data()
272 int rxrpc_server_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, size_t len)  in rxrpc_server_sendmsg()  argument
282 	ret = rxrpc_sendmsg_cmsg(rx, msg, &user_call_ID, &cmd, &abort_code,  in rxrpc_server_sendmsg()
313 		ret = rxrpc_send_data(rx, call, msg, len);  in rxrpc_server_sendmsg()
335 	struct msghdr msg;  in rxrpc_send_packet()  local
343 	msg.msg_name = &trans->peer->srx.transport.sin;  in rxrpc_send_packet()
344 	msg.msg_namelen = sizeof(trans->peer->srx.transport.sin);  in rxrpc_send_packet()
345 	msg.msg_control = NULL;  in rxrpc_send_packet()
346 	msg.msg_controllen = 0;  in rxrpc_send_packet()
347 	msg.msg_flags = 0;  in rxrpc_send_packet()
359 		ret = kernel_sendmsg(trans->local->socket, &msg, iov, 1,  in rxrpc_send_packet()
379 		ret = kernel_sendmsg(trans->local->socket, &msg, iov, 1,  in rxrpc_send_packet()
522 			   struct msghdr *msg, size_t len)  in rxrpc_send_data()  argument
531 	timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);  in rxrpc_send_data()
539 	more = msg->msg_flags & MSG_MORE;  in rxrpc_send_data()
554 				if (msg->msg_flags & MSG_DONTWAIT)  in rxrpc_send_data()
567 			if (chunk > msg_data_left(msg) && !more)  in rxrpc_send_data()
568 				chunk = msg_data_left(msg);  in rxrpc_send_data()
579 				sk, size, msg->msg_flags & MSG_DONTWAIT, &ret);  in rxrpc_send_data()
611 		if (msg_data_left(msg) > 0) {  in rxrpc_send_data()
614 			if (copy > msg_data_left(msg))  in rxrpc_send_data()
615 				copy = msg_data_left(msg);  in rxrpc_send_data()
620 			ret = skb_add_data(skb, &msg->msg_iter, copy);  in rxrpc_send_data()
636 		    (msg_data_left(msg) == 0 && !more)) {  in rxrpc_send_data()
666 			if (msg_data_left(msg) == 0 && !more)  in rxrpc_send_data()
682 			rxrpc_queue_packet(call, skb, !msg_data_left(msg) && !more);  in rxrpc_send_data()
685 	} while (msg_data_left(msg) > 0);  in rxrpc_send_data()