| /linux/net/sunrpc/ |
| H A D | socklib.c | 232 msg->msg_flags |= MSG_MORE; in xprt_sock_sendmsg() 239 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg() 258 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg() 270 msg->msg_flags &= ~MSG_MORE; in xprt_sock_sendmsg()
|
| /linux/crypto/ |
| H A D | algif_hash.c | 91 if (!(msg->msg_flags & MSG_MORE)) { in hash_sendmsg() 136 !(msg->msg_flags & MSG_MORE)) { in hash_sendmsg() 148 if (msg_data_left(msg) || (msg->msg_flags & MSG_MORE)) in hash_sendmsg() 164 ctx->more = msg->msg_flags & MSG_MORE; in hash_sendmsg()
|
| H A D | af_alg.c | 1081 ctx->more = msg->msg_flags & MSG_MORE; in af_alg_sendmsg()
|
| /linux/net/xfrm/ |
| H A D | espintcp.c | 210 .msg_flags = flags | MSG_SPLICE_PAGES | MSG_MORE, in espintcp_sendskmsg_locked() 213 bool more = flags & MSG_MORE; in espintcp_sendskmsg_locked() 228 msghdr.msg_flags &= ~MSG_MORE; in espintcp_sendskmsg_locked()
|
| /linux/net/tls/ |
| H A D | tls_device.c | 440 ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL | in tls_push_data() 444 if ((flags & (MSG_MORE | MSG_EOR)) == (MSG_MORE | MSG_EOR)) in tls_push_data() 451 tls_push_record_flags = flags | MSG_MORE; in tls_push_data() 534 if (flags & MSG_MORE) { in tls_push_data()
|
| H A D | tls_main.c | 255 if (msg->msg_flags & MSG_MORE) in tls_process_cmsg()
|
| H A D | tls_sw.c | 1046 bool eor = !(msg->msg_flags & MSG_MORE); in tls_sw_sendmsg_locked() 1283 if (msg->msg_flags & ~(MSG_MORE | MSG_DONTWAIT | MSG_NOSIGNAL | in tls_sw_sendmsg()
|
| /linux/tools/testing/vsock/ |
| H A D | control.c | 119 ret = send(control_fd, str, len, MSG_MORE); in control_writeln()
|
| /linux/net/rds/ |
| H A D | tcp_send.c | 118 msg.msg_flags |= MSG_MORE; in rds_tcp_xmit()
|
| /linux/drivers/infiniband/sw/siw/ |
| H A D | siw_qp_tx.c | 328 .msg_flags = (MSG_MORE | MSG_DONTWAIT | MSG_SPLICE_PAGES), in siw_tcp_sendpages() 337 msg.msg_flags &= ~MSG_MORE; in siw_tcp_sendpages() 453 rv = siw_tx_ctrl(c_tx, s, MSG_DONTWAIT | MSG_MORE); in siw_tx_hdt() 878 msg_flags = MSG_DONTWAIT | MSG_MORE; in siw_qp_sq_proc_tx()
|
| /linux/net/rxrpc/ |
| H A D | recvmsg.c | 539 msg->msg_flags |= MSG_MORE; in rxrpc_recvmsg() 541 msg->msg_flags &= ~MSG_MORE; in rxrpc_recvmsg()
|
| H A D | rxperf.c | 526 msg.msg_flags = MSG_MORE; in rxperf_process_call()
|
| H A D | sendmsg.c | 330 bool more = msg->msg_flags & MSG_MORE; in rxrpc_send_data()
|
| /linux/fs/afs/ |
| H A D | rxrpc.c | 405 msg.msg_flags = MSG_WAITALL | (call->write_iter ? MSG_MORE : 0); in afs_make_call() 415 msg.msg_flags &= ~MSG_MORE; in afs_make_call()
|
| /linux/tools/perf/trace/beauty/include/linux/ |
| H A D | socket.h | 335 #define MSG_MORE 0x8000 /* Sender will send more */ macro
|
| /linux/tools/testing/selftests/net/ |
| H A D | udpgso.c | 406 if (!__send_one(fd, &msg, MSG_MORE)) in send_one()
|
| H A D | tls.c | 559 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F() 573 /* we don't allow MSG_MORE with non-DATA records */ in TEST_F() 575 MSG_MORE), -1); in TEST_F() 587 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F() 607 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F() 1235 /* MSG_MORE will hold current record open, so later MSG_PEEK in TEST_F() 1239 EXPECT_EQ(send(self->fd, test_str_first, len, MSG_MORE), len); in TEST_F() 1700 EXPECT_EQ(send(self->fd, test_str, send_len, MSG_MORE), send_len); in TEST_F() 3015 ASSERT_EQ(send(cfd, tx, tx_partial, MSG_MORE), tx_partial); in TEST()
|
| H A D | cmsg_sender.c | 541 err = sendmsg(fd, &msg, opt.msg_more ? MSG_MORE : 0); in main()
|
| /linux/net/ceph/ |
| H A D | messenger_v1.c | 67 msg.msg_flags |= MSG_MORE; in ceph_tcp_sendmsg() 495 MSG_MORE); in write_partial_message_data() 532 MSG_MORE); in write_partial_skip()
|
| /linux/drivers/block/drbd/ |
| H A D | drbd_main.c | 623 msg_flags = data ? MSG_MORE : 0; in __send_command() 1580 ? 0 : MSG_MORE); in _drbd_send_bio() 1598 bio_iter_last(bvec, iter) ? 0 : MSG_MORE); in _drbd_send_zc_bio() 1619 page_chain_next(page) ? MSG_MORE : 0); in _drbd_send_zc_ee() 1622 page_chain_next(page) ? MSG_MORE : 0); in _drbd_send_zc_ee()
|
| /linux/fs/ |
| H A D | splice.c | 876 msg.msg_flags |= MSG_MORE; in splice_to_socket() 878 msg.msg_flags |= MSG_MORE; in splice_to_socket()
|
| /linux/net/ipv4/ |
| H A D | tcp_bpf.c | 119 msghdr.msg_flags |= MSG_MORE; in tcp_bpf_push()
|
| H A D | tcp.c | 753 if (!(flags & MSG_MORE) || forced_push(tp)) in tcp_push() 773 if (flags & MSG_MORE) in tcp_push() 1405 tcp_push(sk, flags & ~MSG_MORE, mss_now, in tcp_sendmsg_locked()
|
| /linux/drivers/block/ |
| H A D | nbd.c | 716 (type == NBD_CMD_WRITE) ? MSG_MORE : 0, &sent); in nbd_send_cmd() 748 int flags = is_last ? 0 : MSG_MORE; in nbd_send_cmd()
|
| /linux/net/kcm/ |
| H A D | kcmsock.c | 756 !(msg->msg_flags & MSG_MORE) : !!(msg->msg_flags & MSG_EOR); in kcm_sendmsg()
|