| /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/bt/gd/rust/hal/src/ |
| D | hidl_hal.rs | 29 init_rx.recv().await.unwrap(); in provide_hidl_hal()
109 Some(cmd) = cmd_rx.recv() => ffi::send_command(&cmd.to_bytes()), in dispatch_outgoing()
110 Some(acl) = acl_rx.recv() => ffi::send_acl(&acl.to_bytes()), in dispatch_outgoing()
111 Some(iso) = iso_rx.recv() => ffi::send_iso(&iso.to_bytes()), in dispatch_outgoing()
|
| D | rootcanal_hal.rs | 143 …Some(cmd) = cmd_rx.recv() => write_with_type(&mut writer, HciPacketType::Command, cmd.to_bytes()).… in dispatch_outgoing()
144 …Some(acl) = acl_rx.recv() => write_with_type(&mut writer, HciPacketType::Acl, acl.to_bytes()).awai… in dispatch_outgoing()
145 …Some(iso) = iso_rx.recv() => write_with_type(&mut writer, HciPacketType::Iso, iso.to_bytes()).awai… in dispatch_outgoing()
|
| D | snoop.rs | 152 Some(cmd) = cmd_down_rx.recv() => { in provide_snooped_hal()
159 Some(acl) = acl_down_rx.recv() => { in provide_snooped_hal()
173 Some(iso) = iso_down_rx.recv() => { in provide_snooped_hal()
200 rx.lock().await.recv().await in consume()
|
| /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()
759 fn register_op_auth_receiver(&self, challenge: i64, recv: TokenReceiver) { in register_op_auth_receiver()
760 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()
440 done_receiver.recv().unwrap(); in test_async_task_idle()
522 idle_receiver.recv().unwrap(); in test_async_task_idle_panic()
530 done_receiver.recv().unwrap(); in test_async_task_idle_panic()
|
| /system/bt/gd/rust/facade/helpers/ |
| D | lib.rs | 43 while let Some(payload) = clone_rx.lock().await.recv().await { in stream_grpc()
64 while let Some(payload) = clone_rx.lock().await.recv().await { in stream_runnable()
|
| /system/bt/gd/hal/ |
| D | hci_hal_host.cc | 399 RUN_NO_INTR(received_size = recv(sock_fd_, buf, kH4HeaderSize, 0)); in incoming_packet_received()
408 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciEvtHeaderSize, 0)); in incoming_packet_received()
415 …payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciEvtHeaderSize, hci_evt_parameter_total_len… in incoming_packet_received()
437 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciAclHeaderSize, 0)); in incoming_packet_received()
443 …RUN_NO_INTR(payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciAclHeaderSize, hci_acl_data_to… in incoming_packet_received()
466 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciScoHeaderSize, 0)); in incoming_packet_received()
472 …RUN_NO_INTR(payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciScoHeaderSize, hci_sco_data_to… in incoming_packet_received()
490 RUN_NO_INTR(received_size = recv(sock_fd_, buf + kH4HeaderSize, kHciIsoHeaderSize, 0)); in incoming_packet_received()
496 …RUN_NO_INTR(payload_size = recv(sock_fd_, buf + kH4HeaderSize + kHciIsoHeaderSize, hci_iso_data_to… in incoming_packet_received()
|
| /system/bt/tools/scripts/ |
| D | btsnoop_live.py | 237 snoop_id = btsnoop_sock.recv(SNOOP_ID)
245 snoop_hdr = btsnoop_sock.recv(SNOOP_HDR)
258 data_frag = btsnoop_sock.recv(olen - len(snoop_data))
|
| /system/libhwbinder/vts/performance/ |
| D | PerfTest.h | 45 recv(val); in wait()
55 int recv(T& v) { in recv() function
|
| /system/logging/logd/ |
| D | logd_test.cpp | 535 content_wrap = recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0) > 0; in timeout_negative()
540 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in timeout_negative()
543 recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in timeout_negative()
650 content_wrap = recv(fd, msg_wrap.buf, sizeof(msg_wrap), 0) > 0; in TEST()
655 content_timeout = recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in TEST()
658 recv(fd, msg_timeout.buf, sizeof(msg_timeout), 0) > 0; in TEST()
756 bool read_one = recv(fd, msg.buf, sizeof(msg), 0) > 0; in TEST()
769 recv_ret = recv(fd, msg.buf, sizeof(msg), 0); in TEST()
|
| /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/bt/gd/rust/link/src/acl/ |
| D | core.rs | 92 Some(req) = req_rx.recv() => { in provide_acl_dispatch()
146 Some(evt) = evt_rx.recv() => { in provide_acl_dispatch()
181 rx.lock().await.recv().await in consume()
|
| /system/bt/gd/rust/link/src/acl/classic/ |
| D | mod.rs | 156 Some(req) = req_rx.recv() => { in provide_acl_manager()
179 Some(evt) = evt_rx.recv() => { in provide_acl_manager()
275 Some(evt) = core.evt_rx.recv() => { in run_connection()
286 Some(req) = req_rx.recv() => { in run_connection()
|
| /system/netd/client/ |
| D | FwmarkClient.cpp | 120 if (TEMP_FAILURE_RETRY(recv(mChannel, &error, sizeof(error), 0)) == -1) { in send()
|
| /system/bt/gd/rust/shim/src/ |
| D | message_loop_thread.rs | 45 while let Some(c) = rx.recv().await { in main_message_loop_thread_create()
|
| /system/bt/gd/rust/linux/stack/src/ |
| D | lib.rs | 75 let m = rx.recv().await; in dispatch()
|
| /system/bt/btif/src/ |
| D | btif_sock_util.cc | 70 OSI_NO_INTR(ret = recv(sock_fd, buf, r, MSG_WAITALL)); in sock_recv_all()
|
| /system/core/debuggerd/client/ |
| D | debuggerd_client.cpp | 209 rc = TEMP_FAILURE_RETRY(recv(set_timeout(sockfd.get()), &response, sizeof(response), MSG_TRUNC)); in debuggerd_trigger_dump()
234 rc = TEMP_FAILURE_RETRY(recv(set_timeout(sockfd.get()), &response, sizeof(response), MSG_TRUNC)); in debuggerd_trigger_dump()
|
| /system/bt/gd/rust/hci/src/ |
| D | lib.rs | 235 Some(queued) = cmd_rx.recv(), if pending.is_none() => { in dispatch()
249 evt_rx.lock().await.recv().await in consume()
|
| /system/bt/vendor_libs/test_vendor_lib/scripts/ |
| D | simple_stack.py | 125 return self._socket.recv(size)
|
| D | link_layer_socket.py | 95 more_raw_bytes = self._socket.recv(min(size - len(raw_bytes), 2048))
|
| D | simple_link_layer_socket.py | 92 return self._socket.recv(size)
|