| /system/libbase/ |
| D | cmsg_test.cpp | 44 android::base::Socketpair(Seqpacket() ? SOCK_SEQPACKET : SOCK_STREAM, &send, &recv)); in SetUp()
58 unique_fd recv; member
75 ASSERT_EQ(1, ReceiveFileDescriptors(recv.get(), buf, 2, &received)); in TEST_P()
88 ssize_t rc = ReceiveFileDescriptors(recv.get(), buf, 1, &received1, &received2); in TEST_P()
100 ASSERT_EQ(1, read(recv.get(), buf, 2)); in TEST_P()
109 ASSERT_EQ(-1, ReceiveFileDescriptors(recv.get(), buf, 1, &received)); in TEST_P()
118 ASSERT_EQ(1, ::recv(recv.get(), buf, sizeof(buf), MSG_PEEK)); in TEST_P()
122 ASSERT_EQ(1, ReceiveFileDescriptors(recv.get(), buf, 1, &received)); in TEST_P()
136 ASSERT_EQ(2, TEMP_FAILURE_RETRY(read(recv.get(), buf, 2))); in TEST_P()
140 ssize_t rc = ReceiveFileDescriptorVector(recv.get(), buf, 1, 1, &received1); in TEST_P()
[all …]
|
| /system/security/keystore2/test_utils/ |
| D | run_as.rs | 132 pub fn recv(&mut self) -> T { in recv() method
193 pub fn recv(&mut self) -> M { in recv() method
194 self.response_reader.recv() in recv()
207 self.result_reader.recv() in get_result()
328 reader.recv() in run_as()
437 let ping: PingPong = cmd_reader.recv(); in test_run_as_child()
442 let ping: PingPong = cmd_reader.recv(); in test_run_as_child()
444 let pong: PingPong = cmd_reader.recv(); in test_run_as_child()
459 let pong = child_handle.recv(); in test_run_as_child()
467 let pong = child_handle.recv(); in test_run_as_child()
[all …]
|
| /system/core/libcutils/ |
| D | sockets_test.cpp | 49 EXPECT_EQ(3, recv(server, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
60 EXPECT_EQ(3, recv(client, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
69 EXPECT_EQ(11, recv(server, buffer, sizeof(buffer), 0)); in TestConnectedSockets()
|
| /system/security/keystore2/src/ |
| D | enforcements.rs | 102 AuthRequestState::TimeStampedOpAuth(recv) | AuthRequestState::TimeStamp(recv) => { in get_auth_tokens()
103 let result = recv.recv().context("In get_auth_tokens: Sender disconnected.")?; in get_auth_tokens()
179 let recv = { in add_auth_token() localVariable
187 if let Some((_, recv)) = recv { in add_auth_token()
188 recv.add_auth_token(hat); in add_auth_token()
192 pub fn add_receiver(&self, challenge: i64, recv: TokenReceiver) { in add_receiver()
195 map.insert(challenge, recv); in add_receiver()
745 fn register_op_auth_receiver(&self, challenge: i64, recv: TokenReceiver) { in register_op_auth_receiver()
746 self.op_auth_map.add_receiver(challenge, recv); in register_op_auth_receiver()
|
| D | async_task.rs | 327 start_receiver.recv().unwrap(); in test_async_task()
355 let trace = trace_receiver.recv().unwrap(); in test_async_task()
372 receiver.recv().unwrap(); in test_async_task_chain()
387 done_receiver.recv().unwrap(); in test_async_task_panic()
419 done_receiver.recv().unwrap(); in test_async_task_idle()
442 done_receiver.recv().unwrap(); in test_async_task_idle()
524 idle_receiver.recv().unwrap(); in test_async_task_idle_panic()
532 done_receiver.recv().unwrap(); in test_async_task_idle_panic()
|
| /system/core/trusty/libtrusty-rs/tests/ |
| D | test.rs | 64 connection.recv(&mut recv_buf).unwrap(); in recv_empty_vec()
82 connection.recv(&mut recv_buf).unwrap(); in recv_vec_existing_capacity()
|
| /system/logging/logd/ |
| D | logd_test.cpp | 251 content_wrap = TEMP_FAILURE_RETRY(recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0)) > 0; in timeout_negative()
256 content_timeout = TEMP_FAILURE_RETRY(recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0)) > 0; in timeout_negative()
259 TEMP_FAILURE_RETRY(recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0)) > 0; in timeout_negative()
356 content_wrap = TEMP_FAILURE_RETRY(recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0)) > 0; in TEST()
361 content_timeout = TEMP_FAILURE_RETRY(recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0)) > 0; in TEST()
364 TEMP_FAILURE_RETRY(recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0)) > 0; in TEST()
455 bool read_one = TEMP_FAILURE_RETRY(recv(fd, msg.buf, sizeof(msg), 0)) > 0; in TEST()
467 recv_ret = TEMP_FAILURE_RETRY(recv(fd, msg.buf, sizeof(msg), 0)); in TEST()
|
| /system/security/keystore2/tests/ |
| D | keystore2_client_operation_tests.rs | 95 ch.recv(); in keystore2_backend_busy_test()
128 ch.recv(); in keystore2_forced_op_after_backendbusy_test()
218 first_op_handle.recv(); in keystore2_max_forced_ops_test()
227 ch.recv(); in keystore2_max_forced_ops_test()
297 child_handle.recv(); in keystore2_ops_prune_test()
|
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 174 Some(cmd) = hc.in_cmd_rx.recv() => { in dispatch()
203 qc = cmd_rx.recv(), if pending.is_none() => if let Some(queued) = qc { in dispatch()
221 Some(data) = hc.in_data_rx.recv() => ic.in_data_int.send(data).await.unwrap(), in dispatch()
222 Some(data) = ic.out_data_int.recv() => hc.out_data_tx.send(data).unwrap(), in dispatch()
|
| /system/libhwbinder/vts/performance/ |
| D | PerfTest.h | 45 recv(val); in wait()
55 int recv(T& v) { in recv() function
|
| D | Benchmark_throughput.cpp | 84 template<typename T> void recv(T& v) { in recv() function in Pipe
387 worker_pipes[i].recv(tmp_results); in main()
|
| /system/nfc/src/rust/hal/ |
| D | rootcanal_hal.rs | 102 Some(cmd) = out_cmd_rx.recv() => write_nci(&mut writer, cmd).await?, in dispatch_outgoing()
103 Some(data) = out_data_rx.recv() => write_nci(&mut writer, data).await?, in dispatch_outgoing()
|
| D | hidl_hal.rs | 164 Some(cmd) = out_cmd_rx.recv() => ffi::send_command(&cmd.to_bytes()), in dispatch_outgoing()
165 Some(data) = out_data_rx.recv() => ffi::send_command(&data.to_bytes()), in dispatch_outgoing()
|
| /system/core/init/ |
| D | proto_utils.h | 33 auto result = TEMP_FAILURE_RETRY(recv(socket, buffer, sizeof(buffer), 0)); in ReadMessage()
|
| D | property_service_test.cpp | 56 TEMP_FAILURE_RETRY(recv(fd, &result, sizeof(result), MSG_WAITALL))); in TEST()
|
| /system/netd/client/ |
| D | FwmarkClient.cpp | 118 if (TEMP_FAILURE_RETRY(recv(mChannel, &error, sizeof(error), 0)) == -1) { in send()
|
| /system/core/trusty/libtrusty-rs/src/ |
| D | lib.rs | 155 pub fn recv(&mut self, buf: &mut Vec<u8>) -> Result<()> { in recv() method
|
| /system/core/trusty/keymint/src/ |
| D | keymint_hal_main.rs | 64 self.0.recv(&mut recv_buf).map_err(|e| { in execute()
|
| /system/netd/server/ |
| D | NetlinkCommands.cpp | 52 int ret = recv(sock, &response, sizeof(response), 0); in recvNetlinkAck()
|
| /system/netd/tests/ |
| D | tun_interface.cpp | 164 ssize_t len = recv(s, buf, sizeof(buf), 0); in addAddress()
|
| /system/core/fs_mgr/libsnapshot/snapuserd/dm-snapshot-merge/ |
| D | snapuserd_server.cpp | 112 ssize_t rv = TEMP_FAILURE_RETRY(recv(fd.get(), msg, sizeof(msg), 0)); in Recv()
552 if (recv(client_fd, code, sizeof(code), 0) < 0) { in RunForSocketHandoff()
|
| /system/chre/host/common/ |
| D | socket_client.cc | 177 ssize_t bytesReceived = recv(mSockFd, buffer, sizeof(buffer), 0); in receiveThread()
|
| D | socket_server.cc | 171 recv(clientSocket, mRecvBuffer.data(), mRecvBuffer.size(), MSG_DONTWAIT); in handleClientData()
|
| /system/sepolicy/prebuilts/api/29.0/private/ |
| D | access_vectors | 469 recv
503 recv
|
| /system/sepolicy/prebuilts/api/30.0/private/ |
| D | access_vectors | 450 recv
482 recv
|