Home
last modified time | relevance | path

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

12

/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/acloud/internal/lib/
Dssh.py51 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,
116 timer = threading.Timer(timeout, process.kill)
[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()
DProcessModelFragment.kt73 value.process = this in <lambda>()
/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/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/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/platform-compat/build/
DAndroid.bp22 name: "process-compat-config",
36 name: "process-compat-config-test",
37 main: "process-compat-config-test.py",
40 "process-compat-config-test.py",
/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/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/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 min() ?: 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 …]
Dstress_test.proto24 // 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/trebuchet/analyzer/src/
DAnalyzer.kt38 val process = uiThread.process in measureStartup() constant
39 val rtThread = process.threads.first { it.name == "RenderThread" } in measureStartup()
/tools/platform-compat/java/android/processor/compat/
DSingleAnnotationProcessor.java79 public boolean process( in process() method in SingleAnnotationProcessor
109 process(annotation, annotatedElements); in process()
121 protected abstract void process(TypeElement annotation, in process() method in SingleAnnotationProcessor
/tools/trebuchet/core/model/src/main/kotlin/trebuchet/model/
DThreadModel.kt21 class ThreadModel constructor(val process: ProcessModel, fragment: ThreadModelFragment) { constant in trebuchet.model.ThreadModel
/tools/test/connectivity/acts/framework/acts/controllers/bits_lib/
Dbits_service.py30 from acts.libs.proc import process
170 self._process = process.Process(cmd)
/tools/test/graphicsbenchmark/apps/sample_app/src/cpp/
Dmain.cpp125 source->process(state, source); in android_main()
/tools/test/openhst/docs/
Dcontributing.md23 process](https://source.android.com/setup/contribute/submit-patches).
/tools/acloud/list/
Dinstance.py449 process = subprocess.Popen(cvd_status_cmd,
454 stdout, _ = process.communicate()
455 if process.returncode != 0:
/tools/test/connectivity/acts/framework/acts/
Dutils.py1027 def get_process_uptime(process): argument
1029 pid = job.run('pidof %s' % process, ignore_status=True).stdout
1036 def get_device_process_uptime(adb, process): argument
1038 pid = adb.shell('pidof %s' % process, ignore_status=True)
/tools/acloud/create/
Davd_spec.py667 process = subprocess.Popen(_COMMAND_REPO_INFO, shell=True, stdin=None,
671 timer = threading.Timer(_REPO_TIMEOUT, process.kill)
673 stdout, _ = process.communicate()

12