/tools/test/connectivity/acts/framework/tests/libs/proc/ |
D | process_test.py | 20 from acts.libs.proc.process import Process 21 from acts.libs.proc.process import ProcessError 63 process = Process('cmd').set_on_output_callback(callback) 64 process._on_output_callback() 74 process = Process('cmd').set_on_terminate_callback(callback) 75 process._on_terminate_callback() 87 process = Process('cmd') 92 process._process = mock.Mock() 95 process.start() 98 process.start() [all …]
|
/tools/loganalysis/tests/src/com/android/loganalysis/parser/ |
D | MemHealthParserTest.java | 54 Map<String, Long> process = processes.get("com.google.android.gm"); in testOneForegroundProc() local 55 assertEquals(10910, process.get("native_avg").longValue()); in testOneForegroundProc() 56 assertEquals(8011, process.get("dalvik_avg").longValue()); in testOneForegroundProc() 57 assertEquals(90454, process.get("pss_avg").longValue()); in testOneForegroundProc() 58 assertEquals(11136, process.get("native_peak").longValue()); in testOneForegroundProc() 59 assertEquals(9812, process.get("dalvik_peak").longValue()); in testOneForegroundProc() 60 assertEquals(95161, process.get("pss_peak").longValue()); in testOneForegroundProc() 61 assertEquals(8223, process.get("summary_java_heap_avg").longValue()); in testOneForegroundProc() 62 assertEquals(3852, process.get("summary_native_heap_avg").longValue()); in testOneForegroundProc() 63 assertEquals(1804, process.get("summary_code_avg").longValue()); in testOneForegroundProc() [all …]
|
/tools/acloud/internal/lib/ |
D | ssh.py | 51 process = subprocess.Popen(cmd, shell=True, stdin=None, 55 timer = threading.Timer(timeout, process.kill) 57 process.wait() 60 return process.returncode 78 process = subprocess.Popen(cmd, shell=True, stdin=None, 82 timer = threading.Timer(timeout, process.kill) 84 process.communicate() 87 return process.returncode 111 process = subprocess.Popen(cmd, shell=True, stdin=None, 115 timer = threading.Timer(timeout, process.kill) [all …]
|
/tools/test/connectivity/acts_tests/tests/google/tel/live/ |
D | TelLiveRebootStressTest.py | 546 def _crash_recovery_test(self, process, *args): argument 565 self.dut.droid.logI("======== Trigger %s crash ========" % process) 568 if process == "modem": 572 elif process == "modem-crash": 576 elif process == "sim": 589 if process == "rild": 592 process = "qcrild" 594 process) 595 process_pid = self.dut.adb.shell("pidof %s" % process) 596 self.dut.log.info("Pid of %s is %s", process, process_pid) [all …]
|
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/ |
D | FtraceImporterState.kt | 57 thread.process.hint(tgid, name) in <lambda>() 58 return thread.process in <lambda>() 62 return ProcessModelFragment(InvalidId, hasIdCb = { process -> in <lambda>() method 63 val tgid = process.id in <lambda>() 66 existing.process.merge(process) in <lambda>() 68 pidMap.put(tgid, process.threadFor(tgid, process.name)) in <lambda>() 70 if (modelFragment.processes.none { it.id == process.id }) { in <lambda>() 71 modelFragment.processes.add(process) in <lambda>() 83 val process = in <lambda>() constant 86 thread = process.threadFor(pid, task) in <lambda>()
|
/tools/tradefederation/core/test_framework/com/android/tradefed/device/metric/ |
D | DumpHeapCollector.java | 60 for (String process : mDumpheapThresholds.keySet()) { in collect() 63 String.format("dumpsys meminfo -c | grep %s", process)); in collect() 65 dumpFiles = takeDumpheap(device, output, process, mDumpheapThresholds.get(process)); in collect() 88 List<File> takeDumpheap(ITestDevice device, String output, String process, Long threshold) in takeDumpheap() argument 92 CLog.i("Skipping %s -- no process found.", process); in takeDumpheap() 100 if (item.getName(pid).equals(process) && item.getPss(pid) > threshold) { in takeDumpheap() 101 File dump = device.dumpHeap(process, getDevicePath(process)); in takeDumpheap() 114 private String getDevicePath(String process) { in getDevicePath() argument 116 "%s/%s_%s_%s.hprof", DUMPHEAP_OUTPUT, process, SUFFIX, getFileSuffix()); in getDevicePath()
|
/tools/test/openhst/ |
D | stress_test.py | 221 self.process = None 268 self.process = pexpect.spawn(" ".join(self.command), timeout=None) 269 output_source = self.process 271 self.process = subprocess.Popen(self.command, stdout=subprocess.PIPE) 272 output_source = self.process.stdout 298 self.process.terminate() 300 self.process.send_signal(signal.SIGTERM) 305 if self.process.exitstatus is not None: 306 logging.info("Process finished - exit code %d", self.process.exitstatus) 309 self.process.signalstatus) [all …]
|
D | stress_test.proto | 24 // The process name that this event can be found on, or LOGCAT to come from 68 // The name of the process to be used in LoggingEventConfigs. 70 // The filepath to save the output of this process on the local machine. If 75 // Restart the process if it crashes randomly.
|
/tools/trebuchet/core/common/src/test/kotlin/trebuchet/importers/ftrace/ |
D | FtraceImporterTest.kt | 74 val process = modelFragment.processes[0] in testImportBeginEnd() constant 75 assertEquals(6381, process.id) in testImportBeginEnd() 76 assertEquals("equicksearchbox", process.name) in testImportBeginEnd() 77 assertEquals(1, process.threads.size) in testImportBeginEnd() 78 val thread = process.threads.first() in testImportBeginEnd() 110 val process = modelFragment.processes[0] in testImportBeginEndNoTgids() constant 111 assertEquals(6381, process.id) in testImportBeginEndNoTgids() 112 assertEquals("equicksearchbox", process.name) in testImportBeginEndNoTgids() 113 assertEquals(1, process.threads.size) in testImportBeginEndNoTgids() 114 val thread = process.threads.first() in testImportBeginEndNoTgids()
|
/tools/trebuchet/core/model/src/main/kotlin/trebuchet/model/fragments/ |
D | SchedulingProcessFragment.kt | 21 class SchedulingProcessFragment(val process: ProcessModelFragment, val thread: ThreadModelFragment,… constant in trebuchet.model.fragments.SchedulingProcessFragment 27 … fun switchProcess(process: ProcessModelFragment, thread: ThreadModelFragment, timestamp: Double) { in switchProcess() 34 _slices.add(SchedulingProcessFragment(process, thread, timestamp)) in switchProcess() 40 if (process.name != null) { 41 return process.name!! 43 return process.id.toString() 59 return process.id
|
D | ThreadModelFragment.kt | 24 class ThreadModelFragment(var id: Int, var process: ProcessModelFragment, var name: String? = null)… variable in trebuchet.model.fragments.ThreadModelFragment 31 if (this.process.id == InvalidId) this.process.id = tgid in hint() 32 if (this.process.name == null) this.process.name = processName in hint()
|
/tools/test/connectivity/acts_tests/tests/google/bt/performance/ |
D | BtInterferenceRSSITest.py | 69 process = Process(target=self.atten_sequence_worker, 72 attenuation_processes.append(process) 74 for process in attenuation_processes: 75 process.start() 77 for process in attenuation_processes: 78 process.terminate()
|
/tools/trebuchet/core/common/src/test/kotlin/trebuchet/task/ |
D | ImportTaskTest.kt | 46 val process = model.processes.values.find { it.name == "surfaceflinger" }!! in <lambda>() constant 47 val thread = process.threads.find { it.name == "surfaceflinger" }!! in <lambda>() 53 val counter = process.counters.find { it.name == counterName } in <lambda>() 63 val process = model.processes[6381]!! in <lambda>() constant 64 val thread = process.threads.find { it.name == "RenderThread" }!! in <lambda>() 67 val inputEvent4 = process.asyncSlices.find { in <lambda>()
|
/tools/test/connectivity/acts/framework/tests/controllers/android_lib/ |
D | logcat_test.py | 156 with self.patch('log_stream'), self.patch('Process') as process: 159 self.assertIn('S3R14L', process.call_args[0][0]) 163 process = logcat.create_logcat_keepalive_process('S3R14L', 'dir') 165 self.assertEqual(process.set_on_output_callback.called, True) 169 process = logcat.create_logcat_keepalive_process('S3R14L', 'dir') 171 self.assertEqual(process.set_on_terminate_callback.called, True)
|
/tools/test/connectivity/acts/framework/acts/controllers/android_lib/ |
D | logcat.py | 20 from acts.libs.proc.process import Process 96 process = Process('adb -s %s logcat -T 1 -v year %s' % 99 process.set_on_output_callback(_log_line_func(logger, timestamp_tracker)) 100 process.set_on_terminate_callback( 102 return process
|
/tools/trebuchet/trebuchet/startup-common/src/ |
D | StartupCommon.kt | 110 for (process in this.processes.values) { in findProcess() method 111 if (process.fuzzyNameMatch(queryName)) { in findProcess() 113 process. in findProcess() 118 min() ?: throw MissingProcessInfoException(process.id) in findProcess() 121 return process in findProcess()
|
/tools/acloud/create/ |
D | local_image_local_instance.py | 297 process = subprocess.Popen(cmd, shell=True, stderr=subprocess.STDOUT, 300 timer = threading.Timer(timeout, process.kill) 302 process.wait() 305 if process.returncode == 0: 309 "%s/launcher.log" % (str(process.returncode), cvd_runtime_dir))
|
D | local_image_local_instance_test.py | 234 process = mock.MagicMock() 235 process.wait.return_value = True 236 process.returncode = 0 237 self.Patch(subprocess, "Popen", return_value=process)
|
/tools/tradefederation/core/test_framework/com/android/tradefed/targetprep/ |
D | RunHostCommandTargetPreparer.java | 173 for (Process process : mBgProcesses) { in tearDown() 174 process.destroy(); in tearDown() 235 Process process = in runBgCommandList() local 240 if (process == null) { in runBgCommandList() 244 mBgProcesses.add(process); in runBgCommandList()
|
/tools/platform-compat/build/ |
D | Android.bp | 18 name: "process-compat-config", 32 name: "process-compat-config-test", 33 main: "process-compat-config-test.py", 36 "process-compat-config-test.py",
|
/tools/metalava/src/main/java/com/android/tools/metalava/ |
D | Driver.kt | 24 import com.android.ide.common.process.CachedProcessOutputHandler in <lambda>() 25 import com.android.ide.common.process.DefaultProcessExecutor in <lambda>() 26 import com.android.ide.common.process.ProcessInfoBuilder in <lambda>() 27 import com.android.ide.common.process.ProcessOutput in <lambda>() 28 import com.android.ide.common.process.ProcessOutputHandler in <lambda>()
|
/tools/tradefederation/core/common_util/com/android/tradefed/util/ |
D | RunUtil.java | 351 Process process = createProcessBuilder(command).start(); in runCmdInBackground() local 353 process.getInputStream(), in runCmdInBackground() 357 process.getErrorStream(), in runCmdInBackground() 360 return process; in runCmdInBackground()
|
/tools/trebuchet/trebuchet/viewer/src/main/kotlin/traceviewer/ui/ |
D | ProcessPanel.kt | 26 class ProcessPanel(val process: ProcessModel, renderState: RenderState) : JPanel(GridBagLayout()) { constant in traceviewer.ui.ProcessPanel 32 add(ProcessLabel(process.name), constraints) 33 process.threads.forEach { in <lambda>()
|
/tools/asuite/asuite_plugin/src/java/com/android/atest/commandAdapter/ |
D | AtestProcessListener.java | 19 import com.intellij.execution.process.ProcessEvent; 20 import com.intellij.execution.process.ProcessListener; 21 import com.intellij.execution.process.ProcessOutputTypes;
|
/tools/trebuchet/trebuchet/analyzer/src/ |
D | Analyzer.kt | 38 val process = uiThread.process in measureStartup() constant 39 val rtThread = process.threads.first { it.name == "RenderThread" } in measureStartup()
|