Home
last modified time | relevance | path

Searched refs:MSG_EOR (Results 1 – 25 of 34) sorted by relevance

12

/openbmc/linux/net/sctp/
H 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()
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 Dstream_interleave.c249 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 Ddatagram.c76 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
H A Dpep.c1148 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 Dvirtio_transport_common.c84 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 Dsocket.h311 #define MSG_EOR 0x80 /* End of record */ macro
/openbmc/linux/include/linux/
H A Dsocket.h311 #define MSG_EOR 0x80 /* End of record */ macro
/openbmc/linux/net/sunrpc/
H A Dxprtsock.c374 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 Dtls_device.c444 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 Dtls_sw.c1028 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 Dvsock_test.c442 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 Dsock_fields.c314 err = send(accept_fd, DATA, DATA_LEN, MSG_EOR); in test()
H A Dtcp_hdr_options.c483 MSG_EOR); in misc()
/openbmc/linux/net/x25/
H A Daf_x25.c1116 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 Drecvmsg.c430 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
/openbmc/linux/drivers/nvme/target/
H A Dtcp.c672 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 Dkcmsock.c754 !(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 Dtcp.c1012 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 Dsocket.c1944 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 Drxrpc.rst244 (#) 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 Dsocket.c1158 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 Daf_iucv.c923 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 Daf_netrom.c1053 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
/openbmc/linux/drivers/infiniband/sw/siw/
H A Dsiw_qp_tx.c442 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
H A Dsiw_qp.c393 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_send_terminate()

12