Home
last modified time | relevance | path

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

/Linux-v4.19/net/sctp/
Dulpqueue.c119 if ((event) && (event->msg_flags & MSG_EOR)) { in sctp_ulpq_tail_data()
131 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpq_tail_data()
244 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
524 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_reassembled()
590 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_partial()
606 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
748 if ((event) && (event->msg_flags & MSG_EOR)) { in sctp_ulpq_reasm_drain()
Dstream_interleave.c258 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial()
352 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled()
365 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()
847 if (event && event->msg_flags & MSG_EOR) { in sctp_ulpevent_idata()
858 event_eor = (event->msg_flags & MSG_EOR) ? 1 : 0; in sctp_ulpevent_idata()
Dsocket.c2261 msg->msg_flags &= ~MSG_EOR; in sctp_recvmsg()
2275 (event->msg_flags & MSG_EOR)) in sctp_recvmsg()
2276 msg->msg_flags |= MSG_EOR; in sctp_recvmsg()
2278 msg->msg_flags &= ~MSG_EOR; in sctp_recvmsg()
/Linux-v4.19/net/phonet/
Ddatagram.c92 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
Dpep.c1135 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1137 !(msg->msg_flags & MSG_EOR)) in pep_sendmsg()
1293 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
/Linux-v4.19/net/decnet/
Daf_decnet.c1811 msg->msg_flags |= MSG_EOR; in dn_recvmsg()
1931 if (flags & ~(MSG_TRYHARD|MSG_OOB|MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL|MSG_MORE|MSG_CMSG_COMPAT)) in dn_sendmsg()
1945 if (flags & MSG_EOR) { in dn_sendmsg()
1949 flags |= MSG_EOR; in dn_sendmsg()
2056 if (((sent + len) == size) && (flags & MSG_EOR)) { in dn_sendmsg()
/Linux-v4.19/include/linux/
Dsocket.h279 #define MSG_EOR 0x80 /* End of record */ macro
/Linux-v4.19/net/x25/
Daf_x25.c1095 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg()
1099 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg()
1336 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
/Linux-v4.19/net/rxrpc/
Drecvmsg.c572 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
/Linux-v4.19/net/kcm/
Dkcmsock.c907 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
1158 msg->msg_flags |= MSG_EOR; in kcm_recvmsg()
/Linux-v4.19/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-v4.19/net/
Dsocket.c898 msg.msg_flags |= MSG_EOR; in sock_write_iter()
2205 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
2213 &msg_sys, flags, &used_address, MSG_EOR); in __sys_sendmmsg()
/Linux-v4.19/net/ceph/
Dmessenger.c568 msg.msg_flags |= MSG_EOR; /* superfluous, but what the hell */ in ceph_tcp_sendmsg()
579 int flags = MSG_DONTWAIT | MSG_NOSIGNAL | (more ? MSG_MORE : MSG_EOR); in __ceph_tcp_sendpage()
608 msg.msg_flags |= MSG_EOR; /* superfluous, but what the hell */ in ceph_tcp_sendpage()
/Linux-v4.19/net/iucv/
Daf_iucv.c1074 if (sk->sk_type == SOCK_SEQPACKET && !(msg->msg_flags & MSG_EOR)) in iucv_sock_sendmsg()
1414 msg->msg_flags |= MSG_EOR; in iucv_sock_recvmsg()
/Linux-v4.19/net/tls/
Dtls_sw.c930 msg->msg_flags |= MSG_EOR; in tls_sw_recvmsg()
/Linux-v4.19/net/netrom/
Daf_netrom.c1039 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
/Linux-v4.19/drivers/xen/
Dpvcalls-front.c512 if (flags & (MSG_CONFIRM|MSG_DONTROUTE|MSG_EOR|MSG_OOB)) in pvcalls_front_sendmsg()
/Linux-v4.19/net/rose/
Daf_rose.c1062 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in rose_sendmsg()
/Linux-v4.19/net/ax25/
Daf_ax25.c1449 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in ax25_sendmsg()
/Linux-v4.19/net/ipv4/
Dtcp.c1374 if (unlikely(flags & MSG_EOR)) in tcp_sendmsg_locked()
/Linux-v4.19/net/tipc/
Dsocket.c1762 m->msg_flags |= MSG_EOR; in tipc_recvmsg()