Home
last modified time | relevance | path

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

12

/linux-6.15/tools/testing/selftests/net/packetdrill/
H A Dtcp_eor_no-coalesce-subsequent.pkt25 +0 send(4, ..., 400, MSG_EOR) = 400
26 +0 send(4, ..., 400, MSG_EOR) = 400
27 +0 send(4, ..., 400, MSG_EOR) = 400
28 +0 send(4, ..., 400, MSG_EOR) = 400
29 +0 send(4, ..., 400, MSG_EOR) = 400
30 +0 send(4, ..., 400, MSG_EOR) = 400
31 +0 send(4, ..., 400, MSG_EOR) = 400
32 +0 send(4, ..., 400, MSG_EOR) = 400
33 +0 send(4, ..., 400, MSG_EOR) = 400
34 +0 send(4, ..., 400, MSG_EOR) = 400
H A Dtcp_eor_no-coalesce-retrans.pkt25 +0 send(4, ..., 400, MSG_EOR) = 400
26 +0 send(4, ..., 400, MSG_EOR) = 400
27 +0 send(4, ..., 400, MSG_EOR) = 400
28 +0 send(4, ..., 400, MSG_EOR) = 400
29 +0 send(4, ..., 400, MSG_EOR) = 400
30 +0 send(4, ..., 400, MSG_EOR) = 400
31 +0 send(4, ..., 400, MSG_EOR) = 400
32 +0 send(4, ..., 400, MSG_EOR) = 400
33 +0 send(4, ..., 400, MSG_EOR) = 400
34 +0 send(4, ..., 400, MSG_EOR) = 400
H A Dtcp_eor_no-coalesce-small.pkt24 +0 send(4, ..., 400, MSG_EOR) = 400
H A Dtcp_eor_no-coalesce-large.pkt25 +0 send(4, ..., 10400, MSG_EOR) = 10400
/linux-6.15/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()
/linux-6.15/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()
/linux-6.15/net/tls/
H A Dtls_device.c438 MSG_SPLICE_PAGES | MSG_EOR)) in tls_push_data()
441 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()
1882 msg->msg_flags |= MSG_EOR; in process_rx_list()
2168 msg->msg_flags |= MSG_EOR; in tls_sw_recvmsg()
/linux-6.15/tools/perf/trace/beauty/include/linux/
H A Dsocket.h312 #define MSG_EOR 0x80 /* End of record */ macro
/linux-6.15/include/linux/
H A Dsocket.h312 #define MSG_EOR 0x80 /* End of record */ macro
/linux-6.15/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()
/linux-6.15/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()
/linux-6.15/net/vmw_vsock/
H A Dvirtio_transport_common.c301 if (info->msg->msg_flags & MSG_EOR) in virtio_transport_alloc_skb()
706 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_peek()
781 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_dequeue()
/linux-6.15/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()
/linux-6.15/net/rxrpc/
H A Drecvmsg.c430 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
/linux-6.15/tools/testing/vsock/
H A Dvsock_test.c394 flags = MSG_EOR; in test_seqpacket_msg_bounds_client()
474 if (msg.msg_flags & MSG_EOR) in test_seqpacket_msg_bounds_server()
/linux-6.15/drivers/nvme/target/
H A Dtcp.c701 msg.msg_flags |= MSG_EOR; in nvmet_try_send_response()
731 msg.msg_flags |= MSG_EOR; in nvmet_try_send_r2t()
762 msg.msg_flags |= MSG_EOR; in nvmet_try_send_ddgst()
/linux-6.15/net/kcm/
H A Dkcmsock.c755 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
1012 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()
/linux-6.15/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
/linux-6.15/net/tipc/
H A Dsocket.c1939 if (flags & MSG_EOR) { in tipc_recvmsg()
1947 if (flags & MSG_EOR) in tipc_recvmsg()
1948 m->msg_flags |= MSG_EOR; in tipc_recvmsg()
1963 m->msg_flags |= MSG_EOR; in tipc_recvmsg()
/linux-6.15/drivers/nvme/host/
H A Dtcp.c1136 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_data()
1194 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_cmd_pdu()
1270 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_ddgst()
/linux-6.15/net/
H A Dsocket.c1129 msg.msg_flags |= MSG_EOR; in sock_write_iter()
2703 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
2711 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()

12