Lines Matching refs:msg

279 			   struct msghdr *msg, size_t len,  in rxrpc_send_data()  argument
287 bool more = msg->msg_flags & MSG_MORE; in rxrpc_send_data()
290 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
350 remain = more ? INT_MAX : msg_data_left(msg); in rxrpc_send_data()
373 if (msg_data_left(msg) > 0) { in rxrpc_send_data()
374 size_t copy = min_t(size_t, txb->space, msg_data_left(msg)); in rxrpc_send_data()
378 &msg->msg_iter)) in rxrpc_send_data()
396 (msg_data_left(msg) == 0 && !more)) { in rxrpc_send_data()
397 if (msg_data_left(msg) == 0 && !more) { in rxrpc_send_data()
412 } while (msg_data_left(msg) > 0); in rxrpc_send_data()
440 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data()
445 msg->msg_flags & MSG_WAITALL); in rxrpc_send_data()
463 static int rxrpc_sendmsg_cmsg(struct msghdr *msg, struct rxrpc_send_params *p) in rxrpc_sendmsg_cmsg() argument
469 if (msg->msg_controllen == 0) in rxrpc_sendmsg_cmsg()
472 for_each_cmsghdr(cmsg, msg) { in rxrpc_sendmsg_cmsg()
473 if (!CMSG_OK(msg, cmsg)) in rxrpc_sendmsg_cmsg()
485 if (msg->msg_flags & MSG_CMSG_COMPAT) { in rxrpc_sendmsg_cmsg()
569 rxrpc_new_client_call_for_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, in rxrpc_new_client_call_for_sendmsg() argument
578 DECLARE_SOCKADDR(struct sockaddr_rxrpc *, srx, msg->msg_name); in rxrpc_new_client_call_for_sendmsg()
582 if (!msg->msg_name) { in rxrpc_new_client_call_for_sendmsg()
611 int rxrpc_do_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, size_t len) in rxrpc_do_sendmsg() argument
632 ret = rxrpc_sendmsg_cmsg(msg, &p); in rxrpc_do_sendmsg()
649 call = rxrpc_new_client_call_for_sendmsg(rx, msg, &p); in rxrpc_do_sendmsg()
726 ret = rxrpc_send_data(rx, call, msg, len, NULL, &dropped_lock); in rxrpc_do_sendmsg()
756 struct msghdr *msg, size_t len, in rxrpc_kernel_send_data() argument
764 ASSERTCMP(msg->msg_name, ==, NULL); in rxrpc_kernel_send_data()
765 ASSERTCMP(msg->msg_control, ==, NULL); in rxrpc_kernel_send_data()
769 ret = rxrpc_send_data(rxrpc_sk(sock->sk), call, msg, len, in rxrpc_kernel_send_data()