Home
last modified time | relevance | path

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

123

/net/sctp/
Dulpqueue.c121 if ((event) && (event->msg_flags & MSG_EOR)){ in sctp_ulpq_tail_data()
234 if ((event->msg_flags & MSG_NOTIFICATION) || in sctp_ulpq_tail_event()
236 (event->msg_flags & SCTP_DATA_FRAG_MASK))) in sctp_ulpq_tail_event()
239 clear_pd = event->msg_flags & MSG_EOR; in sctp_ulpq_tail_event()
444 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_ulpq_retrieve_reassembled()
510 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_reassembled()
540 switch (cevent->msg_flags & SCTP_DATA_FRAG_MASK) { in sctp_ulpq_retrieve_partial()
570 retval->msg_flags |= MSG_EOR; in sctp_ulpq_retrieve_partial()
585 if (SCTP_DATA_NOT_FRAG == (event->msg_flags & SCTP_DATA_FRAG_MASK)) { in sctp_ulpq_reasm()
586 event->msg_flags |= MSG_EOR; in sctp_ulpq_reasm()
[all …]
Dulpevent.c60 int msg_flags, in sctp_ulpevent_init() argument
64 event->msg_flags = msg_flags; in sctp_ulpevent_init()
69 SCTP_STATIC struct sctp_ulpevent *sctp_ulpevent_new(int size, int msg_flags, in sctp_ulpevent_new() argument
80 sctp_ulpevent_init(event, msg_flags, skb->truesize); in sctp_ulpevent_new()
91 return MSG_NOTIFICATION == (event->msg_flags & MSG_NOTIFICATION); in sctp_ulpevent_is_notification()
757 event->msg_flags |= chunk->chunk_hdr->flags; in sctp_ulpevent_make_rcvmsg()
/net/core/
Dscm.c196 if (MSG_CMSG_COMPAT & msg->msg_flags) in put_cmsg()
200 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
204 msg->msg_flags |= MSG_CTRUNC; in put_cmsg()
237 if (MSG_CMSG_COMPAT & msg->msg_flags) { in scm_detach_fds()
256 err = get_unused_fd_flags(MSG_CMSG_CLOEXEC & msg->msg_flags in scm_detach_fds()
286 msg->msg_flags |= MSG_CTRUNC; in scm_detach_fds()
/net/rxrpc/
Dar-recvmsg.c63 ullen = msg->msg_flags & MSG_CMSG_COMPAT ? 4 : sizeof(unsigned long); in rxrpc_recvmsg()
66 msg->msg_flags |= MSG_MORE; in rxrpc_recvmsg()
89 (msg->msg_flags & MSG_PEEK || timeo == 0)) in rxrpc_recvmsg()
224 msg->msg_flags &= ~MSG_MORE; in rxrpc_recvmsg()
319 msg->msg_flags &= ~MSG_MORE; in rxrpc_recvmsg()
320 msg->msg_flags |= MSG_EOR; in rxrpc_recvmsg()
Dar-output.c56 if (msg->msg_flags & MSG_CMSG_COMPAT) { in rxrpc_sendmsg_cmsg()
348 msg.msg_flags = 0; in rxrpc_send_packet()
537 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data()
550 more = msg->msg_flags & MSG_MORE; in rxrpc_send_data()
572 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data()
597 sk, size, msg->msg_flags & MSG_DONTWAIT, &ret); in rxrpc_send_data()
Dar-connevent.c90 msg.msg_flags = 0; in rxrpc_abort_connection()
358 msg.msg_flags = 0; in rxrpc_reject_packets()
/net/phonet/
Ddatagram.c78 if (msg->msg_flags & MSG_OOB) in pn_sendmsg()
92 msg->msg_flags & MSG_DONTWAIT, &err); in pn_sendmsg()
136 msg->msg_flags |= MSG_TRUNC; in pn_recvmsg()
Dpep.c845 int flags = msg->msg_flags; in pep_sendmsg()
848 if (msg->msg_flags & MSG_OOB || !(msg->msg_flags & MSG_EOR)) in pep_sendmsg()
982 msg->msg_flags |= MSG_OOB; in pep_recvmsg()
1002 msg->msg_flags |= MSG_EOR; in pep_recvmsg()
1004 msg->msg_flags |= MSG_TRUNC; in pep_recvmsg()
/net/ipv4/
Draw.c460 if (msg->msg_flags & MSG_OOB) /* Mirror BSD error message */ in raw_sendmsg()
526 if (msg->msg_flags & MSG_DONTROUTE) in raw_sendmsg()
562 if (msg->msg_flags & MSG_CONFIRM) in raw_sendmsg()
568 rt, msg->msg_flags); in raw_sendmsg()
575 &ipc, &rt, msg->msg_flags); in raw_sendmsg()
578 else if (!(msg->msg_flags & MSG_MORE)) in raw_sendmsg()
594 if (!(msg->msg_flags & MSG_PROBE) || len) in raw_sendmsg()
671 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
Dudp.c585 int corkreq = up->corkflag || msg->msg_flags&MSG_MORE; in udp_sendmsg()
595 if (msg->msg_flags&MSG_OOB) /* Mirror BSD error message compatibility */ in udp_sendmsg()
668 (msg->msg_flags & MSG_DONTROUTE) || in udp_sendmsg()
714 if (msg->msg_flags&MSG_CONFIRM) in udp_sendmsg()
746 corkreq ? msg->msg_flags|MSG_MORE : msg->msg_flags); in udp_sendmsg()
776 if (!(msg->msg_flags&MSG_PROBE) || len) in udp_sendmsg()
789 struct msghdr msg = { .msg_flags = flags|MSG_MORE }; in udp_sendpage()
906 msg->msg_flags |= MSG_TRUNC; in udp_recvmsg()
Dip_sockglue.c104 msg->msg_flags |= MSG_CTRUNC; in ip_cmsg_recv_retopts()
375 msg->msg_flags |= MSG_TRUNC; in ip_recv_error()
413 msg->msg_flags |= MSG_ERRQUEUE; in ip_recv_error()
1161 msg.msg_flags = 0; in do_ip_getsockopt()
/net/x25/
Daf_x25.c990 int noblock = msg->msg_flags & MSG_DONTWAIT; in x25_sendmsg()
994 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg()
998 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg()
1045 if ((msg->msg_flags & MSG_OOB) && len > 32) in x25_sendmsg()
1053 X25_SKB_CB(skb)->flags = msg->msg_flags; in x25_sendmsg()
1083 if (msg->msg_flags & MSG_OOB) { in x25_sendmsg()
1122 if (msg->msg_flags & MSG_OOB) in x25_sendmsg()
1196 msg->msg_flags |= MSG_OOB; in x25_recvmsg()
1220 msg->msg_flags |= MSG_TRUNC; in x25_recvmsg()
1224 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
/net/bluetooth/
Dhci_sock.c341 if (msg->msg_flags & MSG_CMSG_COMPAT) { in hci_sock_cmsg()
377 msg->msg_flags |= MSG_TRUNC; in hci_sock_recvmsg()
401 if (msg->msg_flags & MSG_OOB) in hci_sock_sendmsg()
404 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_NOSIGNAL|MSG_ERRQUEUE)) in hci_sock_sendmsg()
417 if (!(skb = bt_skb_send_alloc(sk, len, msg->msg_flags & MSG_DONTWAIT, &err))) in hci_sock_sendmsg()
/net/ipv6/
Draw.c472 msg->msg_flags |= MSG_TRUNC; in rawv6_recvmsg()
477 } else if (msg->msg_flags&MSG_TRUNC) { in rawv6_recvmsg()
746 if (msg->msg_flags & MSG_OOB) in rawv6_sendmsg()
886 if (msg->msg_flags&MSG_CONFIRM) in rawv6_sendmsg()
891 err = rawv6_send_hdrinc(sk, msg->msg_iov, len, &fl, (struct rt6_info*)dst, msg->msg_flags); in rawv6_sendmsg()
896 msg->msg_flags); in rawv6_sendmsg()
900 else if (!(msg->msg_flags & MSG_MORE)) in rawv6_sendmsg()
911 if (!(msg->msg_flags & MSG_PROBE) || len) in rawv6_sendmsg()
Dudp.c189 msg->msg_flags |= MSG_TRUNC; in udpv6_recvmsg()
676 int corkreq = up->corkflag || msg->msg_flags&MSG_MORE; in udpv6_sendmsg()
878 if (msg->msg_flags&MSG_CONFIRM) in udpv6_sendmsg()
901 corkreq ? msg->msg_flags|MSG_MORE : msg->msg_flags); in udpv6_sendmsg()
948 if (!(msg->msg_flags&MSG_PROBE) || len) in udpv6_sendmsg()
Ddatagram.c304 msg->msg_flags |= MSG_TRUNC; in ipv6_recv_error()
365 msg->msg_flags |= MSG_ERRQUEUE; in ipv6_recv_error()
/net/econet/
Daf_econet.c158 msg->msg_flags|=MSG_TRUNC; in econet_recvmsg()
290 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_CMSG_COMPAT)) in econet_sendmsg()
344 msg->msg_flags & MSG_DONTWAIT, &err); in econet_sendmsg()
473 msg->msg_flags & MSG_DONTWAIT, in econet_sendmsg()
496 udpmsg.msg_flags=0; in econet_sendmsg()
839 udpmsg.msg_flags=0; in aun_send_response()
/net/
Dcompat.c68 __get_user(kmsg->msg_flags, &umsg->msg_flags)) in get_compat_msghdr()
225 kmsg->msg_flags |= MSG_CTRUNC; in put_cmsg_compat()
246 kmsg->msg_flags |= MSG_CTRUNC; in put_cmsg_compat()
282 err = get_unused_fd_flags(MSG_CMSG_CLOEXEC & kmsg->msg_flags in scm_detach_fds_compat()
311 kmsg->msg_flags |= MSG_CTRUNC; in scm_detach_fds_compat()
Dsocket.c758 msg->msg_flags = (file->f_flags & O_NONBLOCK) ? MSG_DONTWAIT : 0; in do_sock_read()
760 return __sock_recvmsg(iocb, sock, msg, size, msg->msg_flags); in do_sock_read()
798 msg->msg_flags = (file->f_flags & O_NONBLOCK) ? MSG_DONTWAIT : 0; in do_sock_write()
800 msg->msg_flags |= MSG_EOR; in do_sock_write()
1664 msg.msg_flags = flags; in SYSCALL_DEFINE6()
1827 #define COMPAT_FLAGS(msg) COMPAT_MSG(msg, msg_flags)
1917 msg_sys.msg_flags = flags; in SYSCALL_DEFINE3()
1920 msg_sys.msg_flags |= MSG_DONTWAIT; in SYSCALL_DEFINE3()
2003 msg_sys.msg_flags = flags & (MSG_CMSG_CLOEXEC|MSG_CMSG_COMPAT); in SYSCALL_DEFINE3()
2019 err = __put_user((msg_sys.msg_flags & ~MSG_CMSG_COMPAT), in SYSCALL_DEFINE3()
/net/irda/
Daf_irda.c1262 if (msg->msg_flags & ~(MSG_DONTWAIT | MSG_EOR | MSG_CMSG_COMPAT | in irda_sendmsg()
1292 msg->msg_flags & MSG_DONTWAIT, &err); in irda_sendmsg()
1318 return sk_stream_error(sk, msg->msg_flags, err); in irda_sendmsg()
1354 msg->msg_flags |= MSG_TRUNC; in irda_recvmsg_dgram()
1513 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_CMSG_COMPAT)) in irda_sendmsg_dgram()
1538 msg->msg_flags & MSG_DONTWAIT, &err); in irda_sendmsg_dgram()
1584 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_CMSG_COMPAT)) in irda_sendmsg_ultra()
1633 msg->msg_flags & MSG_DONTWAIT, &err); in irda_sendmsg_ultra()
/net/tipc/
Dsocket.c587 if (m->msg_flags & MSG_DONTWAIT) { in send_msg()
646 if (m->msg_flags & MSG_DONTWAIT) { in send_packet()
726 my_msg.msg_flags = m->msg_flags; in send_stream()
977 m->msg_flags |= MSG_TRUNC; in recv_msg()
/net/unix/
Daf_unix.c1363 if (msg->msg_flags&MSG_OOB) in unix_dgram_sendmsg()
1387 skb = sock_alloc_send_skb(sk, len, msg->msg_flags&MSG_DONTWAIT, &err); in unix_dgram_sendmsg()
1404 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in unix_dgram_sendmsg()
1514 if (msg->msg_flags&MSG_OOB) in unix_stream_sendmsg()
1550 skb = sock_alloc_send_skb(sk, size, msg->msg_flags&MSG_DONTWAIT, in unix_stream_sendmsg()
1601 if (sent == 0 && !(msg->msg_flags&MSG_NOSIGNAL)) in unix_stream_sendmsg()
1679 msg->msg_flags |= MSG_TRUNC; in unix_dgram_recvmsg()
/net/sunrpc/
Dsvcsock.c186 .msg_flags = MSG_MORE, in svc_sendto()
312 .msg_flags = MSG_DONTWAIT, in svc_recvfrom()
319 msg.msg_flags); in svc_recvfrom()
435 .msg_flags = MSG_DONTWAIT, in svc_udp_recvfrom()
/net/can/
Draw.c643 skb = sock_alloc_send_skb(sk, size, msg->msg_flags & MSG_DONTWAIT, in raw_sendmsg()
687 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
/net/netrom/
Daf_netrom.c1040 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_EOR|MSG_CMSG_COMPAT)) in nr_sendmsg()
1089 if ((skb = sock_alloc_send_skb(sk, size, msg->msg_flags & MSG_DONTWAIT, &err)) == NULL) in nr_sendmsg()
1172 msg->msg_flags |= MSG_TRUNC; in nr_recvmsg()

123