Home
last modified time | relevance | path

Searched refs:recv (Results 1 – 25 of 63) sorted by relevance

123

/packages/modules/Bluetooth/system/rust/tests/
Dgatt_server_test.rs101 let (tcb_idx, resp) = transport_rx.recv().await.unwrap(); in test_service_read()
131 let (_, resp) = transport_rx.recv().await.unwrap(); in test_server_closed_while_connected()
164 ) = data_rx.recv().await.unwrap() in test_characteristic_read()
171 let (tcb_idx, resp) = transport_rx.recv().await.unwrap(); in test_characteristic_read()
198 ) = data_rx.recv().await.unwrap() in test_characteristic_write()
205 let (tcb_idx, resp) = transport_rx.recv().await.unwrap(); in test_characteristic_write()
226 let (tcb_idx, resp) = transport_rx.recv().await.unwrap(); in test_send_indication()
260 transport_rx.recv().await.unwrap(); in test_send_indication_and_disconnect()
290 ) = data_rx.recv().await.unwrap() in test_write_to_descriptor()
297 let (tcb_idx, resp) = transport_rx.recv().await.unwrap(); in test_write_to_descriptor()
[all …]
Dgatt_callbacks_test.rs38 match events_rx.recv().await.unwrap() { in pull_trans_id()
62 callbacks_rx.recv().await.unwrap() in test_read_characteristic_callback()
249 ) = callbacks_rx.recv().await.unwrap() in test_write_characteristic_callback()
376 ) = callbacks_rx.recv().await.unwrap() in test_write_no_response_callback()
400 callbacks_rx.recv().await.unwrap() in test_execute_characteristic_callback()
/packages/modules/Bluetooth/system/rust/src/gatt/server/
Datt_server_bearer.rs268 assert_eq!(rx.recv().await.unwrap().opcode, att::AttOpcode::ReadResponse); in test_single_transaction()
280 assert_eq!(rx.recv().await.unwrap().opcode, att::AttOpcode::ErrorResponse); in test_sequential_transactions()
286 assert_eq!(rx.recv().await.unwrap().opcode, att::AttOpcode::ReadResponse); in test_sequential_transactions()
342 ) = data_rx.recv().await.unwrap() in test_concurrent_transaction_failure()
350 let resp = rx.recv().await.unwrap(); in test_concurrent_transaction_failure()
368 assert_eq!(rx.recv().await.unwrap().opcode, att::AttOpcode::HandleValueIndication); in test_indication_confirmation()
388 let sent1 = rx.recv().await.unwrap(); in test_sequential_indications()
395 let sent2 = rx.recv().await.unwrap(); in test_sequential_indications()
421 assert_eq!(rx.recv().await.unwrap().opcode, att::AttOpcode::HandleValueIndication); in test_queued_indications_only_one_sent()
441 let sent1 = rx.recv().await.unwrap(); in test_queued_indications_dequeue_second()
[all …]
Dgatt_database.rs807 ) = data_evts.recv().await.unwrap() in test_single_characteristic_value()
936 ) = data_evts.recv().await.unwrap() in test_write_single_characteristic_callback_invoked()
975 data_evts.recv().await.unwrap() in test_write_single_characteristic_recv_response()
1054 ) = data_evts.recv().await.unwrap() in test_single_descriptor_declaration()
1107 ) = data_evts.recv().await.unwrap() in test_write_descriptor()
1238 ) = data_evts_2.recv().await.unwrap() in test_multiple_datastores()
/packages/modules/Bluetooth/system/rust/src/gatt/server/services/
Dgatt.rs356 let resp = rx.recv().await.unwrap(); in test_single_registered_service_change_indication()
400 let resp1 = rx1.recv().await.unwrap(); in test_multiple_registered_service_change_indication()
401 let resp2 = rx2.recv().await.unwrap(); in test_multiple_registered_service_change_indication()
438 let resp1 = rx1.recv().await.unwrap(); in test_one_unregistered_service_change_indication()
441 assert!(try_await(async move { rx2.recv().await }).await.is_err()); in test_one_unregistered_service_change_indication()
480 let resp1 = rx1.recv().await.unwrap(); in test_one_disconnected_service_change_indication()
483 assert!(rx2.recv().await.is_none()); in test_one_disconnected_service_change_indication()
/packages/modules/Virtualization/guest/rialto/src/
Dcommunication.rs102 fn recv(&mut self, buffer: &mut [u8]) -> virtio_drivers::Result<usize> { in recv() method
104 self.connection_manager.recv(self.peer_addr, self.peer_addr.port, buffer)?; in recv()
177 let len = self.recv(&mut data[start..])?; in read_exact()
180 self.recv(&mut data[start..])? in read_exact()
/packages/modules/Bluetooth/system/gd/hal/
Dsnoop_logger_socket_thread_test.cc190 recv(socket_fd, recv_buf1, sizeof(recv_buf1), 0); in TEST_F()
191 return recv(socket_fd, recv_buf2, sizeof(recv_buf2), MSG_DONTWAIT); in TEST_F()
226 return recv(socket_fd, recv_buf, sizeof(SnoopLoggerCommon::FileHeaderType), 0); in TEST_F()
268 recv(socket_fd, recv_buf1, sizeof(recv_buf1), 0); in TEST_F()
269 return recv(socket_fd, recv_buf2, sizeof(recv_buf2), 0); in TEST_F()
Dsnoop_logger_test.cc1176 recv(socket_fd, recv_buf1, sizeof(recv_buf1), 0); in TEST_F()
1177 recv(socket_fd, recv_buf2, sizeof(recv_buf2), 0); in TEST_F()
1178 return recv(socket_fd, recv_buf3, sizeof(recv_buf3), 0); in TEST_F()
1232 recv(socket_fd, recv_buf1, sizeof(recv_buf1), 0); in TEST_F()
1233 recv(socket_fd, recv_buf2, sizeof(recv_buf2), 0); in TEST_F()
1234 return recv(socket_fd, recv_buf3, sizeof(recv_buf3), 0); in TEST_F()
1381 recv(socket_fd, recv_buf1, sizeof(recv_buf1), 0); in TEST_F()
1382 recv(socket_fd, recv_buf2, sizeof(recv_buf2), 0); in TEST_F()
1383 return recv(socket_fd, recv_buf3, sizeof(recv_buf3), 0); in TEST_F()
Dsyscall_wrapper_impl.cc53 int ret = recv(fd, buf, n, flags); in Recv()
Dhci_hal_host_rootcanal.cc249 RUN_NO_INTR(ret = recv(sock_fd_, buf, bufferLen, 0)); in socketRecvAll()
270 RUN_NO_INTR(received_size = recv(sock_fd_, buf, kH4HeaderSize, 0)); in incoming_packet_received()
/packages/modules/Bluetooth/system/tools/scripts/
Dbtsnoop_live.py237 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))
/packages/modules/Bluetooth/tools/rootcanal/test/
Dposix_socket_unittest.cc176 int recv = sock2->Recv(buffer, buflen); in TEST_F() local
177 if (recv > 0) { in TEST_F()
178 buflen -= recv; in TEST_F()
179 buffer += recv; in TEST_F()
/packages/modules/Bluetooth/system/rust/src/gatt/
Dcallbacks.rs239 let resp = rx.recv().await.unwrap(); in test_regular_read_invoke()
266 let resp = rx.recv().await.unwrap(); in test_regular_read_response()
315 let resp = rx.recv().await.unwrap(); in test_write_request_invoke()
349 let resp = rx.recv().await.unwrap(); in test_write_request_response()
/packages/modules/adb/libs/adbconnection/
Dadbconnection_server.cpp39 ssize_t rc = TEMP_FAILURE_RETRY(recv(socket, proto.data(), proto.length(), MSG_PEEK)); in readProcessInfoFromSocket()
53 rc = TEMP_FAILURE_RETRY(recv(socket, proto.data(), message_size, 0)); in readProcessInfoFromSocket()
/packages/modules/Nfc/libnfc-nci/src/rust/hal/
Drootcanal_hal.rs103 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()
Dhidl_hal.rs163 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()
/packages/modules/DnsResolver/doh/connection/
Ddriver.rs295 … self.quiche_conn.recv(&mut self.buffer[..size], quiche::RecvInfo { from, to: local })?; in drive_once()
366 …msg = self.driver.request_rx.recv(), if !self.driver.closing && self.buffered_request.is_none() =>… in drive_once()
380 …self.driver.quiche_conn.recv(&mut self.driver.buffer[..size], quiche::RecvInfo { from, to: local }… in drive_once()
563 while self.driver.request_rx.recv().await.is_some() {} in shutdown()
/packages/services/Car/tools/emulator/
Dvhal_emulator.py156 b = self.sock.recv(4)
161 b = self.sock.recv(msgLen)
/packages/modules/Nfc/libnfc-nci/src/rust/nci/
Dnci.rs331 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()
/packages/modules/Bluetooth/system/btif/src/
Dbtif_sock_util.cc67 OSI_NO_INTR(ret = recv(sock_fd, buf, r, MSG_WAITALL)); in sock_recv_all()
/packages/modules/adb/
Dsysdeps_unix.cpp122 upper_bound_bytes = recv(fd.get(), nullptr, 0, MSG_PEEK | MSG_TRUNC); in network_peek()
/packages/modules/Bluetooth/tools/rootcanal/net/posix/
Dposix_async_socket.cc108 if (recv(fd_, &buf, 1, MSG_PEEK | MSG_DONTWAIT) != 1) { in Connected()
/packages/modules/Nfc/libnfc-nci/tools/casimir/src/
Dmain.rs174 .recv() in rf()
400 result = rf_rx.recv() => { in run()
/packages/modules/Bluetooth/tools/rootcanal/scripts/
Dsimple_stack.py125 return self._socket.recv(size)
Dlink_layer_socket.py95 more_raw_bytes = self._socket.recv(min(size - len(raw_bytes), 2048))

123