Home
last modified time | relevance | path

Searched refs:msg_flags (Results 1 – 25 of 86) sorted by relevance

1234

/net/sctp/
Dstream_interleave.c140 (cevent->msg_flags & SCTP_DATA_FIRST_FRAG || in sctp_intl_store_reasm()
141 (!(event->msg_flags & SCTP_DATA_FIRST_FRAG) && in sctp_intl_store_reasm()
166 !(cevent->msg_flags & SCTP_DATA_FIRST_FRAG) && in sctp_intl_store_reasm()
167 (event->msg_flags & SCTP_DATA_FIRST_FRAG || in sctp_intl_store_reasm()
204 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_intl_retrieve_partial()
249 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_partial()
287 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_intl_retrieve_reassembled()
342 retval->msg_flags |= MSG_EOR; in sctp_intl_retrieve_reassembled()
354 if (SCTP_DATA_NOT_FRAG == (event->msg_flags & SCTP_DATA_FRAG_MASK)) { in sctp_intl_reasm()
355 event->msg_flags |= MSG_EOR; in sctp_intl_reasm()
[all …]
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()
224 if ((event->msg_flags & MSG_NOTIFICATION) || in sctp_ulpq_tail_event()
226 (event->msg_flags & SCTP_DATA_FRAG_MASK))) in sctp_ulpq_tail_event()
229 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
435 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_ulpq_retrieve_reassembled()
502 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_reassembled()
532 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_ulpq_retrieve_partial()
568 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_partial()
583 if (SCTP_DATA_NOT_FRAG == (event->msg_flags & SCTP_DATA_FRAG_MASK)) { in sctp_ulpq_reasm()
[all …]
Dulpevent.c39 __u16 msg_flags, in sctp_ulpevent_init() argument
43 event->msg_flags = msg_flags; in sctp_ulpevent_init()
48 static struct sctp_ulpevent *sctp_ulpevent_new(int size, __u16 msg_flags, in sctp_ulpevent_new() argument
59 sctp_ulpevent_init(event, msg_flags, skb->truesize); in sctp_ulpevent_new()
70 return MSG_NOTIFICATION == (event->msg_flags & MSG_NOTIFICATION); in sctp_ulpevent_is_notification()
753 event->msg_flags |= chunk->chunk_hdr->flags; in sctp_ulpevent_make_rcvmsg()
/net/core/
Dscm.c223 if (msg->msg_flags & MSG_CMSG_COMPAT) in put_cmsg()
227 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
231 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
309 unsigned int o_flags = (msg->msg_flags & MSG_CMSG_CLOEXEC) ? O_CLOEXEC : 0; in scm_detach_fds()
318 if (msg->msg_flags & MSG_CMSG_COMPAT) { in scm_detach_fds()
347 msg->msg_flags |= MSG_CTRUNC; in scm_detach_fds()
/net/phonet/
Ddatagram.c79 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pn_sendmsg()
93 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
134 msg->msg_flags |= MSG_TRUNC; in pn_recvmsg()
Dpep.c1119 int flags = msg->msg_flags; in pep_sendmsg()
1125 if ((msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_NOSIGNAL| in pep_sendmsg()
1127 !(msg->msg_flags & MSG_EOR)) in pep_sendmsg()
1263 msg->msg_flags |= MSG_OOB; in pep_recvmsg()
1283 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
1285 msg->msg_flags |= MSG_TRUNC; in pep_recvmsg()
/net/rds/
Drecv.c634 int msg_flags) in rds_recvmsg() argument
639 int ret = 0, nonblock = msg_flags & MSG_DONTWAIT; in rds_recvmsg()
647 rdsdebug("size %zu flags 0x%x timeo %ld\n", size, msg_flags, timeo); in rds_recvmsg()
649 if (msg_flags & MSG_OOB) in rds_recvmsg()
651 if (msg_flags & MSG_ERRQUEUE) in rds_recvmsg()
701 if (!rds_still_queued(rs, inc, !(msg_flags & MSG_PEEK))) { in rds_recvmsg()
710 if (msg_flags & MSG_TRUNC) in rds_recvmsg()
712 msg->msg_flags |= MSG_TRUNC; in rds_recvmsg()
/net/sunrpc/
Dsocklib.c283 msg->msg_flags |= MSG_MORE; in xprt_sock_sendmsg()
290 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
309 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
321 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
Dxprtsock.c420 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
443 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
459 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf()
497 msg->msg_flags |= MSG_EOR; in xs_read_stream_check_eor()
531 msg->msg_flags |= MSG_TRUNC; in xs_read_stream_request()
580 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_call()
606 msg->msg_flags |= MSG_TRUNC; in xs_read_stream_reply()
615 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_reply()
649 msg.msg_flags |= MSG_TRUNC; in xs_read_stream()
657 if (msg.msg_flags & MSG_TRUNC) { in xs_read_stream()
[all …]
/net/l2tp/
Dl2tp_ip6.c513 if (msg->msg_flags & MSG_OOB) in l2tp_ip6_sendmsg()
626 if (msg->msg_flags & MSG_CONFIRM) in l2tp_ip6_sendmsg()
635 msg->msg_flags); in l2tp_ip6_sendmsg()
638 else if (!(msg->msg_flags & MSG_MORE)) in l2tp_ip6_sendmsg()
650 if (msg->msg_flags & MSG_PROBE) in l2tp_ip6_sendmsg()
652 if (!(msg->msg_flags & MSG_PROBE) || len) in l2tp_ip6_sendmsg()
679 msg->msg_flags |= MSG_TRUNC; in l2tp_ip6_recvmsg()
/net/
Dcompat.c47 kmsg->msg_flags = msg.msg_flags; in __get_compat_msghdr()
237 kmsg->msg_flags |= MSG_CTRUNC; in put_cmsg_compat()
265 kmsg->msg_flags |= MSG_CTRUNC; in put_cmsg_compat()
295 unsigned int o_flags = (msg->msg_flags & MSG_CMSG_CLOEXEC) ? O_CLOEXEC : 0; in scm_detach_fds_compat()
324 msg->msg_flags |= MSG_CTRUNC; in scm_detach_fds_compat()
Dsocket.c1061 msg.msg_flags = MSG_DONTWAIT; in sock_read_iter()
1069 res = sock_recvmsg(sock, &msg, msg.msg_flags); in sock_read_iter()
1086 msg.msg_flags = MSG_DONTWAIT; in sock_write_iter()
1089 msg.msg_flags |= MSG_EOR; in sock_write_iter()
2069 msg.msg_flags = flags; in __sys_sendto()
2124 msg.msg_flags = 0; in __sys_recvfrom()
2310 #define COMPAT_FLAGS(msg) COMPAT_MSG(msg, msg_flags)
2331 kmsg->msg_flags = msg.msg_flags; in __copy_msghdr_from_user()
2402 flags |= (msg_sys->msg_flags & allowed_msghdr_flags); in ____sys_sendmsg()
2426 msg_sys->msg_flags = flags; in ____sys_sendmsg()
[all …]
/net/xfrm/
Despintcp.c155 msg->msg_flags |= MSG_TRUNC; in espintcp_recvmsg()
317 long timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
326 if (msg->msg_flags & ~MSG_DONTWAIT) in espintcp_sendmsg()
337 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
339 if (err != -EAGAIN || !(msg->msg_flags & MSG_DONTWAIT)) in espintcp_sendmsg()
377 err = espintcp_push_msgs(sk, msg->msg_flags & MSG_DONTWAIT); in espintcp_sendmsg()
/net/ipv4/
Draw.c530 if (msg->msg_flags & MSG_OOB) /* Mirror BSD error message */ in raw_sendmsg()
606 if (msg->msg_flags & MSG_DONTROUTE) in raw_sendmsg()
658 if (msg->msg_flags & MSG_CONFIRM) in raw_sendmsg()
664 &rt, msg->msg_flags, &ipc.sockc); in raw_sendmsg()
672 &ipc, &rt, msg->msg_flags); in raw_sendmsg()
675 else if (!(msg->msg_flags & MSG_MORE)) { in raw_sendmsg()
693 if (msg->msg_flags & MSG_PROBE) in raw_sendmsg()
695 if (!(msg->msg_flags & MSG_PROBE) || len) in raw_sendmsg()
780 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
Dping.c674 if (msg->msg_flags & MSG_OOB) in ping_common_sendmsg()
780 (msg->msg_flags & MSG_DONTROUTE) || in ping_v4_sendmsg()
816 if (msg->msg_flags & MSG_CONFIRM) in ping_v4_sendmsg()
835 0, &ipc, &rt, msg->msg_flags); in ping_v4_sendmsg()
854 if (msg->msg_flags & MSG_PROBE) in ping_v4_sendmsg()
856 if (!(msg->msg_flags & MSG_PROBE) || len) in ping_v4_sendmsg()
885 msg->msg_flags |= MSG_TRUNC; in ping_recvmsg()
/net/smc/
Dsmc_tx.c166 if (msg->msg_flags & MSG_OOB) in smc_tx_sendmsg()
177 if (msg->msg_flags & MSG_OOB) in smc_tx_sendmsg()
183 rc = smc_tx_wait(smc, msg->msg_flags); in smc_tx_sendmsg()
236 if ((msg->msg_flags & MSG_OOB) && !send_remaining) in smc_tx_sendmsg()
238 if ((msg->msg_flags & MSG_MORE || smc_tx_is_corked(smc)) && in smc_tx_sendmsg()
253 rc = sk_stream_error(sk, msg->msg_flags, rc); in smc_tx_sendmsg()
/net/ieee802154/
Dsocket.c249 if (msg->msg_flags & MSG_OOB) { in raw_sendmsg()
250 pr_debug("msg->msg_flags = 0x%x\n", msg->msg_flags); in raw_sendmsg()
283 msg->msg_flags & MSG_DONTWAIT, &err); in raw_sendmsg()
328 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
620 if (msg->msg_flags & MSG_OOB) { in dgram_sendmsg()
621 pr_debug("msg->msg_flags = 0x%x\n", msg->msg_flags); in dgram_sendmsg()
662 msg->msg_flags & MSG_DONTWAIT, in dgram_sendmsg()
722 msg->msg_flags |= MSG_TRUNC; in dgram_recvmsg()
/net/caif/
Dcaif_socket.c289 m->msg_flags |= MSG_TRUNC; in caif_seqpkt_recvmsg()
534 if (msg->msg_flags&MSG_OOB) in caif_seqpkt_sendmsg()
545 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg()
605 if (unlikely(msg->msg_flags&MSG_OOB)) in caif_stream_sendmsg()
611 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg()
634 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg()
655 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg()
666 if (sent == 0 && !(msg->msg_flags&MSG_NOSIGNAL)) in caif_stream_sendmsg()
/net/ipv6/
Draw.c487 msg->msg_flags |= MSG_TRUNC; in rawv6_recvmsg()
492 } else if (msg->msg_flags&MSG_TRUNC) { in rawv6_recvmsg()
797 if (msg->msg_flags & MSG_OOB) in rawv6_sendmsg()
944 if (msg->msg_flags&MSG_CONFIRM) in rawv6_sendmsg()
950 msg->msg_flags, &ipc6.sockc); in rawv6_sendmsg()
956 msg->msg_flags); in rawv6_sendmsg()
960 else if (!(msg->msg_flags & MSG_MORE)) in rawv6_sendmsg()
971 if (msg->msg_flags & MSG_PROBE) in rawv6_sendmsg()
973 if (!(msg->msg_flags & MSG_PROBE) || len) in rawv6_sendmsg()
Dudp.c375 msg->msg_flags |= MSG_TRUNC; in udpv6_recvmsg()
472 msg->msg_flags &= ~MSG_TRUNC; in udpv6_recvmsg()
1340 int corkreq = READ_ONCE(up->corkflag) || msg->msg_flags&MSG_MORE; in udpv6_sendmsg()
1567 if (msg->msg_flags&MSG_CONFIRM) in udpv6_sendmsg()
1579 msg->msg_flags, &cork); in udpv6_sendmsg()
1605 corkreq ? msg->msg_flags|MSG_MORE : msg->msg_flags); in udpv6_sendmsg()
1638 if (msg->msg_flags & MSG_PROBE) in udpv6_sendmsg()
1640 if (!(msg->msg_flags&MSG_PROBE) || len) in udpv6_sendmsg()
/net/rxrpc/
Dsendmsg.c298 bool more = msg->msg_flags & MSG_MORE; in rxrpc_send_data()
301 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
359 sk, bufsize, msg->msg_flags & MSG_DONTWAIT, &ret); in rxrpc_send_data()
474 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data()
479 msg->msg_flags & MSG_WAITALL); in rxrpc_send_data()
519 if (msg->msg_flags & MSG_CMSG_COMPAT) { in rxrpc_sendmsg_cmsg()
Doutput.c205 msg.msg_flags = 0; in rxrpc_send_ack_packet()
314 msg.msg_flags = 0; in rxrpc_send_abort_packet()
399 msg.msg_flags = 0; in rxrpc_send_data_packet()
577 msg.msg_flags = 0; in rxrpc_reject_packets()
646 msg.msg_flags = 0; in rxrpc_send_keepalive()
/net/x25/
Daf_x25.c1106 int noblock = msg->msg_flags & MSG_DONTWAIT; in x25_sendmsg()
1111 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg()
1115 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg()
1168 if ((msg->msg_flags & MSG_OOB) && len > 32) in x25_sendmsg()
1178 X25_SKB_CB(skb)->flags = msg->msg_flags; in x25_sendmsg()
1211 if (msg->msg_flags & MSG_OOB) { in x25_sendmsg()
1250 if (msg->msg_flags & MSG_OOB) in x25_sendmsg()
1320 msg->msg_flags |= MSG_OOB; in x25_recvmsg()
1348 msg->msg_flags |= MSG_TRUNC; in x25_recvmsg()
1352 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
/net/ceph/
Dmessenger_v1.c27 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_recvmsg()
31 msg.msg_flags |= MSG_TRUNC; in ceph_tcp_recvmsg()
34 r = sock_recvmsg(sock, &msg, msg.msg_flags); in ceph_tcp_recvmsg()
48 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_recvpage()
53 r = sock_recvmsg(sock, &msg, msg.msg_flags); in ceph_tcp_recvpage()
66 struct msghdr msg = { .msg_flags = MSG_DONTWAIT | MSG_NOSIGNAL }; in ceph_tcp_sendmsg()
70 msg.msg_flags |= MSG_MORE; in ceph_tcp_sendmsg()
72 msg.msg_flags |= MSG_EOR; /* superfluous, but what the hell */ in ceph_tcp_sendmsg()
/net/can/j1939/
Dsocket.c330 skcb->msg_flags &= ~(MSG_DONTROUTE); in j1939_sk_recv_one()
332 skcb->msg_flags |= MSG_DONTROUTE; in j1939_sk_recv_one()
827 msg->msg_flags |= MSG_TRUNC; in j1939_sk_recvmsg()
862 msg->msg_flags |= skcb->msg_flags; in j1939_sk_recvmsg()
883 msg->msg_flags & MSG_DONTWAIT, &ret); in j1939_sk_alloc_skb()

1234