| /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 | 121 pub fn recv(&mut self) -> T { in recv() method
182 pub fn recv(&mut self) -> M { in recv() method
183 self.response_reader.recv() in recv()
196 self.result_reader.recv() in get_result()
321 reader.recv() in run_as()
430 let ping: PingPong = cmd_reader.recv(); in test_run_as_child()
435 let ping: PingPong = cmd_reader.recv(); in test_run_as_child()
437 let pong: PingPong = cmd_reader.recv(); in test_run_as_child()
452 let pong = child_handle.recv(); in test_run_as_child()
460 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/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/security/keystore2/src/ |
| D | enforcements.rs | 103 AuthRequestState::TimeStampedOpAuth(recv) | AuthRequestState::TimeStamp(recv) => { in get_auth_tokens()
104 let result = recv in get_auth_tokens()
107 .recv() in get_auth_tokens()
184 let recv = { in add_auth_token() localVariable
192 if let Some((_, recv)) = recv { in add_auth_token()
193 recv.add_auth_token(hat); in add_auth_token()
197 pub fn add_receiver(&self, challenge: i64, recv: TokenReceiver) { in add_receiver()
200 map.insert(challenge, recv); in add_receiver()
778 fn register_op_auth_receiver(&self, challenge: i64, recv: TokenReceiver) { in register_op_auth_receiver()
779 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/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 | 101 ch.recv(); in keystore2_backend_busy_test()
135 ch.recv(); in keystore2_forced_op_after_backendbusy_test()
229 first_op_handle.recv(); in keystore2_max_forced_ops_test()
239 ch.recv(); in keystore2_max_forced_ops_test()
312 child_handle.recv(); in keystore2_ops_prune_test()
|
| /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 | 103 Some(cmd) = out_cmd_rx.recv() => write_nci(&mut writer, cmd).await?, in dispatch_outgoing()
104 Some(data) = out_data_rx.recv() => write_nci(&mut writer, data).await?, in dispatch_outgoing()
|
| D | hidl_hal.rs | 163 Some(cmd) = out_cmd_rx.recv() => ffi::send_command(&cmd.encode_to_bytes().unwrap()), in dispatch_outgoing()
164 Some(data) = out_data_rx.recv() => ffi::send_command(&data.encode_to_bytes().unwrap()), in dispatch_outgoing()
|
| /system/core/trusty/secretkeeper/src/ |
| D | hal_main.rs | 76 channel.recv(&mut rsp_frag).map_err(|e| binderr("receive response", e))?; in execute()
85 channel.recv(&mut rsp_frag).map_err(|e| binderr("receive response", e))?; in execute()
|
| /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/server_configurable_flags/aconfigd/ |
| D | aconfigd_main.cpp | 61 TEMP_FAILURE_RETRY(recv(client_fd, size_buffer + size_bytes_received, in receiveMessage()
76 recv(client_fd, payload_buffer + payload_bytes_received, in receiveMessage()
|
| D | aconfigd_socket_test.cpp | 94 num_bytes = TEMP_FAILURE_RETRY(recv(*sock_fd, bytes, 4, 0)); in send_message()
105 recv(*sock_fd, buffer + payload_bytes_received, in send_message()
|
| /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 | 157 pub fn recv(&mut self, buf: &mut Vec<u8>) -> Result<()> { in recv() method
|
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 331 Some(cmd) = hc.in_cmd_rx.recv() => { in dispatch()
370 qc = cmd_rx.recv(), if pending.is_none() => if let Some(queued) = qc { in dispatch()
388 Some(data) = hc.in_data_rx.recv() => lcons.send_callback(data).await, in dispatch()
|
| /system/nfc/tools/casimir/src/ |
| D | main.rs | 173 .recv() in rf()
331 result = rf_rx.recv() => { in run()
|
| /system/core/fs_mgr/libsnapshot/snapuserd/user-space-merge/ |
| D | snapuserd_server.cpp | 104 ssize_t rv = TEMP_FAILURE_RETRY(recv(fd.get(), msg, sizeof(msg), 0)); in Recv()
468 if (recv(client_fd, code, sizeof(code), 0) < 0) { in RunForSocketHandoff()
|
| /system/core/trusty/keymint/src/ |
| D | keymint_hal_main.rs | 64 self.0.recv(&mut recv_buf).map_err(|e| { in execute()
|
| /system/netd/tests/ |
| D | tun_interface.cpp | 164 ssize_t len = recv(s, buf, sizeof(buf), 0); in addAddress()
|
| /system/netd/server/ |
| D | NetlinkCommands.cpp | 53 int ret = recv(sock, &response, sizeof(response), 0); in recvNetlinkAck()
|