/Linux-v5.10/net/sctp/ |
D | stream_interleave.c | 140 (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 …]
|
D | ulpqueue.c | 109 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 …]
|
D | ulpevent.c | 39 __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()
|
/Linux-v5.10/net/core/ |
D | scm.c | 217 if (msg->msg_flags & MSG_CMSG_COMPAT) in put_cmsg() 221 msg->msg_flags |= MSG_CTRUNC; in put_cmsg() 225 msg->msg_flags |= MSG_CTRUNC; in put_cmsg() 294 unsigned int o_flags = (msg->msg_flags & MSG_CMSG_CLOEXEC) ? O_CLOEXEC : 0; in scm_detach_fds() 303 if (msg->msg_flags & MSG_CMSG_COMPAT) { in scm_detach_fds() 332 msg->msg_flags |= MSG_CTRUNC; in scm_detach_fds()
|
/Linux-v5.10/drivers/net/can/peak_canfd/ |
D | peak_canfd.c | 651 u16 msg_size, msg_flags; in peak_canfd_start_xmit() local 674 msg_flags = 0; in peak_canfd_start_xmit() 677 msg_flags |= PUCAN_MSG_EXT_ID; in peak_canfd_start_xmit() 687 msg_flags |= PUCAN_MSG_EXT_DATA_LEN; in peak_canfd_start_xmit() 690 msg_flags |= PUCAN_MSG_BITRATE_SWITCH; in peak_canfd_start_xmit() 693 msg_flags |= PUCAN_MSG_ERROR_STATE_IND; in peak_canfd_start_xmit() 699 msg_flags |= PUCAN_MSG_RTR; in peak_canfd_start_xmit() 703 msg_flags |= PUCAN_MSG_LOOPED_BACK; in peak_canfd_start_xmit() 707 msg_flags |= PUCAN_MSG_SELF_RECEIVE; in peak_canfd_start_xmit() 709 msg->flags = cpu_to_le16(msg_flags); in peak_canfd_start_xmit()
|
/Linux-v5.10/net/phonet/ |
D | datagram.c | 79 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()
|
/Linux-v5.10/drivers/media/common/siano/ |
D | smsendian.c | 89 phdr->msg_flags = le16_to_cpu((__force __le16)phdr->msg_flags); in smsendian_handle_message_header()
|
/Linux-v5.10/net/sunrpc/ |
D | socklib.c | 283 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()
|
D | xprtsock.c | 415 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf() 437 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf() 453 if (offset == count || msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_xdr_buf() 491 msg->msg_flags |= MSG_EOR; in xs_read_stream_check_eor() 525 msg->msg_flags |= MSG_TRUNC; in xs_read_stream_request() 570 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_call() 596 msg->msg_flags |= MSG_TRUNC; in xs_read_stream_reply() 605 if (msg->msg_flags & (MSG_EOR|MSG_TRUNC)) in xs_read_stream_reply() 639 msg.msg_flags |= MSG_TRUNC; in xs_read_stream() 647 if (msg.msg_flags & MSG_TRUNC) { in xs_read_stream() [all …]
|
/Linux-v5.10/net/rds/ |
D | recv.c | 634 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()
|
/Linux-v5.10/net/l2tp/ |
D | l2tp_ip6.c | 515 if (msg->msg_flags & MSG_OOB) in l2tp_ip6_sendmsg() 628 if (msg->msg_flags & MSG_CONFIRM) in l2tp_ip6_sendmsg() 636 msg->msg_flags); in l2tp_ip6_sendmsg() 639 else if (!(msg->msg_flags & MSG_MORE)) in l2tp_ip6_sendmsg() 651 if (msg->msg_flags & MSG_PROBE) in l2tp_ip6_sendmsg() 653 if (!(msg->msg_flags & MSG_PROBE) || len) in l2tp_ip6_sendmsg() 680 msg->msg_flags |= MSG_TRUNC; in l2tp_ip6_recvmsg()
|
/Linux-v5.10/net/xfrm/ |
D | espintcp.c | 155 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()
|
/Linux-v5.10/net/ |
D | compat.c | 47 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()
|
/Linux-v5.10/net/ipv4/ |
D | raw.c | 530 if (msg->msg_flags & MSG_OOB) /* Mirror BSD error message */ in raw_sendmsg() 603 if (msg->msg_flags & MSG_DONTROUTE) in raw_sendmsg() 655 if (msg->msg_flags & MSG_CONFIRM) in raw_sendmsg() 661 &rt, msg->msg_flags, &ipc.sockc); in raw_sendmsg() 669 &ipc, &rt, msg->msg_flags); in raw_sendmsg() 672 else if (!(msg->msg_flags & MSG_MORE)) { in raw_sendmsg() 690 if (msg->msg_flags & MSG_PROBE) in raw_sendmsg() 692 if (!(msg->msg_flags & MSG_PROBE) || len) in raw_sendmsg() 774 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg()
|
/Linux-v5.10/net/ieee802154/ |
D | socket.c | 249 if (msg->msg_flags & MSG_OOB) { in raw_sendmsg() 250 pr_debug("msg->msg_flags = 0x%x\n", msg->msg_flags); in raw_sendmsg() 279 msg->msg_flags & MSG_DONTWAIT, &err); in raw_sendmsg() 324 msg->msg_flags |= MSG_TRUNC; in raw_recvmsg() 611 if (msg->msg_flags & MSG_OOB) { in dgram_sendmsg() 612 pr_debug("msg->msg_flags = 0x%x\n", msg->msg_flags); in dgram_sendmsg() 643 msg->msg_flags & MSG_DONTWAIT, in dgram_sendmsg() 713 msg->msg_flags |= MSG_TRUNC; in dgram_recvmsg()
|
/Linux-v5.10/net/caif/ |
D | caif_socket.c | 289 m->msg_flags |= MSG_TRUNC; in caif_seqpkt_recvmsg() 534 if (msg->msg_flags&MSG_OOB) in caif_seqpkt_sendmsg() 544 noblock = msg->msg_flags & MSG_DONTWAIT; in caif_seqpkt_sendmsg() 604 if (unlikely(msg->msg_flags&MSG_OOB)) in caif_stream_sendmsg() 610 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in caif_stream_sendmsg() 633 msg->msg_flags&MSG_DONTWAIT, in caif_stream_sendmsg() 654 msg->msg_flags&MSG_DONTWAIT, timeo); in caif_stream_sendmsg() 665 if (sent == 0 && !(msg->msg_flags&MSG_NOSIGNAL)) in caif_stream_sendmsg()
|
/Linux-v5.10/tools/testing/selftests/net/ |
D | tcp_inq.c | 155 msg.msg_flags = 0; in main() 163 if (msg.msg_flags & MSG_CTRUNC) in main()
|
D | so_txtime.c | 170 if (msg.msg_flags != MSG_ERRQUEUE) in do_recv_errqueue_timeout() 171 error(1, 0, "errqueue: flags 0x%x\n", msg.msg_flags); in do_recv_errqueue_timeout() 207 msg.msg_flags = 0; in do_recv_errqueue_timeout()
|
/Linux-v5.10/net/smc/ |
D | smc_tx.c | 164 if (msg->msg_flags & MSG_OOB) in smc_tx_sendmsg() 170 rc = smc_tx_wait(smc, msg->msg_flags); in smc_tx_sendmsg() 223 if ((msg->msg_flags & MSG_OOB) && !send_remaining) in smc_tx_sendmsg() 225 if ((msg->msg_flags & MSG_MORE || smc_tx_is_corked(smc)) && in smc_tx_sendmsg() 240 rc = sk_stream_error(sk, msg->msg_flags, rc); in smc_tx_sendmsg()
|
/Linux-v5.10/net/rxrpc/ |
D | sendmsg.c | 302 timeo = sock_sndtimeo(sk, msg->msg_flags & MSG_DONTWAIT); in rxrpc_send_data() 310 more = msg->msg_flags & MSG_MORE; in rxrpc_send_data() 336 if (msg->msg_flags & MSG_DONTWAIT) in rxrpc_send_data() 340 msg->msg_flags & MSG_WAITALL); in rxrpc_send_data() 362 sk, size, msg->msg_flags & MSG_DONTWAIT, &ret); in rxrpc_send_data() 509 if (msg->msg_flags & MSG_CMSG_COMPAT) { in rxrpc_sendmsg_cmsg()
|
D | output.c | 198 msg.msg_flags = 0; in rxrpc_send_ack_packet() 310 msg.msg_flags = 0; in rxrpc_send_abort_packet() 395 msg.msg_flags = 0; in rxrpc_send_data_packet() 573 msg.msg_flags = 0; in rxrpc_reject_packets() 642 msg.msg_flags = 0; in rxrpc_send_keepalive()
|
/Linux-v5.10/net/ipv6/ |
D | raw.c | 487 msg->msg_flags |= MSG_TRUNC; in rawv6_recvmsg() 492 } else if (msg->msg_flags&MSG_TRUNC) { in rawv6_recvmsg() 793 if (msg->msg_flags & MSG_OOB) in rawv6_sendmsg() 939 if (msg->msg_flags&MSG_CONFIRM) in rawv6_sendmsg() 945 msg->msg_flags, &ipc6.sockc); in rawv6_sendmsg() 951 msg->msg_flags); in rawv6_sendmsg() 955 else if (!(msg->msg_flags & MSG_MORE)) in rawv6_sendmsg() 966 if (msg->msg_flags & MSG_PROBE) in rawv6_sendmsg() 968 if (!(msg->msg_flags & MSG_PROBE) || len) in rawv6_sendmsg()
|
/Linux-v5.10/drivers/char/ipmi/ |
D | ipmi_si_intf.c | 162 unsigned char msg_flags; member 462 if (smi_info->msg_flags & WDT_PRE_TIMEOUT_INT) { in handle_flags() 467 smi_info->msg_flags &= ~WDT_PRE_TIMEOUT_INT; in handle_flags() 469 } else if (smi_info->msg_flags & RECEIVE_MSG_AVAIL) { in handle_flags() 476 } else if (smi_info->msg_flags & EVENT_MSG_BUFFER_FULL) { in handle_flags() 483 } else if (smi_info->msg_flags & OEM_DATA_AVAIL && in handle_flags() 579 smi_info->msg_flags = msg[3]; in handle_transaction_done() 620 smi_info->msg_flags &= ~EVENT_MSG_BUFFER_FULL; in handle_transaction_done() 658 smi_info->msg_flags &= ~RECEIVE_MSG_AVAIL; in handle_transaction_done() 1701 smi_info->msg_flags = ((smi_info->msg_flags & ~OEM_DATA_AVAIL) | in oem_data_avail_to_receive_msg_avail()
|
D | ipmi_ssif.c | 219 unsigned char msg_flags; member 359 ssif_info->msg_flags &= ~WDT_PRE_TIMEOUT_INT; in start_clear_flags() 457 if (ssif_info->msg_flags & WDT_PRE_TIMEOUT_INT) { in handle_flags() 462 } else if (ssif_info->msg_flags & RECEIVE_MSG_AVAIL) in handle_flags() 465 else if (ssif_info->msg_flags & EVENT_MSG_BUFFER_FULL) in handle_flags() 820 ssif_info->msg_flags = data[3]; in msg_done_handler() 848 ssif_info->msg_flags &= ~EVENT_MSG_BUFFER_FULL; in msg_done_handler() 857 ssif_info->msg_flags &= ~EVENT_MSG_BUFFER_FULL; in msg_done_handler() 872 ssif_info->msg_flags &= ~RECEIVE_MSG_AVAIL; in msg_done_handler() 882 ssif_info->msg_flags &= ~RECEIVE_MSG_AVAIL; in msg_done_handler()
|
/Linux-v5.10/net/x25/ |
D | af_x25.c | 1110 int noblock = msg->msg_flags & MSG_DONTWAIT; in x25_sendmsg() 1115 if (msg->msg_flags & ~(MSG_DONTWAIT|MSG_OOB|MSG_EOR|MSG_CMSG_COMPAT)) in x25_sendmsg() 1119 if (!(msg->msg_flags & (MSG_EOR|MSG_OOB))) in x25_sendmsg() 1172 if ((msg->msg_flags & MSG_OOB) && len > 32) in x25_sendmsg() 1182 X25_SKB_CB(skb)->flags = msg->msg_flags; in x25_sendmsg() 1215 if (msg->msg_flags & MSG_OOB) { in x25_sendmsg() 1254 if (msg->msg_flags & MSG_OOB) in x25_sendmsg() 1324 msg->msg_flags |= MSG_OOB; in x25_recvmsg() 1352 msg->msg_flags |= MSG_TRUNC; in x25_recvmsg() 1356 msg->msg_flags |= MSG_EOR; in x25_recvmsg()
|