Home
last modified time | relevance | path

Searched refs:msg_flags (Results 1 – 25 of 90) sorted by relevance

1234

/net/sctp/
A Dstream_interleave.c140 (cevent->msg_flags & SCTP_DATA_FIRST_FRAG || in sctp_intl_store_reasm()
167 (event->msg_flags & SCTP_DATA_FIRST_FRAG || in sctp_intl_store_reasm()
249 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial()
342 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled()
355 event->msg_flags |= MSG_EOR; in sctp_intl_reasm()
525 (cevent->msg_flags & SCTP_DATA_FIRST_FRAG || in sctp_intl_store_reasm_uo()
631 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial_uo()
725 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled_uo()
738 event->msg_flags |= MSG_EOR; in sctp_intl_reasm_uo()
831 if (event->msg_flags & SCTP_DATA_FIRST_FRAG) in sctp_ulpevent_idata()
[all …]
A Dulpqueue.c106 if (event->msg_flags & MSG_EOR) in sctp_ulpq_tail_data()
114 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpq_tail_data()
221 if ((event->msg_flags & MSG_NOTIFICATION) || in sctp_ulpq_tail_event()
223 (event->msg_flags & SCTP_DATA_FRAG_MASK))) in sctp_ulpq_tail_event()
226 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
429 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_ulpq_retrieve_reassembled()
496 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_reassembled()
562 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_partial()
578 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
724 if (event->msg_flags & MSG_EOR) in sctp_ulpq_reasm_drain()
[all …]
A Dulpevent.c39 __u16 msg_flags, in sctp_ulpevent_init() argument
43 event->msg_flags = msg_flags; in sctp_ulpevent_init()
48 static struct sctp_ulpevent *sctp_ulpevent_new(int size, __u16 msg_flags, in sctp_ulpevent_new() argument
59 sctp_ulpevent_init(event, msg_flags, skb->truesize); in sctp_ulpevent_new()
70 return MSG_NOTIFICATION == (event->msg_flags & MSG_NOTIFICATION); in sctp_ulpevent_is_notification()
753 event->msg_flags |= chunk->chunk_hdr->flags; in sctp_ulpevent_make_rcvmsg()
/net/core/
A Dscm.c259 if (msg->msg_flags & MSG_CMSG_COMPAT) in put_cmsg()
263 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
267 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
358 unsigned int o_flags = (msg->msg_flags & MSG_CMSG_CLOEXEC) ? O_CLOEXEC : 0; in scm_detach_fds()
367 if (msg->msg_flags & MSG_CMSG_COMPAT) { in scm_detach_fds()
396 msg->msg_flags |= MSG_CTRUNC; in scm_detach_fds()
473 if (msg->msg_flags & MSG_CMSG_COMPAT) in scm_pidfd_recv()
479 msg->msg_flags |= MSG_CTRUNC; in scm_pidfd_recv()
507 msg->msg_flags |= MSG_CTRUNC; in __scm_recv_common()
/net/xfrm/
A Despintcp.c155 msg->msg_flags |= MSG_TRUNC; in espintcp_recvmsg()
213 .msg_flags = flags | MSG_SPLICE_PAGES | MSG_MORE, in espintcp_sendskmsg_locked()
231 msghdr.msg_flags &= ~MSG_MORE; in espintcp_sendskmsg_locked()
326 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
335 if (msg->msg_flags & ~MSG_DONTWAIT) in espintcp_sendmsg()
346 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
348 if (err != -EAGAIN || !(msg->msg_flags & MSG_DONTWAIT)) in espintcp_sendmsg()
386 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
/net/sunrpc/
A Dsocklib.c232 msg->msg_flags |= MSG_MORE; in xprt_sock_sendmsg()
239 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
258 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
270 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
A Dxprtsock.c374 *msg_flags &= ~MSG_EOR; in xs_sock_process_cmsg()
401 .msg_flags = *msg_flags, in xs_sock_recv_cmsg()
570 msg->msg_flags |= MSG_EOR; in xs_read_stream_check_eor()
604 msg->msg_flags |= MSG_TRUNC; in xs_read_stream_request()
679 msg->msg_flags |= MSG_TRUNC; in xs_read_stream_reply()
722 msg.msg_flags |= MSG_TRUNC; in xs_read_stream()
740 msg.msg_flags = 0; in xs_read_stream()
958 .msg_flags = XS_SENDMSG_FLAGS, in xs_local_send_request()
1028 .msg_flags = XS_SENDMSG_FLAGS, in xs_udp_send_request()
1114 .msg_flags = XS_SENDMSG_FLAGS, in xs_tcp_send_request()
[all …]
A Dsvcsock.c245 msg->msg_flags &= ~MSG_EOR; in svc_tcp_sock_process_cmsg()
260 svc_tcp_sock_recv_cmsg(struct socket *sock, unsigned int *msg_flags) in svc_tcp_sock_recv_cmsg() argument
272 .msg_flags = *msg_flags, in svc_tcp_sock_recv_cmsg()
296 if (msg->msg_flags & MSG_CTRUNC) { in svc_tcp_sock_recvmsg()
297 msg->msg_flags &= ~(MSG_CTRUNC | MSG_EOR); in svc_tcp_sock_recvmsg()
299 ret = svc_tcp_sock_recv_cmsg(sock, &msg->msg_flags); in svc_tcp_sock_recvmsg()
604 .msg_flags = MSG_DONTWAIT, in svc_udp_recvfrom()
727 .msg_flags = MSG_SPLICE_PAGES, in svc_udp_sendto()
1230 .msg_flags = MSG_SPLICE_PAGES, in svc_tcp_sendmsg()
/net/phonet/
A Ddatagram.c76 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
90 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
131 msg->msg_flags |= MSG_TRUNC; in pn_recvmsg()
/net/rds/
A Drecv.c639 int msg_flags) in rds_recvmsg() argument
644 int ret = 0, nonblock = msg_flags & MSG_DONTWAIT; in rds_recvmsg()
652 rdsdebug("size %zu flags 0x%x timeo %ld\n", size, msg_flags, timeo); in rds_recvmsg()
654 if (msg_flags & MSG_OOB) in rds_recvmsg()
656 if (msg_flags & MSG_ERRQUEUE) in rds_recvmsg()
706 if (!rds_still_queued(rs, inc, !(msg_flags & MSG_PEEK))) { in rds_recvmsg()
715 if (msg_flags & MSG_TRUNC) in rds_recvmsg()
717 msg->msg_flags |= MSG_TRUNC; in rds_recvmsg()
A Dtcp_send.c63 .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL, in rds_tcp_sendmsg()
116 msg.msg_flags = MSG_SPLICE_PAGES | MSG_DONTWAIT | MSG_NOSIGNAL; in rds_tcp_xmit()
118 msg.msg_flags |= MSG_MORE; in rds_tcp_xmit()
/net/
A Dcompat.c42 kmsg->msg_flags = msg->msg_flags; in __get_compat_msghdr()
236 kmsg->msg_flags |= MSG_CTRUNC; in put_cmsg_compat()
264 kmsg->msg_flags |= MSG_CTRUNC; in put_cmsg_compat()
294 unsigned int o_flags = (msg->msg_flags & MSG_CMSG_CLOEXEC) ? O_CLOEXEC : 0; in scm_detach_fds_compat()
323 msg->msg_flags |= MSG_CTRUNC; in scm_detach_fds_compat()
/net/l2tp/
A Dl2tp_ip6.c541 if (msg->msg_flags & MSG_OOB) in l2tp_ip6_sendmsg()
648 if (msg->msg_flags & MSG_CONFIRM) in l2tp_ip6_sendmsg()
657 msg->msg_flags); in l2tp_ip6_sendmsg()
660 else if (!(msg->msg_flags & MSG_MORE)) in l2tp_ip6_sendmsg()
672 if (msg->msg_flags & MSG_PROBE) in l2tp_ip6_sendmsg()
674 if (!(msg->msg_flags & MSG_PROBE) || len) in l2tp_ip6_sendmsg()
701 msg->msg_flags |= MSG_TRUNC; in l2tp_ip6_recvmsg()
/net/ipv4/
A Dtcp_bpf.c112 msghdr.msg_flags = flags | MSG_SPLICE_PAGES; in tcp_bpf_push()
115 msghdr.msg_flags |= MSG_SENDPAGE_NOPOLICY; in tcp_bpf_push()
118 msghdr.msg_flags |= MSG_MORE; in tcp_bpf_push()
504 flags = (msg->msg_flags & ~MSG_SENDPAGE_DECRYPTED); in tcp_bpf_sendmsg()
512 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in tcp_bpf_sendmsg()
577 err = sk_stream_error(sk, msg->msg_flags, err); in tcp_bpf_sendmsg()
A Draw.c509 if (msg->msg_flags & MSG_OOB) /* Mirror BSD error message */ in raw_sendmsg()
639 if (msg->msg_flags & MSG_CONFIRM) in raw_sendmsg()
645 &rt, msg->msg_flags, &ipc.sockc); in raw_sendmsg()
653 &ipc, &rt, msg->msg_flags); in raw_sendmsg()
656 else if (!(msg->msg_flags & MSG_MORE)) { in raw_sendmsg()
674 if (msg->msg_flags & MSG_PROBE) in raw_sendmsg()
676 if (!(msg->msg_flags & MSG_PROBE) || len) in raw_sendmsg()
762 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
A Dping.c667 if (msg->msg_flags & MSG_OOB) in ping_common_sendmsg()
804 if (msg->msg_flags & MSG_CONFIRM) in ping_v4_sendmsg()
824 msg->msg_flags); in ping_v4_sendmsg()
843 if (msg->msg_flags & MSG_PROBE) in ping_v4_sendmsg()
845 if (!(msg->msg_flags & MSG_PROBE) || len) in ping_v4_sendmsg()
874 msg->msg_flags |= MSG_TRUNC; in ping_recvmsg()
/net/smc/
A Dsmc_tx.c170 if ((msg->msg_flags & MSG_MORE || in smc_tx_should_cork()
210 if (msg->msg_flags & MSG_OOB) in smc_tx_sendmsg()
221 if (msg->msg_flags & MSG_OOB) in smc_tx_sendmsg()
227 rc = smc_tx_wait(smc, msg->msg_flags); in smc_tx_sendmsg()
279 if ((msg->msg_flags & MSG_OOB) && !send_remaining) in smc_tx_sendmsg()
293 rc = sk_stream_error(sk, msg->msg_flags, rc); in smc_tx_sendmsg()
/net/caif/
A Dcaif_socket.c285 m->msg_flags |= MSG_TRUNC; in caif_seqpkt_recvmsg()
530 if (msg->msg_flags&MSG_OOB) in caif_seqpkt_sendmsg()
537 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg()
597 if (unlikely(msg->msg_flags&MSG_OOB)) in caif_stream_sendmsg()
603 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg()
626 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg()
647 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg()
658 if (sent == 0 && !(msg->msg_flags&MSG_NOSIGNAL)) in caif_stream_sendmsg()
/net/ieee802154/
A Dsocket.c249 if (msg->msg_flags & MSG_OOB) { in raw_sendmsg()
250 pr_debug("msg->msg_flags = 0x%x\n", msg->msg_flags); in raw_sendmsg()
283 msg->msg_flags & MSG_DONTWAIT, &err); in raw_sendmsg()
328 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
618 if (msg->msg_flags & MSG_OOB) { in dgram_sendmsg()
619 pr_debug("msg->msg_flags = 0x%x\n", msg->msg_flags); in dgram_sendmsg()
660 msg->msg_flags & MSG_DONTWAIT, in dgram_sendmsg()
720 msg->msg_flags |= MSG_TRUNC; in dgram_recvmsg()
/net/ipv6/
A Draw.c458 msg->msg_flags |= MSG_TRUNC; in rawv6_recvmsg()
463 } else if (msg->msg_flags&MSG_TRUNC) { in rawv6_recvmsg()
767 if (msg->msg_flags & MSG_OOB) in rawv6_sendmsg()
901 if (msg->msg_flags&MSG_CONFIRM) in rawv6_sendmsg()
907 msg->msg_flags, &ipc6.sockc); in rawv6_sendmsg()
913 msg->msg_flags); in rawv6_sendmsg()
917 else if (!(msg->msg_flags & MSG_MORE)) in rawv6_sendmsg()
928 if (msg->msg_flags & MSG_PROBE) in rawv6_sendmsg()
930 if (!(msg->msg_flags & MSG_PROBE) || len) in rawv6_sendmsg()
/net/x25/
A Daf_x25.c1111 int noblock = msg->msg_flags & MSG_DONTWAIT; in x25_sendmsg()
1116 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg()
1120 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg()
1173 if ((msg->msg_flags & MSG_OOB) && len > 32) in x25_sendmsg()
1183 X25_SKB_CB(skb)->flags = msg->msg_flags; in x25_sendmsg()
1216 if (msg->msg_flags & MSG_OOB) { in x25_sendmsg()
1255 if (msg->msg_flags & MSG_OOB) in x25_sendmsg()
1325 msg->msg_flags |= MSG_OOB; in x25_recvmsg()
1352 msg->msg_flags |= MSG_TRUNC; in x25_recvmsg()
1356 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
/net/ceph/
A Dmessenger_v1.c27 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_recvmsg()
31 msg.msg_flags |= MSG_TRUNC; in ceph_tcp_recvmsg()
34 r = sock_recvmsg(sock, &msg, msg.msg_flags); in ceph_tcp_recvmsg()
44 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_recvpage()
50 r = sock_recvmsg(sock, &msg, msg.msg_flags); in ceph_tcp_recvpage()
63 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_sendmsg()
67 msg.msg_flags |= MSG_MORE; in ceph_tcp_sendmsg()
69 msg.msg_flags |= MSG_EOR; /* superfluous, but what the hell */ in ceph_tcp_sendmsg()
84 .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL | more, in ceph_tcp_sendpage()
98 msg.msg_flags |= MSG_SPLICE_PAGES; in ceph_tcp_sendpage()
/net/rxrpc/
A Dsendmsg.c330 bool more = msg->msg_flags & MSG_MORE; in rxrpc_send_data()
340 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
479 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data()
484 msg->msg_flags & MSG_WAITALL); in rxrpc_send_data()
524 if (msg->msg_flags & MSG_CMSG_COMPAT) { in rxrpc_sendmsg_cmsg()
A Doutput.c265 msg.msg_flags = MSG_SPLICE_PAGES; in rxrpc_send_ack_packet()
392 msg.msg_flags = 0; in rxrpc_send_abort_packet()
673 msg.msg_flags = MSG_SPLICE_PAGES; in rxrpc_send_data_packet()
764 msg.msg_flags = 0; in rxrpc_send_conn_abort()
830 msg.msg_flags = 0; in rxrpc_reject_packet()
890 msg.msg_flags = 0; in rxrpc_send_keepalive()
958 msg.msg_flags = MSG_SPLICE_PAGES; in rxrpc_send_response()
/net/kcm/
A Dkcmsock.c608 .msg_flags = MSG_DONTWAIT | MSG_SPLICE_PAGES, in kcm_write_msgs()
754 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in kcm_sendmsg()
756 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
834 if (msg->msg_flags & MSG_SPLICE_PAGES) { in kcm_sendmsg()
904 if (msg->msg_flags & MSG_BATCH) { in kcm_sendmsg()
949 err = sk_stream_error(sk, msg->msg_flags, err); in kcm_sendmsg()
1004 msg->msg_flags |= MSG_TRUNC; in kcm_recvmsg()
1012 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()

Completed in 62 milliseconds

1234