Lines Matching defs:msg
289 struct msghdr *msg, size_t len,
298 bool more = msg->msg_flags & MSG_MORE;
301 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT);
350 if (chunk > msg_data_left(msg) && !more)
351 chunk = msg_data_left(msg);
362 sk, size, msg->msg_flags & MSG_DONTWAIT, &ret);
395 if (msg_data_left(msg) > 0) {
398 if (copy > msg_data_left(msg))
399 copy = msg_data_left(msg);
404 ret = skb_add_data(skb, &msg->msg_iter, copy);
422 (msg_data_left(msg) == 0 && !more)) {
443 if (msg_data_left(msg) == 0 && !more)
455 !msg_data_left(msg) && !more,
460 } while (msg_data_left(msg) > 0);
491 if (msg->msg_flags & MSG_DONTWAIT)
496 msg->msg_flags & MSG_WAITALL);
514 static int rxrpc_sendmsg_cmsg(struct msghdr *msg, struct rxrpc_send_params *p)
520 if (msg->msg_controllen == 0)
523 for_each_cmsghdr(cmsg, msg) {
524 if (!CMSG_OK(msg, cmsg))
536 if (msg->msg_flags & MSG_CMSG_COMPAT) {
620 rxrpc_new_client_call_for_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg,
629 DECLARE_SOCKADDR(struct sockaddr_rxrpc *, srx, msg->msg_name);
633 if (!msg->msg_name) {
663 int rxrpc_do_sendmsg(struct rxrpc_sock *rx, struct msghdr *msg, size_t len)
686 ret = rxrpc_sendmsg_cmsg(msg, &p);
703 call = rxrpc_new_client_call_for_sendmsg(rx, msg, &p);
780 ret = rxrpc_send_data(rx, call, msg, len, NULL, &dropped_lock);
800 * @msg: The data to send
805 * appropriate to sending data. No control data should be supplied in @msg,
810 struct msghdr *msg, size_t len,
818 ASSERTCMP(msg->msg_name, ==, NULL);
819 ASSERTCMP(msg->msg_control, ==, NULL);
830 ret = rxrpc_send_data(rxrpc_sk(sock->sk), call, msg, len,