| /packages/modules/Bluetooth/tools/rootcanal/model/controller/ |
| D | dual_mode_controller.cc | 322 void DualModeController::SniffSubrating(CommandView command) { in DualModeController() argument
325 gd_hci::AclCommandView::Create(command))); in DualModeController()
489 void DualModeController::Reset(CommandView command) { in DualModeController() argument
490 auto command_view = gd_hci::ResetView::Create(command); in DualModeController()
501 void DualModeController::ReadBufferSize(CommandView command) { in DualModeController() argument
502 auto command_view = gd_hci::ReadBufferSizeView::Create(command); in DualModeController()
512 void DualModeController::ReadEncryptionKeySize(CommandView command) { in DualModeController() argument
514 gd_hci::SecurityCommandView::Create(command)); in DualModeController()
523 void DualModeController::HostBufferSize(CommandView command) { in DualModeController() argument
524 auto command_view = gd_hci::HostBufferSizeView::Create(command); in DualModeController()
[all …]
|
| /packages/services/Car/cpp/computepipe/tests/runner/client_interface/ |
| D | ClientInterfaceTest.cc | 134 proto::ConfigurationCommand command; in TEST_F() local
139 .WillRepeatedly(DoAll(SaveArg<0>(&command), Return(Status::SUCCESS))); in TEST_F()
148 EXPECT_EQ(command.has_set_input_source(), true); in TEST_F()
149 EXPECT_EQ(command.set_input_source().source_id(), 1); in TEST_F()
153 EXPECT_EQ(command.has_set_offload_offload(), true); in TEST_F()
154 EXPECT_EQ(command.set_offload_offload().offload_option_id(), 5); in TEST_F()
158 EXPECT_EQ(command.has_set_termination_option(), true); in TEST_F()
159 EXPECT_EQ(command.set_termination_option().termination_option_id(), 3); in TEST_F()
164 EXPECT_EQ(command.has_set_output_stream(), true); in TEST_F()
165 EXPECT_EQ(command.set_output_stream().stream_id(), 0); in TEST_F()
[all …]
|
| /packages/modules/Media/apex/framework/java/android/media/ |
| D | Session2CommandGroup.java | 75 for (Parcelable command : commands) { in Session2CommandGroup()
76 mCommands.add((Session2Command) command); in Session2CommandGroup()
86 public boolean hasCommand(@NonNull Session2Command command) { in hasCommand() argument
87 if (command == null) { in hasCommand()
90 return mCommands.contains(command); in hasCommand()
103 for (Session2Command command : mCommands) { in hasCommand()
104 if (command.getCommandCode() == commandCode) { in hasCommand()
165 public Builder addCommand(@NonNull Session2Command command) { in addCommand() argument
166 if (command == null) { in addCommand()
169 mCommands.add(command); in addCommand()
[all …]
|
| /packages/apps/SecureElement/src/com/android/se/ |
| D | Channel.java | 115 public byte[] transmit(byte[] command) throws IOException { in transmit() argument
119 if (command == null) { in transmit()
130 CommandApduValidator.execute(command); in transmit()
132 if (((command[0] & (byte) 0x80) == 0) in transmit()
133 && ((command[0] & (byte) 0x60) != (byte) 0x20)) { in transmit()
135 if (command[1] == (byte) 0x70) { in transmit()
138 if ((command[1] == (byte) 0xA4) && (command[2] == (byte) 0x04)) { in transmit()
147 checkCommand(command); in transmit()
150 command[0] = setChannelToClassByte(command[0], mChannelNumber); in transmit()
151 return mTerminal.transmit(command); in transmit()
[all …]
|
| /packages/modules/Bluetooth/system/gd/hci/ |
| D | le_address_manager.cc | 243 void LeAddressManager::push_command(Command command) { in push_command() argument
245 cached_commands_.push(std::move(command)); in push_command()
300 Command command = {CommandType::ROTATE_RANDOM_ADDRESS, RotateRandomAddressCommand{}}; in prepare_to_rotate() local
301 cached_commands_.push(std::move(command)); in prepare_to_rotate()
341 Command command = {CommandType::UPDATE_IRK, update_irk_command}; in prepare_to_update_irk() local
342 cached_commands_.push(std::move(command)); in prepare_to_update_irk()
350 void LeAddressManager::update_irk(UpdateIRKCommand command) { in update_irk() argument
351 rotation_irk_ = command.rotation_irk; in update_irk()
352 minimum_rotation_time_ = command.minimum_rotation_time; in update_irk()
353 maximum_rotation_time_ = command.maximum_rotation_time; in update_irk()
[all …]
|
| D | controller_test.cc | 72 std::unique_ptr<CommandBuilder> command, in EnqueueCommand() argument
74 …->Post(common::BindOnce(&TestHciLayer::HandleCommand, common::Unretained(this), std::move(command), in EnqueueCommand()
79 std::unique_ptr<CommandBuilder> command, in EnqueueCommand() argument
88 CommandView command = CommandView::Create(packet_view); in HandleCommand() local
89 ASSERT_TRUE(command.IsValid()); in HandleCommand()
93 switch (command.GetOpCode()) { in HandleCommand()
120 ReadLocalExtendedFeaturesView read_command = ReadLocalExtendedFeaturesView::Create(command); in HandleCommand()
187 auto view = SetEventMaskView::Create(command); in HandleCommand()
193 auto view = LeSetEventMaskView::Create(command); in HandleCommand()
200 auto view = LeRandView::Create(LeSecurityCommandView::Create(command)); in HandleCommand()
[all …]
|
| D | acl_manager_unittest.cc | 133 std::unique_ptr<CommandBuilder> command, in EnqueueCommand() argument
135 command_queue_.push(std::move(command)); in EnqueueCommand()
141 std::unique_ptr<CommandBuilder> command, in EnqueueCommand() argument
143 command_queue_.push(std::move(command)); in EnqueueCommand()
177 ConnectionManagementCommandView command = in GetCommand() local
180 return command; in GetCommand()
196 ConnectionManagementCommandView command = in GetLastCommand() local
199 return command; in GetLastCommand()
209 ConnectionManagementCommandView command = in GetLastOutgoingCommand() local
211 return command; in GetLastOutgoingCommand()
[all …]
|
| /packages/modules/Virtualization/virtualizationservice/src/ |
| D | crosvm.rs | 298 let mut command = Command::new(CROSVM_PATH); in run_vm() localVariable
300 command in run_vm()
308 command.arg("--protected-vm"); in run_vm()
315 command.arg("--swiotlb").arg(swiotlb_size_mib.to_string()); in run_vm()
319 command.arg("--mem").arg(memory_mib.to_string()); in run_vm()
323 command.arg("--cpus").arg(cpus.to_string()); in run_vm()
327 command.arg("--cpu-affinity").arg(cpu_affinity); in run_vm()
331 command.arg("--task-profiles").arg(config.task_profiles.join(",")); in run_vm()
355 command.arg(format!("--serial={},hardware=serial,num=1", &console_arg)); in run_vm()
357 command.arg(format!("--serial=type=file,path={},hardware=serial,num=2", &failure_serial_path)); in run_vm()
[all …]
|
| /packages/modules/Bluetooth/tools/rootcanal/lmp/src/ |
| D | packets.rs | 5 pub fn command_remote_device_address(command: &CommandPacket) -> Option<Address> { in command_remote_device_address()
10 match command.specialize() { in command_remote_device_address()
11 CommandChild::SecurityCommand(command) => match command.specialize() { in command_remote_device_address()
31 pub fn command_connection_handle(command: &CommandPacket) -> Option<u16> { in command_connection_handle()
36 match command.specialize() { in command_connection_handle()
37 CommandChild::AclCommand(command) => match command.specialize() { in command_connection_handle()
38 AclCommandChild::ConnectionManagementCommand(command) => { in command_connection_handle()
39 match command.specialize() { in command_connection_handle()
|
| D | manager.rs | 47 fn ingest_hci(&self, command: hci::CommandPacket) { in ingest_hci()
48 assert!(self.hci.replace(Some(command)).is_none(), "HCI flow control violation"); in ingest_hci()
52 let command = self.hci.take(); in poll_hci_command() localVariable
54 if let Some(command) = command.clone().and_then(|c| c.try_into().ok()) { in poll_hci_command()
55 Poll::Ready(command) in poll_hci_command()
57 self.hci.set(command); in poll_hci_command()
120 pub fn ingest_hci(&self, command: hci::CommandPacket) -> Result<(), LinkManagerError> { in ingest_hci()
122 let peer = hci::command_connection_handle(&command) in ingest_hci()
124 .or_else(|| hci::command_remote_device_address(&command)); in ingest_hci()
128 link.ingest_hci(command); in ingest_hci()
|
| /packages/modules/Bluetooth/system/gd/hci/acl_manager/ |
| D | le_impl_test.cc | 240 …std::unique_ptr<T> command, common::ContextualOnceCallback<void(CommandCompleteView)> on_complete)… in EnqueueCommand() argument
241 hci_.EnqueueCommand(move(command), std::move(on_complete)); in EnqueueCommand()
245 …std::unique_ptr<T> command, common::ContextualOnceCallback<void(CommandStatusView)> on_status) ove… in EnqueueCommand() argument
246 hci_.EnqueueCommand(move(command), std::move(on_status)); in EnqueueCommand()
252 std::unique_ptr<CommandBuilder> command, in EnqueueCommand() argument
255 command_queue_.push(std::move(command)); in EnqueueCommand()
265 std::unique_ptr<CommandBuilder> command, in EnqueueCommand() argument
268 command_queue_.push(std::move(command)); in EnqueueCommand()
286 auto command = DequeueCommand(); in DequeueCommandBytes() local
289 command->Serialize(bi); in DequeueCommandBytes()
[all …]
|
| /packages/modules/Bluetooth/system/gd/rust/topshim/gatt/ |
| D | gatt_ble_scanner_shim.cc | 42 ApcfCommand ConvertApcfFromRust(const RustApcfCommand& command) { in ConvertApcfFromRust() argument
43 RawAddress address = rusty::CopyFromRustAddress(command.address); in ConvertApcfFromRust()
48 std::copy(command.name.begin(), command.name.end(), std::back_inserter(name)); in ConvertApcfFromRust()
49 std::copy(command.data.begin(), command.data.end(), std::back_inserter(data)); in ConvertApcfFromRust()
50 std::copy(command.data_mask.begin(), command.data_mask.end(), std::back_inserter(data_mask)); in ConvertApcfFromRust()
51 std::copy(command.irk.begin(), command.irk.end(), std::begin(irk)); in ConvertApcfFromRust()
54 .type = command.type_, in ConvertApcfFromRust()
56 .addr_type = command.addr_type, in ConvertApcfFromRust()
57 .uuid = bluetooth::Uuid::From128BitBE(command.uuid.uu), in ConvertApcfFromRust()
58 .uuid_mask = bluetooth::Uuid::From128BitBE(command.uuid_mask.uu), in ConvertApcfFromRust()
[all …]
|
| /packages/modules/Wifi/service/java/com/android/server/wifi/hotspot2/soap/command/ |
| D | BrowserUri.java | 17 package com.android.server.wifi.hotspot2.soap.command;
33 private BrowserUri(PropertyInfo command) { in BrowserUri() argument
34 mUri = command.getValue().toString(); in BrowserUri()
43 public static BrowserUri createInstance(PropertyInfo command) { in createInstance() argument
44 if (!TextUtils.equals(command.getName(), "launchBrowserToURI")) { in createInstance()
45 Log.e(TAG, "received wrong command : " + ((command == null) ? "" : command.getName())); in createInstance()
48 return new BrowserUri(command); in createInstance()
|
| D | PpsMoData.java | 17 package com.android.server.wifi.hotspot2.soap.command;
59 public static PpsMoData createInstance(@NonNull PropertyInfo command) { in createInstance() argument
60 if (command == null || command.getValue() == null) { in createInstance()
65 if (!TextUtils.equals(command.getName(), ADD_MO_COMMAND)) { in createInstance()
70 if (!(command.getValue() instanceof SoapPrimitive)) { in createInstance()
75 SoapPrimitive soapObject = (SoapPrimitive) command.getValue(); in createInstance()
|
| /packages/modules/adb/ |
| D | sockets.cpp | 434 p->msg.command = A_WRTE; in remote_socket_enqueue()
453 p->msg.command = A_OKAY; in remote_socket_ready()
463 p->msg.command = A_CLSE; in remote_socket_shutdown()
508 p->msg.command = A_OPEN; in connect_to_remote()
601 std::string_view command = full_service; in parse_host_service() local
603 auto consume = [&full_service, &serial, &command](size_t count) { in parse_host_service()
604 CHECK_LE(count, command.size()); in parse_host_service()
606 CHECK_EQ(serial.data() + serial.size(), command.data()); in parse_host_service()
610 command.remove_prefix(count); in parse_host_service()
614 auto finish = [out_serial, out_command, &serial, &command] { in parse_host_service()
[all …]
|
| /packages/modules/adb/daemon/ |
| D | shell_service_test.cpp | 47 void StartTestSubprocess(const char* command, SubprocessType type,
51 void StartTestCommandInProcess(std::string name, Command command, SubprocessProtocol protocol);
63 const char* command, SubprocessType type, SubprocessProtocol protocol) { in StartTestSubprocess() argument
64 command_fd_ = StartSubprocess(command, nullptr, type, protocol); in StartTestSubprocess()
71 void ShellServiceTest::StartTestCommandInProcess(std::string name, Command command, in StartTestCommandInProcess() argument
73 command_fd_ = StartCommandInProcess(std::move(name), std::move(command), protocol); in StartTestCommandInProcess()
212 for (std::string command : commands) { in TEST_F() local
214 command.push_back('\n'); in TEST_F()
215 memcpy(protocol->data(), command.data(), command.length()); in TEST_F()
216 ASSERT_TRUE(protocol->Write(ShellProtocol::kIdStdin, command.length())); in TEST_F()
[all …]
|
| /packages/apps/DocumentsUI/src/com/android/documentsui/ |
| D | ProviderExecutor.java | 86 public void execute(Runnable command) {
87 assert(command != null);
88 mQueue.add(command);
93 public void execute(Runnable command) { in execute() argument
95 assert(command != null); in execute()
96 mQueue.add(command); in execute()
103 final Runnable command = mQueue.take(); in run() local
104 command.run(); in run()
|
| /packages/modules/Bluetooth/system/gd/neighbor/ |
| D | inquiry_test.cc | 88 std::unique_ptr<hci::CommandBuilder> command, in EnqueueCommand() argument
91 …&TestHciLayer::HandleCommand, common::Unretained(this), std::move(command), std::move(on_complete)… in EnqueueCommand()
95 std::unique_ptr<hci::CommandBuilder> command, in EnqueueCommand() argument
98 … &TestHciLayer::HandleStatus, common::Unretained(this), std::move(command), std::move(on_status))); in EnqueueCommand()
104 hci::CommandView command = hci::CommandView::Create(GetPacketView(std::move(command_builder))); in HandleCommand() local
105 ASSERT_TRUE(command.IsValid()); in HandleCommand()
108 switch (command.GetOpCode()) { in HandleCommand()
116 … auto inquiry = hci::PeriodicInquiryModeView::Create(hci::DiscoveryCommandView::Create(command)); in HandleCommand()
137 auto view = hci::WriteInquiryModeView::Create(hci::DiscoveryCommandView::Create(command)); in HandleCommand()
152 … auto view = hci::WriteInquiryScanActivityView::Create(hci::DiscoveryCommandView::Create(command)); in HandleCommand()
[all …]
|
| /packages/services/Car/obd2-lib/src/com/android/car/obd2/ |
| D | Obd2LiveFrameGenerator.java | 80 for (LiveFrameCommand<Integer> command : mIntegerCommands) { in generate()
82 Optional<Integer> result = command.run(mConnection); in generate()
85 jsonWriter.name("id").value(command.getPid()); in generate()
94 command.getPid(), e)); in generate()
101 for (LiveFrameCommand<Float> command : mFloatCommands) { in generate()
103 Optional<Float> result = command.run(mConnection); in generate()
106 jsonWriter.name("id").value(command.getPid()); in generate()
115 command.getPid(), e)); in generate()
|
| D | Obd2Connection.java | 120 private String runImpl(String command) throws IOException, InterruptedException { in runImpl() argument
125 Log.i(TAG, "runImpl(" + command + ")"); in runImpl()
127 out.write((command + "\r").getBytes()); in runImpl()
166 public int[] run(String command) throws IOException, InterruptedException { in run() argument
167 String responseValue = runImpl(command); in run()
169 String unspacedCommand = command.replaceAll(" ", ""); in run()
202 command, originalResponseValue, responseValue)); in run()
277 int command = basePid + 8 * byteIndex + 7 - bitIndex; in getSupportedPIDs() local
279 Log.i(TAG, "command " + command + " found supported"); in getSupportedPIDs()
281 result.add(command); in getSupportedPIDs()
|
| D | Obd2FreezeFrameGenerator.java | 133 FreezeFrameCommand<Integer> command = in generate() local
136 Optional<Integer> result = command.run(mConnection); in generate()
139 jsonWriter.name("id").value(command.getPid()); in generate()
148 command.getPid(), e)); in generate()
155 FreezeFrameCommand<Float> command = in generate() local
158 Optional<Float> result = command.run(mConnection); in generate()
161 jsonWriter.name("id").value(command.getPid()); in generate()
170 command.getPid(), e)); in generate()
|
| /packages/modules/Bluetooth/framework/tests/stress/src/android/bluetooth/ |
| D | BluetoothInstrumentation.java | 60 String command = mArgs.getString("command"); in onStart() local
61 if ("enable".equals(command)) { in onStart()
63 } else if ("disable".equals(command)) { in onStart()
65 } else if ("unpairAll".equals(command)) { in onStart()
67 } else if ("getName".equals(command)) { in onStart()
69 } else if ("getAddress".equals(command)) { in onStart()
71 } else if ("getBondedDevices".equals(command)) { in onStart()
|
| /packages/services/Car/cpp/computepipe/runner/engine/ |
| D | DefaultEngine.cpp | 88 Status DefaultEngine::processClientConfigUpdate(const proto::ConfigurationCommand& command) { in processClientConfigUpdate() argument
94 if (command.has_set_input_source()) { in processClientConfigUpdate()
96 mConfigBuilder.updateInputConfigOption(command.set_input_source().source_id()); in processClientConfigUpdate()
97 } else if (command.has_set_termination_option()) { in processClientConfigUpdate()
99 command.set_termination_option().termination_option_id()); in processClientConfigUpdate()
100 } else if (command.has_set_output_stream()) { in processClientConfigUpdate()
102 command.set_output_stream().stream_id(), in processClientConfigUpdate()
103 command.set_output_stream().max_inflight_packets_count()); in processClientConfigUpdate()
104 } else if (command.has_set_offload_offload()) { in processClientConfigUpdate()
106 mConfigBuilder.updateOffloadOption(command.set_offload_offload().offload_option_id()); in processClientConfigUpdate()
[all …]
|
| /packages/apps/Launcher3/tests/src/com/android/launcher3/testcomponent/ |
| D | TestCommandReceiver.java | 37 public static Bundle callCommand(String command) { in callCommand() argument
38 return callCommand(command, null); in callCommand()
41 public static Bundle callCommand(String command, String arg) { in callCommand() argument
42 return callCommand(command, arg, null); in callCommand()
45 public static Bundle callCommand(String command, String arg, Bundle extras) { in callCommand() argument
48 return inst.getTargetContext().getContentResolver().call(uri, command, arg, extras); in callCommand()
|
| /packages/services/Telephony/tests/src/com/android/ |
| D | TestExecutorService.java | 203 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule() argument
206 command.run(); in schedule()
222 public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, in scheduleAtFixedRate() argument
228 public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, in scheduleWithFixedDelay() argument
234 public void execute(Runnable command) { in execute() argument
235 onExecute(command); in execute()
238 private void onExecute(Runnable command) { in onExecute() argument
240 mPendingRunnables.add(command); in onExecute()
242 command.run(); in onExecute()
|