Home
last modified time | relevance | path

Searched refs:process (Results 1 – 25 of 104) sorted by relevance

12345

/tools/test/connectivity/acts/framework/tests/libs/proc/
Dprocess_test.py19 from acts.libs.proc.process import Process
20 from acts.libs.proc.process import ProcessError
64 process = Process('cmd').set_on_output_callback(callback)
65 process._on_output_callback()
75 process = Process('cmd').set_on_terminate_callback(callback)
76 process._on_terminate_callback()
88 process = Process('cmd')
93 process._process = mock.Mock()
96 process.start()
99 process.start()
[all …]
/tools/loganalysis/javatests/com/android/loganalysis/parser/
DMemHealthParserTest.java54 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/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/
DFtraceImporterState.kt57 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/trebuchet/core/model/src/main/kotlin/trebuchet/model/fragments/
DSchedulingProcessFragment.kt21 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
DThreadModelFragment.kt24 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/acloud/internal/lib/
Dssh.py58 process = subprocess.Popen(cmd, shell=True, stdin=None,
62 timer = threading.Timer(timeout, process.kill)
64 process.wait()
67 return process.returncode
85 process = subprocess.Popen(cmd, shell=True, stdin=None,
89 timer = threading.Timer(timeout, process.kill)
91 process.communicate()
94 return process.returncode
123 process = subprocess.Popen(cmd, shell=True, stdin=None,
128 timer = threading.Timer(timeout, process.kill)
[all …]
/tools/test/connectivity/acts_tests/tests/google/bt/performance/
DBtInterferenceRSSITest.py69 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/importers/ftrace/
DFtraceImporterTest.kt74 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/test/connectivity/acts/framework/acts/controllers/android_lib/
Dlogcat.py20 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/test/connectivity/acts/framework/acts/controllers/fuchsia_lib/
Dssh.py39 self, process: Union[subprocess.CompletedProcess,
42 self._raw_stdout = process.stdout
43 self._stdout = process.stdout.decode('utf-8', errors='replace')
44 self._stderr = process.stderr.decode('utf-8', errors='replace')
45 self._exit_status: int = process.returncode
206 process = subprocess.run(full_command,
229 return SSHResult(process)
Dffx.py39 process: subprocess.CalledProcessError) -> None:
41 self.stdout: str = process.stdout.decode('utf-8', errors='replace')
42 self.stderr: str = process.stderr.decode('utf-8', errors='replace')
43 self.exit_status = process.returncode
/tools/test/connectivity/acts/framework/tests/controllers/android_lib/
Dlogcat_test.py156 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/tradefederation/core/src/com/android/tradefed/util/
DPerfettoTraceRecorder.java127 Process process = in startTrace() local
172 deviceTraceMetadata.setProcess(process); in startTrace()
222 public Process process; field in PerfettoTraceRecorder.DeviceTraceMetadata
233 return process; in getProcess()
236 public void setProcess(Process process) { in setProcess() argument
237 this.process = process; in setProcess()
/tools/platform-compat/build/
DAndroid.bp23 name: "process-compat-config",
34 name: "process-compat-config-test",
35 main: "process-compat-config-test.py",
38 "process-compat-config-test.py",
/tools/asuite/adevice/src/
Dadevice_fingerprint.rs11 use std::process;
22 process::exit(1); in main()
27 process::exit(1); in main()
/tools/trebuchet/trebuchet/viewer/src/main/kotlin/traceviewer/ui/
DProcessPanel.kt26 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/
DAtestProcessListener.java19 import com.intellij.execution.process.ProcessEvent;
20 import com.intellij.execution.process.ProcessListener;
21 import com.intellij.execution.process.ProcessOutputTypes;
/tools/asuite/atest/bazel/runner/src/com/android/tradefed/testtype/bazel/
DBazelTest.java454 Process process = startProcess(QUERY_MAP_MODULES_TO_TARGETS, builder, BAZEL_QUERY_TIMEOUT); in queryModulesToTestTargets() local
456 List<String> queryLines = readProcessLines(process); in queryModulesToTestTargets()
458 waitForSuccessfulProcess(process, QUERY_MAP_MODULES_TO_TARGETS); in queryModulesToTestTargets()
463 private List<String> readProcessLines(Process process) throws IOException { in readProcessLines() argument
464 return CharStreams.readLines(process.inputReader()); in readProcessLines()
570 Process process = startProcess(processTag, builder, processTimeout); in startAndWaitForSuccessfulProcess() local
571 waitForSuccessfulProcess(process, processTag); in startAndWaitForSuccessfulProcess()
572 return process; in startAndWaitForSuccessfulProcess()
580 Process process = mProcessStarter.start(processTag, builder); in startProcess() local
588 if (waitForProcessUninterruptibly(process, timeout)) { in startProcess()
[all …]
/tools/test/connectivity/acts_tests/tests/google/tel/live/
DTelLiveRebootStressTest.py544 def _crash_recovery_test(self, process, *args): argument
563 self.dut.droid.logI("======== Trigger %s crash ========" % process)
566 if process == "modem":
570 elif process == "modem-crash":
574 elif process == "sim":
587 if process == "rild":
590 process = "qcrild"
592 process)
593 process_pid = self.dut.adb.shell("pidof %s" % process)
594 self.dut.log.info("Pid of %s is %s", process, process_pid)
[all …]
/tools/test/connectivity/acts_tests/acts_contrib/test_utils/abstract_devices/
Dwmm_transceiver.py303 process = multiprocessing.Process(target=self._run_traffic,
321 process.start()
323 self._running_processes.add(process)
349 process = self._running_processes.pop()
350 process.join(timeout)
351 if process.is_alive():
355 process.terminate()
356 process.join()
659 def process(self, msg, kwargs): member in WmmTransceiverLoggerAdapter
/tools/trebuchet/trebuchet/analyzer/src/
DAnalyzer.kt38 val process = uiThread.process in measureStartup() constant
39 val rtThread = process.threads.first { it.name == "RenderThread" } in measureStartup()
/tools/trebuchet/trebuchet/startup-common/src/
DStartupCommon.kt110 for (process in this.processes.values) { in findProcess() method
111 if (process.fuzzyNameMatch(queryName)) { in findProcess()
113 process. in findProcess()
118 minOrNull() ?: throw MissingProcessInfoException(process.id) in findProcess()
121 return process in findProcess()
/tools/test/openhst/
Dstress_test.py221 self.process = None
269 self.process = pexpect.spawn(" ".join(self.command), timeout=None)
270 output_source = self.process
272 self.process = subprocess.Popen(self.command, stdout=subprocess.PIPE)
273 output_source = self.process.stdout
306 self.process.terminate()
308 self.process.send_signal(signal.SIGTERM)
314 if self.process.exitstatus is not None:
315 logging.info("Process finished - exit code %d", self.process.exitstatus)
318 self.process.signalstatus)
[all …]
/tools/netsim/scripts/tasks/
Drun_pytest_task.py41 return run_pytest_manager.process()
78 def process(self) -> bool: member in RunPytestManager
/tools/asuite/atest/test_runners/
Dsuite_plan_test_runner_unittest.py153 process = _mock_popen.return_value.__enter__.return_value
154 process.returncode = 0
155 process.communicate.return_value = (b'output', b'error')

12345