/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/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/Virtualization/virtmanager/src/ |
D | crosvm.rs | 127 let mut command = Command::new(CROSVM_PATH); in run_vm() localVariable 129 command.arg("run").arg("--disable-sandbox").arg("--cid").arg(cid.to_string()); in run_vm() 131 command.stdout(log_fd); in run_vm() 134 command.arg("--serial=type=sink"); in run_vm() 137 command.arg("--bios").arg(bootloader); in run_vm() 140 command.arg("--initrd").arg(initrd); in run_vm() 143 command.arg("--params").arg(params); in run_vm() 146 command.arg(if disk.writable { "--rwdisk" } else { "--disk" }).arg(&disk.image); in run_vm() 149 command.arg(kernel); in run_vm() 151 info!("Running {:?}", command); in run_vm() [all …]
|
/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 …]
|
D | abb_service.cpp | 31 unique_fd sendCommand(std::string_view command); 43 unique_fd AbbProcess::sendCommand(std::string_view command) { in sendCommand() argument 56 if (!SendProtocolString(socket_fd_, command)) { in sendCommand() 88 unique_fd execute_abb_command(std::string_view command) { in execute_abb_command() argument 89 return abbp->sendCommand(command); in execute_abb_command()
|
/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/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/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/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 | 119 private String runImpl(String command) throws IOException, InterruptedException { in runImpl() argument 124 Log.i(TAG, "runImpl(" + command + ")"); in runImpl() 127 out.write((command + "\r").getBytes()); in runImpl() 169 public int[] run(String command) throws IOException, InterruptedException { in run() argument 170 String responseValue = runImpl(command); in run() 172 String unspacedCommand = command.replaceAll(" ", ""); in run() 205 command, originalResponseValue, responseValue)); in run() 280 int command = basePid + 8 * byteIndex + 7 - bitIndex; in getSupportedPIDs() local 282 Log.i(TAG, "command " + command + " found supported"); in getSupportedPIDs() 284 result.add(command); in getSupportedPIDs()
|
D | Obd2FreezeFrameGenerator.java | 131 FreezeFrameCommand<Integer> command = in generate() local 134 Optional<Integer> result = command.run(mConnection); in generate() 137 jsonWriter.name("id").value(command.getPid()); in generate() 146 command.getPid(), e)); in generate() 153 FreezeFrameCommand<Float> command = in generate() local 156 Optional<Float> result = command.run(mConnection); in generate() 159 jsonWriter.name("id").value(command.getPid()); in generate() 168 command.getPid(), e)); in generate()
|
/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()
|
/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/apps/Contacts/src/com/android/contacts/util/concurrent/ |
D | ContactsExecutors.java | 111 public ScheduledFuture<?> schedule(final Runnable command, long delay, TimeUnit unit) { in schedule() argument 113 .fromRunnable(mHandler, delay, unit, command); in schedule() 128 public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, in scheduleAtFixedRate() argument 135 public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, in scheduleWithFixedDelay() argument 165 public void execute(Runnable command) { in execute() argument 166 mHandler.post(command); in execute() 232 final Runnable command) { in fromRunnable() argument 236 command.run(); in fromRunnable()
|
/packages/modules/adb/client/ |
D | commandline.cpp | 580 const std::string& command) { in ShellServiceString() argument 598 command.c_str()); in ShellServiceString() 774 std::string command; in adb_shell() local 777 command = android::base::Join(std::vector<const char*>(argv + optind, argv + argc), ' '); in adb_shell() 780 std::string service_string = ShellServiceString(use_shell_protocol, shell_type_arg, command); in adb_shell() 781 return RemoteShell(use_shell_protocol, shell_type_arg, escape_char, command.empty(), in adb_shell() 1103 static bool adb_root(const char* command) { in adb_root() argument 1107 unique_fd fd(adb_connect(&transport_id, android::base::StringPrintf("%s:", command), &error)); in adb_root() 1109 fprintf(stderr, "adb: unable to connect for %s: %s\n", command, error.c_str()); in adb_root() 1122 fprintf(stderr, "adb: error while reading for %s: %s\n", command, strerror(errno)); in adb_root() [all …]
|
/packages/apps/Dialer/java/com/android/dialer/commandline/ |
D | CommandLineReceiver.java | 52 Command command = in onReceive() local 58 if (command == null) { in onReceive() 66 LogUtil.i(outputTag, "usage:\n" + command.getUsage()); in onReceive() 70 command.run(args), in onReceive() 84 LogUtil.e(outputTag, throwable.getMessage() + "\n\nusage:\n" + command.getUsage()); in onReceive() 91 LogUtil.e(outputTag, e.getMessage() + "\n\nusage:\n" + command.getUsage()); in onReceive()
|
/packages/apps/Dialer/java/com/android/voicemail/impl/protocol/ |
D | CvvmProtocol.java | 47 public String getCommand(String command) { in getCommand() argument 48 if (command == OmtpConstants.IMAP_CHANGE_TUI_PWD_FORMAT) { in getCommand() 51 if (command == OmtpConstants.IMAP_CLOSE_NUT) { in getCommand() 54 if (command == OmtpConstants.IMAP_CHANGE_VM_LANG_FORMAT) { in getCommand() 57 return super.getCommand(command); in getCommand()
|
/packages/inputmethods/LatinIME/tools/dicttool/src/com/android/inputmethod/latin/dicttool/ |
D | Dicttool.java | 108 final Command command = getCommandInstance(commandName); in getCommand() local 110 command.setArgs(argsArray); in getCommand() 111 return command; in getCommand() 120 final Command command = getCommand(arguments); in execute() local 122 command.run(); in execute() 126 + command.getClass().getSimpleName() + " : " + e); in execute()
|
/packages/modules/Wifi/service/java/com/android/server/wifi/aware/ |
D | WifiAwareShellCommand.java | 41 public void register(String command, DelegatedShellCommand shellCommand) { in register() argument 42 if (mDelegatedCommands.containsKey(command)) { in register() 43 Log.e(TAG, "register: overwriting existing command -- '" + command + "'"); in register() 46 mDelegatedCommands.put(command, shellCommand); in register() 123 void onHelp(String command, BasicShellCommandHandler parentShell); in onHelp() argument
|
/packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
D | TestScheduledExecutorService.java | 115 public void execute(Runnable command) { in execute() argument 116 schedule(command, 0, TimeUnit.MILLISECONDS); in execute() 120 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { in schedule() argument 121 TestFuture future = new TestFuture(command, delay, unit); in schedule() 132 public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, in scheduleAtFixedRate() argument 138 public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, in scheduleWithFixedDelay() argument
|
/packages/apps/Launcher3/src/com/android/launcher3/pm/ |
D | UserCache.java | 71 public SafeCloseable addUserChangeListener(Runnable command) { in addUserChangeListener() argument 80 mUserChangeListeners.add(command); in addUserChangeListener() 81 return () -> removeUserChangeListener(command); in addUserChangeListener() 100 private void removeUserChangeListener(Runnable command) { in removeUserChangeListener() argument 102 mUserChangeListeners.remove(command); in removeUserChangeListener()
|
/packages/apps/Launcher3/tests/src/com/android/launcher3/ui/widget/ |
D | RequestPinItemTest.java | 93 Intent command = RequestPinItemActivity.getCommandIntent( in testPinWidgetNoConfig_customPreview() local 100 .equals(AppWidgetNoConfig.class.getName()), command); in testPinWidgetNoConfig_customPreview() 115 Intent command = RequestPinItemActivity.getCommandIntent( in testPinShortcut() local 126 }, command); in testPinShortcut() 151 for (Intent command : commandIntents) { in runTest() 152 mTargetContext.sendBroadcast(command); in runTest()
|
/packages/modules/NetworkStack/tests/hostdriven/host/src/com/android/networkstack/hosttests/ |
D | NetworkStackHostTests.kt | 140 private fun assertCommandSucceeds(command: String): CommandResult { in assertCommandSucceeds() 141 return mDevice.executeShellV2Command(command).also { in assertCommandSucceeds() 142 assertEquals(CommandStatus.SUCCESS, it.getStatus(), makeErrorMessage(command, it)) in assertCommandSucceeds() 168 private fun makeErrorMessage(command: String, result: CommandResult): String { in makeErrorMessage() 169 return "$command failed; stderr: ${result.getStderr()}; stdout: ${result.stdout}; " + in makeErrorMessage()
|