Home
last modified time | relevance | path

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

12

/Linux-v5.4/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()
503 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_reassembled()
569 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_partial()
585 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
731 if (event->msg_flags & MSG_EOR) in sctp_ulpq_reasm_drain()
Dstream_interleave.c250 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial()
344 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled()
357 event->msg_flags |= MSG_EOR; in sctp_intl_reasm()
639 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial_uo()
734 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled_uo()
747 event->msg_flags |= MSG_EOR; in sctp_intl_reasm_uo()
851 if (event->msg_flags & MSG_EOR) in sctp_ulpevent_idata()
863 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpevent_idata()
Dsocket.c2147 msg->msg_flags &= ~MSG_EOR; in sctp_recvmsg()
2161 (event->msg_flags & MSG_EOR)) in sctp_recvmsg()
2162 msg->msg_flags |= MSG_EOR; in sctp_recvmsg()
2164 msg->msg_flags &= ~MSG_EOR; in sctp_recvmsg()
/Linux-v5.4/net/phonet/
Ddatagram.c79 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
Dpep.c1122 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1124 !(msg->msg_flags & MSG_EOR)) in pep_sendmsg()
1280 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
/Linux-v5.4/net/decnet/
Daf_decnet.c1803 msg->msg_flags |= MSG_EOR; in dn_recvmsg()
1923 if (flags & ~(MSG_TRYHARD|MSG_OOB|MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL|MSG_MORE|MSG_CMSG_COMPAT)) in dn_sendmsg()
1937 if (flags & MSG_EOR) { in dn_sendmsg()
1941 flags |= MSG_EOR; in dn_sendmsg()
2048 if (((sent + len) == size) && (flags & MSG_EOR)) { in dn_sendmsg()
/Linux-v5.4/include/linux/
Dsocket.h280 #define MSG_EOR 0x80 /* End of record */ macro
/Linux-v5.4/net/sunrpc/
Dxprtsock.c414 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
436 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
452 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
490 msg->msg_flags |= MSG_EOR; in xs_read_stream_check_eor()
569 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_call()
604 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_reply()
/Linux-v5.4/net/x25/
Daf_x25.c1100 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg()
1104 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg()
1341 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
/Linux-v5.4/net/rxrpc/
Drecvmsg.c583 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
/Linux-v5.4/drivers/nvme/host/
Dtcp.c860 flags |= MSG_EOR; in nvme_tcp_try_send_data()
901 int flags = MSG_DONTWAIT | (inline_data ? MSG_MORE : MSG_EOR); in nvme_tcp_try_send_cmd_pdu()
966 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in nvme_tcp_try_send_ddgst()
/Linux-v5.4/net/kcm/
Dkcmsock.c908 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
1159 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()
/Linux-v5.4/drivers/nvme/target/
Dtcp.c574 flags |= MSG_EOR; in nvmet_try_send_response()
603 flags |= MSG_EOR; in nvmet_try_send_r2t()
/Linux-v5.4/Documentation/networking/
Drxrpc.txt245 (*) When receiving data or messages for a call, MSG_EOR is flagged by recvmsg
615 for a particular call to be read. MSG_EOR will be set on the terminal
623 buffer instead, and MSG_EOR will be flagged to indicate the end of that
742 MSG_EOR will be flagged to indicate that this is the final message for
/Linux-v5.4/net/
Dsocket.c987 msg.msg_flags |= MSG_EOR; in sock_write_iter()
2407 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
2415 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
/Linux-v5.4/net/iucv/
Daf_iucv.c1085 if (sk->sk_type == SOCK_SEQPACKET && !(msg->msg_flags & MSG_EOR)) in iucv_sock_sendmsg()
1426 msg->msg_flags |= MSG_EOR; in iucv_sock_recvmsg()
/Linux-v5.4/drivers/infiniband/sw/siw/
Dsiw_qp_tx.c430 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_tx_hdt()
Dsiw_qp.c389 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_EOR }; in siw_send_terminate()
/Linux-v5.4/net/tls/
Dtls_sw.c1658 msg->msg_flags |= MSG_EOR; in process_rx_list()
1848 msg->msg_flags |= MSG_EOR; in tls_sw_recvmsg()
/Linux-v5.4/net/netrom/
Daf_netrom.c1021 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
/Linux-v5.4/drivers/xen/
Dpvcalls-front.c539 if (flags & (MSG_CONFIRM|MSG_DONTROUTE|MSG_EOR|MSG_OOB)) in pvcalls_front_sendmsg()
/Linux-v5.4/net/rose/
Daf_rose.c1039 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in rose_sendmsg()
/Linux-v5.4/net/ax25/
Daf_ax25.c1455 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in ax25_sendmsg()
/Linux-v5.4/net/ipv4/
Dtcp.c1373 if (unlikely(flags & MSG_EOR)) in tcp_sendmsg_locked()
/Linux-v5.4/net/ceph/
Dmessenger.c558 msg.msg_flags |= MSG_EOR; /* superfluous, but what the hell */ in ceph_tcp_sendmsg()

12