| /tools/repohooks/rh/ |
| D | utils.py | 151 def _kill_child_process(proc, int_timeout, kill_timeout, cmd, original_handler, argument
168 if proc.returncode is None and proc.pid is not None:
170 while proc.poll_lock_breaker() is None and int_timeout >= 0:
174 proc.terminate()
175 while proc.poll_lock_breaker() is None and kill_timeout >= 0:
179 if proc.poll_lock_breaker() is None:
181 proc.kill()
187 proc.wait_lock_breaker(timeout=60)
372 proc = None
374 proc = _Popen(cmd, cwd=cwd, stdin=stdin, stdout=popen_stdout,
[all …]
|
| /tools/test/connectivity/acts/framework/acts/libs/proc/ |
| D | job.py | 135 proc = subprocess.Popen(command,
145 (out, err) = proc.communicate(timeout=timeout)
148 proc.kill()
149 proc.wait()
154 exit_status=proc.returncode,
165 if not ignore_status and proc.returncode != 0:
189 proc = subprocess.Popen(command,
195 logging.debug("command %s started with pid %s", command, proc.pid)
196 return proc
|
| /tools/asuite/atest/test_runners/ |
| D | test_runner_base.py | 122 def wait_for_subprocess(self, proc): argument
134 self.NAME, proc.pid)
135 signal.signal(signal.SIGINT, self._signal_passer(proc))
136 proc.wait()
137 return proc.returncode
140 os.killpg(os.getpgid(proc.pid), signal.SIGINT)
143 def _signal_passer(self, proc): argument
161 os.killpg(os.getpgid(proc.pid), signal.SIGINT)
|
| D | regression_test_runner.py | 50 proc = super(RegressionTestRunner, self).run(run_cmds[0],
52 proc.wait()
53 return proc.returncode
|
| D | suite_plan_test_runner.py | 64 proc = super().run(run_cmd, output_to_stdout=True)
65 ret_code |= self.wait_for_subprocess(proc)
|
| D | vts_tf_test_runner.py | 70 proc = super(VtsTradefedTestRunner, self).run(run_cmd,
72 ret_code |= self.wait_for_subprocess(proc)
|
| /tools/asuite/atest-py2/test_runners/ |
| D | test_runner_base.py | 130 def wait_for_subprocess(self, proc): argument
141 logging.debug('Runner Name: %s, Process ID: %s', self.NAME, proc.pid)
142 signal.signal(signal.SIGINT, self._signal_passer(proc))
143 proc.wait()
144 return proc.returncode
147 os.killpg(os.getpgid(proc.pid), signal.SIGINT)
150 def _signal_passer(self, proc): argument
168 os.killpg(os.getpgid(proc.pid), signal.SIGINT)
|
| D | regression_test_runner.py | 50 proc = super(RegressionTestRunner, self).run(run_cmds[0],
52 proc.wait()
53 return proc.returncode
|
| D | suite_plan_test_runner.py | 66 proc = super(SuitePlanTestRunner, self).run(run_cmd,
68 ret_code |= self.wait_for_subprocess(proc)
|
| D | vts_tf_test_runner.py | 71 proc = super(VtsTradefedTestRunner, self).run(run_cmd,
73 ret_code |= self.wait_for_subprocess(proc)
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/wifi/rtt/ |
| D | RttBaseTest.py | 63 proc = nutils.start_tcpdump(ad, self.test_name)
64 self.tcpdump_proc.append((ad, proc))
85 for proc in self.tcpdump_proc:
87 proc[0], proc[1], self.test_name, pull_dump=False)
105 for proc in self.tcpdump_proc:
106 nutils.stop_tcpdump(proc[0], proc[1], self.test_name)
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/wifi/aware/ |
| D | AwareBaseTest.py | 60 proc = nutils.start_tcpdump(ad, self.test_name)
61 self.tcpdump_proc.append((ad, proc))
91 for proc in self.tcpdump_proc:
93 proc[0], proc[1], self.test_name, pull_dump=False)
151 for proc in self.tcpdump_proc:
152 nutils.stop_tcpdump(proc[0], proc[1], self.test_name)
|
| /tools/acloud/internal/lib/ |
| D | ota_tools.py | 141 proc = None
155 proc = subprocess.Popen(command, **popen_args)
156 stdout, stderr = proc.communicate()
160 if proc.returncode != 0:
162 (command[0], proc.returncode))
164 if proc and proc.poll() is None:
166 proc.kill()
|
| D | adb_tools.py | 288 proc = subprocess.Popen(adb_cmd, stdin=subprocess.PIPE,
291 proc.communicate()
292 return proc.returncode
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/wifi/p2p/ |
| D | WifiP2pBaseTest.py | 118 proc = nutils.start_tcpdump(ad, self.test_name)
119 self.tcpdump_proc.append((ad, proc))
127 for proc in self.tcpdump_proc:
129 proc[0], proc[1], self.test_name, pull_dump=False)
150 for proc in self.tcpdump_proc:
151 nutils.stop_tcpdump(proc[0], proc[1], self.test_name)
|
| /tools/test/connectivity/acts/framework/acts/controllers/ |
| D | packet_capture.py | 28 from acts.libs.proc.process import Process
74 def __init__(self, proc, pcap_fname, pcap_file): argument
76 self.proc = proc
283 def stop_packet_capture(self, proc): argument
290 if val.proc is proc:
296 proc.stop()
|
| /tools/test/connectivity/acts/framework/acts/ |
| D | utils.py | 43 from acts.libs.proc import job
400 proc = subprocess.Popen(cmd,
404 (out, err) = proc.communicate()
426 def _assert_subprocess_running(proc): argument
435 ret = proc.poll()
437 out, err = proc.communicate()
439 " stdout: %s" % (proc.pid, ret, err, out))
462 proc = subprocess.Popen(cmd,
470 _assert_subprocess_running(proc)
471 return proc
[all …]
|
| /tools/test/connectivity/acts_tests/tests/google/bt/performance/ |
| D | BtInterferenceStaticTest.py | 145 for proc in procs_iperf:
146 proc.start()
149 for proc in procs_iperf:
150 proc.join()
|
| D | BtInterferenceDynamicTest.py | 289 for proc in procs_iperf:
290 proc.join()
344 for proc in procs_iperf:
345 proc.join()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceImporterState.kt | 45 val proc = ProcessModelFragment(tgid, name) in <lambda>() constant
46 modelFragment.processes.add(proc) in <lambda>()
47 val thread = proc.threadFor(tgid, name) in <lambda>()
|
| /tools/acloud/create/ |
| D | goldfish_local_image_local_instance.py | 195 proc = self._StartEmulatorProcess(emulator_path, instance_dir,
203 self._WaitForEmulatorToStart(ins.adb, proc, boot_timeout_secs)
541 def _WaitForEmulatorToStart(self, adb, proc, timeout): argument
556 utils.PollAndWait(func=lambda: (proc.poll() is None and
562 if proc.poll() is not None:
564 proc.returncode)
|
| /tools/treble/build/sandbox/ |
| D | nsjail.cfg | 37 # Mount proc as read/write.
39 dst: "/proc"
40 fstype: "proc"
121 src: "/proc/self/fd"
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/bt/ |
| D | A2dpBaseTest.py | 127 proc = self.audio_device.start()
129 proc.kill()
131 proc.kill()
|
| /tools/asuite/atest-py2/ |
| D | atest.py | 88 proc = Process(target=task)
89 proc.daemon = not join
90 proc.start()
91 _running_procs.append(proc)
93 for proc in _running_procs:
94 proc.join()
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/wifi/ |
| D | WifiBaseTest.py | 94 proc = nutils.start_tcpdump(ad, self.test_name)
95 self.tcpdump_proc.append((ad, proc))
105 for proc in self.tcpdump_proc:
106 nutils.stop_tcpdump(proc[0],
107 proc[1],
128 for proc in self.tcpdump_proc:
129 nutils.stop_tcpdump(proc[0], proc[1], self.test_name)
|