/openbmc/linux/net/sctp/ |
H A D | ulpqueue.c | 106 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() 226 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event() 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()
|
H A D | stream_interleave.c | 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() 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() 842 if (event->msg_flags & MSG_EOR) in sctp_ulpevent_idata() 854 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpevent_idata()
|
/openbmc/linux/net/phonet/ |
H A D | datagram.c | 76 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
|
H A D | pep.c | 1148 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg() 1150 !(msg->msg_flags & MSG_EOR)) in pep_sendmsg() 1306 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
|
/openbmc/linux/net/vmw_vsock/ |
H A D | virtio_transport_common.c | 84 if (info->msg->msg_flags & MSG_EOR) in virtio_transport_alloc_skb() 518 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_peek() 591 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_dequeue()
|
/openbmc/linux/tools/perf/trace/beauty/include/linux/ |
H A D | socket.h | 311 #define MSG_EOR 0x80 /* End of record */ macro
|
/openbmc/linux/include/linux/ |
H A D | socket.h | 311 #define MSG_EOR 0x80 /* End of record */ macro
|
/openbmc/linux/net/sunrpc/ |
H A D | xprtsock.c | 374 msg->msg_flags &= ~MSG_EOR; in xs_sock_process_cmsg() 473 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf() 496 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf() 512 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf() 550 msg->msg_flags |= MSG_EOR; in xs_read_stream_check_eor() 633 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_call() 668 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_reply()
|
/openbmc/linux/net/tls/ |
H A D | tls_device.c | 444 MSG_SPLICE_PAGES | MSG_EOR)) in tls_push_data() 447 if ((flags & (MSG_MORE | MSG_EOR)) == (MSG_MORE | MSG_EOR)) in tls_push_data()
|
H A D | tls_sw.c | 1028 if (!eor && (msg->msg_flags & MSG_EOR)) in tls_sw_sendmsg_locked() 1232 MSG_CMSG_COMPAT | MSG_SPLICE_PAGES | MSG_EOR | in tls_sw_sendmsg() 1848 msg->msg_flags |= MSG_EOR; in process_rx_list() 2134 msg->msg_flags |= MSG_EOR; in tls_sw_recvmsg()
|
/openbmc/linux/tools/testing/vsock/ |
H A D | vsock_test.c | 442 flags = MSG_EOR; in test_seqpacket_msg_bounds_client() 536 if (msg.msg_flags & MSG_EOR) in test_seqpacket_msg_bounds_server()
|
/openbmc/linux/tools/testing/selftests/bpf/prog_tests/ |
H A D | sock_fields.c | 314 err = send(accept_fd, DATA, DATA_LEN, MSG_EOR); in test()
|
H A D | tcp_hdr_options.c | 483 MSG_EOR); in misc()
|
/openbmc/linux/net/x25/ |
H A D | af_x25.c | 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() 1356 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
|
/openbmc/linux/net/rxrpc/ |
H A D | recvmsg.c | 430 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
|
/openbmc/linux/drivers/nvme/target/ |
H A D | tcp.c | 672 msg.msg_flags |= MSG_EOR; in nvmet_try_send_response() 702 msg.msg_flags |= MSG_EOR; in nvmet_try_send_r2t() 733 msg.msg_flags |= MSG_EOR; in nvmet_try_send_ddgst()
|
/openbmc/linux/net/kcm/ |
H A D | kcmsock.c | 754 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg() 1011 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()
|
/openbmc/linux/drivers/nvme/host/ |
H A D | tcp.c | 1012 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_data() 1070 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_cmd_pdu() 1146 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_ddgst()
|
/openbmc/linux/net/tipc/ |
H A D | socket.c | 1944 if (flags & MSG_EOR) { in tipc_recvmsg() 1952 if (flags & MSG_EOR) in tipc_recvmsg() 1953 m->msg_flags |= MSG_EOR; in tipc_recvmsg() 1968 m->msg_flags |= MSG_EOR; in tipc_recvmsg()
|
/openbmc/linux/Documentation/networking/ |
H A D | rxrpc.rst | 244 (#) When receiving data or messages for a call, MSG_EOR is flagged by recvmsg 617 for a particular call to be read. MSG_EOR will be set on the terminal 625 buffer instead, and MSG_EOR will be flagged to indicate the end of that 752 MSG_EOR will be flagged to indicate that this is the final message for
|
/openbmc/linux/net/ |
H A D | socket.c | 1158 msg.msg_flags |= MSG_EOR; in sock_write_iter() 2724 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg() 2732 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
|
/openbmc/linux/net/iucv/ |
H A D | af_iucv.c | 923 if (sk->sk_type == SOCK_SEQPACKET && !(msg->msg_flags & MSG_EOR)) in iucv_sock_sendmsg() 1267 msg->msg_flags |= MSG_EOR; in iucv_sock_recvmsg()
|
/openbmc/linux/net/netrom/ |
H A D | af_netrom.c | 1053 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
|
/openbmc/linux/drivers/infiniband/sw/siw/ |
H A D | siw_qp_tx.c | 442 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
|
H A D | siw_qp.c | 393 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_send_terminate()
|