| /external/rust/crates/tokio/tests/ |
| D | udp.rs | 22 let mut recv_buf = [0u8; 32]; in send_recv() localVariable
23 let len = receiver.recv(&mut recv_buf[..]).await?; in send_recv()
25 assert_eq!(&recv_buf[..len], MSG); in send_recv()
39 let mut recv_buf = [0u8; 32]; in send_recv_poll() localVariable
40 let mut read = ReadBuf::new(&mut recv_buf); in send_recv_poll()
55 let mut recv_buf = [0u8; 32]; in send_to_recv_from() localVariable
56 let (len, addr) = receiver.recv_from(&mut recv_buf[..]).await?; in send_to_recv_from()
58 assert_eq!(&recv_buf[..len], MSG); in send_to_recv_from()
71 let mut recv_buf = [0u8; 32]; in send_to_recv_from_poll() localVariable
72 let mut read = ReadBuf::new(&mut recv_buf); in send_to_recv_from_poll()
[all …]
|
| D | uds_datagram.rs | 14 let mut recv_buf = vec![0u8; 1024]; in echo_server() localVariable
16 let (len, peer_addr) = socket.recv_from(&mut recv_buf[..]).await?; in echo_server()
18 socket.send_to(&recv_buf[..len], path).await?; in echo_server()
41 let mut recv_buf = [0u8; 16]; in echo() localVariable
42 let len = socket.recv(&mut recv_buf[..]).await?; in echo()
43 assert_eq!(&recv_buf[..len], b"ECHO"); in echo()
67 let mut recv_buf = [0u8; 16]; in echo_from() localVariable
68 let (len, addr) = socket.recv_from(&mut recv_buf[..]).await?; in echo_from()
69 assert_eq!(&recv_buf[..len], b"ECHO"); in echo_from()
79 let mut recv_buf = [0u8; 16]; in try_send_recv_never_block() localVariable
[all …]
|
| /external/strace/tests-mx32/ |
| D | msg_name.c | 51 TAIL_ALLOC_OBJECT_CONST_PTR(char, recv_buf); in test_msg_name()
53 iov->iov_base = recv_buf; in test_msg_name()
54 iov->iov_len = sizeof(*recv_buf); in test_msg_name()
|
| D | mmsg_name.c | 182 char *const recv_buf = tail_alloc(sizeof(*recv_buf) * IOV_MAX1); in test_mmsg_name() local
187 recv_iov[i].iov_base = &recv_buf[i]; in test_mmsg_name()
188 recv_iov[i].iov_len = sizeof(*recv_buf); in test_mmsg_name()
|
| D | recvfrom.c | 32 #define PREFIX_S_ARGS , recv_buf, 1, 0
37 static char recv_buf[1]; variable
|
| /external/strace/tests/ |
| D | msg_name.c | 51 TAIL_ALLOC_OBJECT_CONST_PTR(char, recv_buf); in test_msg_name()
53 iov->iov_base = recv_buf; in test_msg_name()
54 iov->iov_len = sizeof(*recv_buf); in test_msg_name()
|
| D | mmsg_name.c | 182 char *const recv_buf = tail_alloc(sizeof(*recv_buf) * IOV_MAX1); in test_mmsg_name() local
187 recv_iov[i].iov_base = &recv_buf[i]; in test_mmsg_name()
188 recv_iov[i].iov_len = sizeof(*recv_buf); in test_mmsg_name()
|
| D | recvfrom.c | 32 #define PREFIX_S_ARGS , recv_buf, 1, 0
37 static char recv_buf[1]; variable
|
| /external/strace/tests-m32/ |
| D | msg_name.c | 51 TAIL_ALLOC_OBJECT_CONST_PTR(char, recv_buf); in test_msg_name()
53 iov->iov_base = recv_buf; in test_msg_name()
54 iov->iov_len = sizeof(*recv_buf); in test_msg_name()
|
| D | mmsg_name.c | 182 char *const recv_buf = tail_alloc(sizeof(*recv_buf) * IOV_MAX1); in test_mmsg_name() local
187 recv_iov[i].iov_base = &recv_buf[i]; in test_mmsg_name()
188 recv_iov[i].iov_len = sizeof(*recv_buf); in test_mmsg_name()
|
| D | recvfrom.c | 32 #define PREFIX_S_ARGS , recv_buf, 1, 0
37 static char recv_buf[1]; variable
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | client_callback_end2end_test.cc | 113 ByteBuffer recv_buf; in SendRpcsGeneric() local
124 &cli_ctx, kMethodName, send_buf.get(), &recv_buf, in SendRpcsGeneric()
125 [&request, &recv_buf, &done, &mu, &cv, maybe_except](Status s) { in SendRpcsGeneric()
129 EXPECT_TRUE(ParseFromByteBuffer(&recv_buf, &response)); in SendRpcsGeneric()
|
| /external/ltp/testcases/kernel/syscalls/recvmsg/ |
| D | recvmsg03.c | 92 static char recv_buf[128]; in server() local
111 msg.msg_iov->iov_base = recv_buf; in server()
|
| /external/rust/crates/quiche/src/h3/ |
| D | stream.rs | 789 let mut recv_buf = vec![0; payload.len()]; in request_good() localVariable
791 stream.try_consume_data_for_tests(&mut cursor, &mut recv_buf), in request_good()
794 assert_eq!(payload, recv_buf); in request_good()
882 let mut recv_buf = vec![0; payload.len()]; in push_good() localVariable
884 stream.try_consume_data_for_tests(&mut cursor, &mut recv_buf), in push_good()
887 assert_eq!(payload, recv_buf); in push_good()
|
| D | mod.rs | 2111 let mut recv_buf = vec![0; body.len()]; in request_no_body_response_one_chunk() localVariable
2121 assert_eq!(s.recv_body_client(stream, &mut recv_buf), Ok(body.len())); in request_no_body_response_one_chunk()
2153 let mut recv_buf = vec![0; body.len()]; in request_no_body_response_many_chunks() localVariable
2164 assert_eq!(s.recv_body_client(stream, &mut recv_buf), Ok(body.len())); in request_no_body_response_many_chunks()
2181 let mut recv_buf = vec![0; body.len()]; in request_one_chunk_response_no_body() localVariable
2191 assert_eq!(s.recv_body_server(stream, &mut recv_buf), Ok(body.len())); in request_one_chunk_response_no_body()
2222 let mut recv_buf = vec![0; body.len()]; in request_many_chunks_response_no_body() localVariable
2233 assert_eq!(s.recv_body_server(stream, &mut recv_buf), Ok(body.len())); in request_many_chunks_response_no_body()
2274 let mut recv_buf = vec![0; body.len()]; in many_requests_many_chunks_response_one_chunk() localVariable
2290 assert_eq!(s.recv_body_server(stream, &mut recv_buf), Ok(body.len())); in many_requests_many_chunks_response_one_chunk()
[all …]
|
| /external/tpm2-tss/test/unit/ |
| D | tcti-mssim.c | 213 uint8_t recv_buf[4] = { 0 }; in tcti_socket_init_from_conf() local
234 will_return (__wrap_read, recv_buf); in tcti_socket_init_from_conf()
237 will_return (__wrap_read, recv_buf); in tcti_socket_init_from_conf()
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 841 char recv_buf[sizeof(send_buf)]; in TEST_F() local
857 std::thread th([blocked_thread, &recv_sock, &recv_buf] { in TEST_F()
858 ssize_t rd = PERFETTO_EINTR(read(recv_sock.fd(), recv_buf, 1)); in TEST_F()
864 while (offset < sizeof(recv_buf)) { in TEST_F()
866 read(recv_sock.fd(), recv_buf + offset, sizeof(recv_buf) - offset)); in TEST_F()
892 ASSERT_EQ(memcmp(send_buf, recv_buf, sizeof(send_buf)), 0); in TEST_F()
|
| /external/perfetto/src/profiling/memory/ |
| D | unwinding.cc | 244 char recv_buf[kUnwindBatchSize]; in OnDataAvailable() local
245 self->Receive(recv_buf, sizeof(recv_buf)); in OnDataAvailable()
|
| /external/linux-kselftest/tools/testing/selftests/net/ |
| D | reuseport_bpf.c | 215 char recv_buf[8], send_buf[8]; in test_recv_order() local
217 struct iovec recv_io = { recv_buf, 8 }; in test_recv_order()
264 memcpy(&ndata, recv_buf, sizeof(ndata)); in test_recv_order()
|
| D | tls.c | 185 char recv_buf[10]; in TEST_F() local
194 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
195 EXPECT_EQ(memcmp(test_str, recv_buf, to_send), 0); in TEST_F()
|
| /external/curl/lib/ |
| D | smb.h | 42 char *recv_buf; member
|
| D | smb.c | 258 smbc->recv_buf = malloc(MAX_MESSAGE_SIZE); in smb_connect()
259 if(!smbc->recv_buf) in smb_connect()
290 char *buf = smbc->recv_buf; in smb_recv_message()
936 Curl_safefree(smbc->recv_buf); in smb_disconnect()
|
| /external/rust/crates/quiche/src/ |
| D | lib.rs | 3652 let recv_buf = &crypto_buf[..read]; in process_frame() localVariable
3653 self.handshake.provide_data(level, &recv_buf)?; in process_frame()
|