Home
last modified time | relevance | path

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

12

/Linux-v6.6/net/sctp/
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()
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-v6.6/net/phonet/
Ddatagram.c76 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
Dpep.c1125 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1127 !(msg->msg_flags & MSG_EOR)) in pep_sendmsg()
1283 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
/Linux-v6.6/net/vmw_vsock/
Dvirtio_transport_common.c82 if (info->msg->msg_flags & MSG_EOR) in virtio_transport_alloc_skb()
509 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_peek()
582 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_dequeue()
/Linux-v6.6/include/linux/
Dsocket.h311 #define MSG_EOR 0x80 /* End of record */ macro
/Linux-v6.6/tools/perf/trace/beauty/include/linux/
Dsocket.h311 #define MSG_EOR 0x80 /* End of record */ macro
/Linux-v6.6/net/sunrpc/
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-v6.6/net/tls/
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()
Dtls_sw.c987 if (!eor && (msg->msg_flags & MSG_EOR)) in tls_sw_sendmsg_locked()
1199 MSG_CMSG_COMPAT | MSG_SPLICE_PAGES | MSG_EOR | in tls_sw_sendmsg()
1820 msg->msg_flags |= MSG_EOR; in process_rx_list()
2096 msg->msg_flags |= MSG_EOR; in tls_sw_recvmsg()
/Linux-v6.6/tools/testing/vsock/
Dvsock_test.c440 flags = MSG_EOR; in test_seqpacket_msg_bounds_client()
530 if (msg.msg_flags & MSG_EOR) in test_seqpacket_msg_bounds_server()
/Linux-v6.6/net/x25/
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-v6.6/tools/testing/selftests/bpf/prog_tests/
Dsock_fields.c314 err = send(accept_fd, DATA, DATA_LEN, MSG_EOR); in test()
Dtcp_hdr_options.c483 MSG_EOR); in misc()
/Linux-v6.6/net/rxrpc/
Drecvmsg.c430 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
/Linux-v6.6/drivers/nvme/target/
Dtcp.c670 msg.msg_flags |= MSG_EOR; in nvmet_try_send_response()
700 msg.msg_flags |= MSG_EOR; in nvmet_try_send_r2t()
731 msg.msg_flags |= MSG_EOR; in nvmet_try_send_ddgst()
/Linux-v6.6/net/kcm/
Dkcmsock.c754 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
1008 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()
/Linux-v6.6/drivers/nvme/host/
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()
/Linux-v6.6/net/tipc/
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()
/Linux-v6.6/Documentation/networking/
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-v6.6/net/
Dsocket.c1156 msg.msg_flags |= MSG_EOR; in sock_write_iter()
2692 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
2700 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
/Linux-v6.6/net/iucv/
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()
/Linux-v6.6/net/netrom/
Daf_netrom.c1053 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
/Linux-v6.6/drivers/infiniband/sw/siw/
Dsiw_qp_tx.c442 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
Dsiw_qp.c393 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_send_terminate()

12