Home
last modified time | relevance | path

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

12

/Linux-v6.1/net/sctp/
Dulpqueue.c109 if (event->msg_flags & MSG_EOR) in sctp_ulpq_tail_data()
117 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpq_tail_data()
229 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
502 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_reassembled()
568 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_partial()
584 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
730 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()
637 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial_uo()
731 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled_uo()
744 event->msg_flags |= MSG_EOR; in sctp_intl_reasm_uo()
848 if (event->msg_flags & MSG_EOR) in sctp_ulpevent_idata()
860 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpevent_idata()
/Linux-v6.1/net/phonet/
Ddatagram.c79 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
Dpep.c1126 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1128 !(msg->msg_flags & MSG_EOR)) in pep_sendmsg()
1284 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
/Linux-v6.1/tools/testing/vsock/
Dvsock_test.c301 send_byte(fd, 1, (i == MSG_EOR_IDX) ? MSG_EOR : 0); in test_seqpacket_msg_bounds_client()
332 if ((i == MSG_EOR_IDX) ^ !!(msg.msg_flags & MSG_EOR)) { in test_seqpacket_msg_bounds_server()
/Linux-v6.1/net/sunrpc/
Dxprtsock.c421 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
444 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
460 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
498 msg->msg_flags |= MSG_EOR; in xs_read_stream_check_eor()
581 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_call()
616 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_reply()
/Linux-v6.1/tools/perf/trace/beauty/include/linux/
Dsocket.h307 #define MSG_EOR 0x80 /* End of record */ macro
/Linux-v6.1/include/linux/
Dsocket.h307 #define MSG_EOR 0x80 /* End of record */ macro
/Linux-v6.1/net/x25/
Daf_x25.c1110 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg()
1114 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg()
1350 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
/Linux-v6.1/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.1/net/vmw_vsock/
Dvirtio_transport_common.c82 if (info->msg->msg_flags & MSG_EOR) in virtio_transport_alloc_pkt()
469 msg->msg_flags |= MSG_EOR; in virtio_transport_seqpacket_do_dequeue()
/Linux-v6.1/drivers/nvme/target/
Dtcp.c634 flags |= MSG_EOR; in nvmet_try_send_response()
662 flags |= MSG_EOR; in nvmet_try_send_r2t()
692 msg.msg_flags |= MSG_EOR; in nvmet_try_send_ddgst()
/Linux-v6.1/net/rxrpc/
Drecvmsg.c626 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
/Linux-v6.1/net/kcm/
Dkcmsock.c912 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
1127 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()
/Linux-v6.1/drivers/nvme/host/
Dtcp.c990 flags |= MSG_EOR; in nvme_tcp_try_send_data()
1048 flags |= MSG_EOR; in nvme_tcp_try_send_cmd_pdu()
1123 msg.msg_flags |= MSG_EOR; in nvme_tcp_try_send_ddgst()
/Linux-v6.1/net/tipc/
Dsocket.c1943 if (flags & MSG_EOR) { in tipc_recvmsg()
1951 if (flags & MSG_EOR) in tipc_recvmsg()
1952 m->msg_flags |= MSG_EOR; in tipc_recvmsg()
1967 m->msg_flags |= MSG_EOR; in tipc_recvmsg()
/Linux-v6.1/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.1/net/
Dsocket.c1106 msg.msg_flags |= MSG_EOR; in sock_write_iter()
2616 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
2624 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
/Linux-v6.1/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.1/net/netrom/
Daf_netrom.c1043 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
/Linux-v6.1/drivers/infiniband/sw/siw/
Dsiw_qp.c390 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_send_terminate()
Dsiw_qp_tx.c437 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
/Linux-v6.1/net/tls/
Dtls_sw.c1811 msg->msg_flags |= MSG_EOR; in process_rx_list()
2078 msg->msg_flags |= MSG_EOR; in tls_sw_recvmsg()
/Linux-v6.1/net/rose/
Daf_rose.c1075 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in rose_sendmsg()

12