Home
last modified time | relevance | path

Searched refs:send (Results 1 – 25 of 211) sorted by relevance

123456789

/system/bt/gd/rust/hci/src/
Dcontroller.rs28 ($hci:ident.send($builder:expr)) => {{
29 let response = $hci.send($builder).await;
38 assert_success!(hci.send(LeSetEventMaskBuilder { le_event_mask: 0x0000000000021e7f })); in provide_controller()
39 assert_success!(hci.send(SetEventMaskBuilder { event_mask: 0x3dbfffffffffffff })); in provide_controller()
41 hci.send(WriteSimplePairingModeBuilder { simple_pairing_mode: Enable::Enabled }) in provide_controller()
43 assert_success!(hci.send(WriteLeHostSupportBuilder { in provide_controller()
49 assert_success!(hci.send(ReadLocalNameBuilder {})).get_local_name(), in provide_controller()
52 let version_info = assert_success!(hci.send(ReadLocalVersionInformationBuilder {})) in provide_controller()
57 supported: *assert_success!(hci.send(ReadLocalSupportedCommandsBuilder {})) in provide_controller()
63 let buffer_size = assert_success!(hci.send(ReadBufferSizeBuilder {})); in provide_controller()
[all …]
Dlib.rs74 commands.send(ResetBuilder {}).await.get_status() == ErrorCode::Success, in provide_hci()
97 pub async fn send(&mut self, cmd: CommandPacket) -> Result<EventPacket> { in send() method
99 self.cmd_tx.send(QueuedCommand { cmd, fut: tx }).await?; in send()
113 pub async fn send<T: Into<CommandPacket> + CommandExpectations>( in send() method
117 T::_to_response_type(self.raw.send(cmd.into()).await.unwrap()) in send()
186 if let Err(e) = fut.send(evt.into()) { in dispatch()
199 if let Err(e) = fut.send(evt.into()) { in dispatch()
211 if let Err(e) = sender.send(evt).await { in dispatch()
225 if let Err(e) = sender.send(evt).await { in dispatch()
236 if let Err(e) = cmd_tx.send(queued.cmd.clone()).await { in dispatch()
/system/libbase/
Dcmsg_test.cpp44 android::base::Socketpair(Seqpacket() ? SOCK_SEQPACKET : SOCK_STREAM, &send, &recv)); in SetUp()
57 unique_fd send; member
71 ASSERT_EQ(1, SendFileDescriptors(send.get(), "x", 1, fd1.get())); in TEST_P()
83 ASSERT_EQ(2, SendFileDescriptors(send.get(), "ab", 2, fd1.get(), fd2.get())); in TEST_P()
105 ASSERT_EQ(1, SendFileDescriptors(send.get(), "a", 1, fd1.get(), fd2.get())); in TEST_P()
115 ASSERT_EQ(1, SendFileDescriptors(send.get(), "a", 1, fd1.get())); in TEST_P()
132 ASSERT_EQ(1, TEMP_FAILURE_RETRY(write(send.get(), "a", 1))); in TEST_P()
133 ASSERT_EQ(2, SendFileDescriptors(send.get(), "bc", 2, fd1.get())); in TEST_P()
134 ASSERT_EQ(1, SendFileDescriptors(send.get(), "d", 1, fd2.get())); in TEST_P()
153 ASSERT_EQ(1, SendFileDescriptors(send.get(), "a", 1, fd1.get(), fd2.get())); in TEST_P()
[all …]
/system/bt/gd/rust/link/src/acl/classic/
Dmod.rs78 self.requests.send(ConnectionRequest::Disconnect { reason, fut: tx }).await.unwrap(); in disconnect()
103 self.req_tx.send(Request::Connect { addr }).await.unwrap(); in connect()
109 self.req_tx.send(Request::CancelConnect { addr, fut: tx }).await.unwrap(); in cancel_connect()
165 hci.send(build_create_connection(addr)).await; in provide_acl_manager()
173 hci.send(CreateConnectionCancelBuilder { bd_addr: addr }).await; in provide_acl_manager()
175 fut.send(()).unwrap(); in provide_acl_manager()
213 … conn_evt_tx.send(Event::ConnectSuccess(connection)).await.unwrap(); in provide_acl_manager()
215 … _ => conn_evt_tx.send(Event::ConnectFail { addr, reason: status }).await.unwrap(), in provide_acl_manager()
222 hci.send(RejectConnectionRequestBuilder { in provide_acl_manager()
227 hci.send(AcceptConnectionRequestBuilder { in provide_acl_manager()
[all …]
/system/netd/server/
DNFLogListener.cpp61 Status cfgCmdPfUnbind(const SendFn& send) { in cfgCmdPfUnbind() argument
76 return send(makeSlice(msg)); in cfgCmdPfUnbind()
82 Status cfgMode(const SendFn& send, uint16_t nfLogGroup, uint32_t range, uint8_t mode) { in cfgMode() argument
99 return send(makeSlice(msg)); in cfgMode()
103 Status cfgCmdBind(const SendFn& send, uint16_t nfLogGroup) { in cfgCmdBind() argument
119 return send(makeSlice(msg)); in cfgCmdBind()
123 Status cfgCmdUnbind(const SendFn& send, uint16_t nfLogGroup) { in cfgCmdUnbind() argument
139 return send(makeSlice(msg)); in cfgCmdUnbind()
169 const auto sendFn = [this](const Slice msg) { return mListener->send(msg); }; in ~NFLogListener()
181 const auto sendFn = [this](const Slice msg) { return mListener->send(msg); }; in subscribe()
[all …]
/system/bt/gd/l2cap/classic/cert/
Dcert_l2cap.py62 def send(self, packet): member in CertL2capChannel
64 self._acl.send(frame.Serialize())
77 self._acl.send(frame.Serialize())
81 self._acl.send(frame.Serialize())
89 self._control_channel.send(request)
95 self.send(information_request)
109 self._control_channel.send(config_response)
117 self._control_channel.send(config_response)
125 … self._control_channel.send(l2cap_packets.DisconnectionRequestBuilder(1, self._dcid, self._scid))
203 self.control_channel.send(l2cap_packets.ConnectionRequestBuilder(signal_id, psm, scid))
[all …]
Dl2cap_test.py134 dut_channel.send(b'abc')
159 dut_channel.send(b'abc' * 34)
182 dut_channel.send(b'hello')
204 dut_channel.send(b'a' * 48)
329 dut_channel.send(b"a" * 44)
412 self.cert_l2cap.get_control_channel().send(echo_request)
425 self.cert_l2cap.get_control_channel().send(invalid_command_packet)
542 dut_channel.send(b'abc')
556 dut_channel.send(b'abc')
572 dut_channel.send(b'abc')
[all …]
Dl2cap_performance_test.py47 dut_channel.send(b'a' * mtu)
70 dut_channel.send(b'a' * mtu)
84 cert_channel.send(data_packet)
111 dut_channel.send(b'a' * mtu)
176 cert_channel.send(data_packet)
/system/bt/gd/l2cap/le/cert/
Dcert_le_l2cap.py47 def send(self, packet): member in CertLeL2capChannel
49 self._acl.send(frame.Serialize())
54 self._acl.send(frame.Serialize())
59 … self._control_channel.send(l2cap_packets.LeDisconnectionRequestBuilder(1, self._dcid, self._scid))
67 … self._control_channel.send(l2cap_packets.LeFlowControlCreditBuilder(2, self._scid, num_credits))
109 self.control_channel.send(
122 …self.control_channel.send(l2cap_packets.LeCreditBasedConnectionRequestBuilder(1, psm, 0x40, 1000, …
145 self.control_channel.send(reject)
165 self.control_channel.send(response)
180 self.control_channel.send(response)
Dle_l2cap_test.py139 dut_channel.send(b'hello' * 40)
146 cert_channel.send(SAMPLE_PACKET)
174 self.cert_l2cap.get_control_channel().send(
187 self.cert_l2cap.get_control_channel().send(
199 self.cert_l2cap.get_control_channel().send(
210 dut_channel.send(b'hello' * 20 + b'world')
224 dut_channel.send(b'hello' * 40)
232 dut_channel.send(b'hello' * 40)
244 cert_channel.send(SAMPLE_PACKET)
293 self.cert_l2cap.get_control_channel().send(
[all …]
/system/core/init/
Dkeychords_test.cpp56 bool send(struct input_event& e);
57 bool send(uint16_t type, uint16_t code, uint16_t value);
58 bool send(uint16_t code, bool value);
118 bool EventHandler::send(struct input_event& e) { in send() function in android::init::__anon781e2fd10111::EventHandler
123 bool EventHandler::send(uint16_t type, uint16_t code, uint16_t value) { in send() function in android::init::__anon781e2fd10111::EventHandler
125 return send(e); in send()
128 bool EventHandler::send(uint16_t code, bool value) { in send() function in android::init::__anon781e2fd10111::EventHandler
129 return (code < KEY_MAX) && init() && send(EV_KEY, code, value) && send(EV_SYN, SYN_REPORT, 0); in send()
225 EXPECT_TRUE(ev_->send(key, value)); in SetChord()
/system/netd/client/
DNetdClient.cpp142 if (int error = FwmarkClient().send(&command, acceptedSocket, nullptr)) { in netdClientAccept4()
156 error = FwmarkClient().send(&command, sockfd, &connectInfo); in netdClientConnect()
158 error = FwmarkClient().send(&command, sockfd, nullptr); in netdClientConnect()
179 FwmarkClient().send(&command, sockfd, &connectInfo); in netdClientConnect()
212 FwmarkClient().send(&command, sockfd, &sendmmsgInfo); in netdClientSendmmsg()
227 FwmarkClient().send(&command, sockfd, &sendmsgInfo); in netdClientSendmsg()
240 FwmarkClient().send(&command, sockfd, &sendtoInfo); in netdClientSendto()
479 return FwmarkClient().send(&command, socketFd, nullptr); in setNetworkForSocket()
493 return FwmarkClient().send(&command, socketFd, nullptr); in protectFromVpn()
499 return FwmarkClient().send(&command, socketFd, nullptr); in setNetworkForUser()
[all …]
/system/bt/gd/hci/cert/
Dacl_manager_test.py48 dut_acl.send(b'\x29\x00\x07\x00This is just SomeMoreAclData from the DUT')
62 dut_acl.send(b'\x29\x00\x07\x00This is just SomeMoreAclData from the DUT')
78 cert_acl.send(hci_packets.PacketBoundaryFlag.FIRST_AUTOMATICALLY_FLUSHABLE,
83 cert_acl.send(hci_packets.PacketBoundaryFlag.FIRST_AUTOMATICALLY_FLUSHABLE,
97 dut_acl.send(b'\x29\x00\x07\x00This is just SomeMoreAclData from the DUT')
/system/bt/gd/rust/link/src/acl/
Dcore.rs57 self.requests.send(Request::Register { handle, bt, fut: tx }).await.unwrap(); in register()
120 fut.send(Connection { in provide_acl_dispatch()
139 acl.tx.send(p).await.unwrap(); in provide_acl_dispatch()
143 acl.tx.send(p).await.unwrap(); in provide_acl_dispatch()
166 c.close_tx.send(()).unwrap(); in provide_acl_dispatch()
167 c.evt_tx.send(evt.into()).await.unwrap(); in provide_acl_dispatch()
/system/memory/libmemunreachable/tests/
DBinder_test.cpp146 Parcel send; in TEST_F() local
149 send.writeStrongBinder(binder); in TEST_F()
150 status_t rv = service->transact(0, send, &reply); in TEST_F()
/system/security/keystore2/src/
Dasync_task.rs350 trace_sender.send(trace.clone()).unwrap(); in test_async_task()
354 start_sender.send(()).unwrap(); in test_async_task()
369 sender.send(()).unwrap(); in test_async_task_chain()
385 done_sender.send(()).unwrap(); in test_async_task_panic()
396 idle_done_sender.send(()).unwrap(); in test_async_task_idle()
411 done_sender.send(()).unwrap(); in test_async_task_idle()
432 done_sender.send(()).unwrap(); in test_async_task_idle()
457 idle_sender.send(i).unwrap(); in test_async_task_multiple_idle()
488 idle_sender.send(*i).unwrap(); in test_async_task_idle_queues_job()
517 idle_sender.send(()).unwrap(); in test_async_task_idle_panic()
[all …]
/system/bt/gd/rust/hal/src/
Dhidl_hal.rs72 callbacks.as_ref().unwrap().init_tx.send(()).unwrap(); in on_init_complete()
79 Ok(p) => callbacks.as_ref().unwrap().evt_tx.send(p).unwrap(), in on_event()
87 Ok(p) => callbacks.as_ref().unwrap().acl_tx.send(p).unwrap(), in on_acl()
97 Ok(p) => callbacks.as_ref().unwrap().iso_tx.send(p).unwrap(), in on_iso()
Dfacade.rs53 cmd_tx.send(CommandPacket::parse(&data.take_payload()).unwrap()).await.unwrap(); in send_command()
61 acl_tx.send(AclPacket::parse(&data.take_payload()).unwrap()).await.unwrap(); in send_acl()
73 iso_tx.send(IsoPacket::parse(&data.take_payload()).unwrap()).await.unwrap(); in send_iso()
/system/bt/gd/rust/linux/adapter/src/
Dmain.rs39 txl.send(Callbacks::AdapterStateChanged(state)).await; in make_context()
45 txl.send(Callbacks::AdapterPropertiesChanged(status, count, props)).await; in make_context()
51 txl.send(Callbacks::RemoteDevicePropertiesChanged(status, address, count, props)); in make_context()
57 txl.send(Callbacks::DeviceFound(count, props)).await; in make_context()
63 txl.send(Callbacks::DiscoveryStateChanged(state)).await; in make_context()
/system/bt/gd/rust/facade/src/
Dlib.rs132 done.send(()).unwrap(); in create()
139 done.send(()).unwrap(); in create()
150 self.lifecycle_tx.send(LifecycleCommand::Start { req, done: tx }).await?; in start()
157 self.lifecycle_tx.send(LifecycleCommand::Stop { done: tx }).await?; in stop()
/system/sepolicy/prebuilts/api/29.0/public/
Dhal_health.te20 # Allow to wake up to send periodic events
26 # Allow to use timerfd to wake itself up periodically to send health info.
/system/sepolicy/public/
Dhal_health.te20 # Allow to wake up to send periodic events
26 # Allow to use timerfd to wake itself up periodically to send health info.
/system/sepolicy/prebuilts/api/30.0/public/
Dhal_health.te20 # Allow to wake up to send periodic events
26 # Allow to use timerfd to wake itself up periodically to send health info.
/system/sepolicy/prebuilts/api/31.0/public/
Dhal_health.te20 # Allow to wake up to send periodic events
26 # Allow to use timerfd to wake itself up periodically to send health info.
/system/extras/tests/binder/benchmarks/
DbinderAddInts.cpp130 Parcel send, reply; in BM_addInts() local
139 send.writeInt32(val1); in BM_addInts()
140 send.writeInt32(val2); in BM_addInts()
145 send, &reply)) != 0) { in BM_addInts()

123456789