| /tools/repohooks/rh/ |
| D | utils.py | 155 def _kill_child_process(proc, int_timeout, kill_timeout, cmd, original_handler, argument
172 if proc.returncode is None and proc.pid is not None:
174 while proc.poll_lock_breaker() is None and int_timeout >= 0:
178 proc.terminate()
179 while proc.poll_lock_breaker() is None and kill_timeout >= 0:
183 if proc.poll_lock_breaker() is None:
185 proc.kill()
195 proc.wait_lock_breaker(**kwargs)
379 proc = None
381 proc = _Popen(cmd, cwd=cwd, stdin=stdin, stdout=popen_stdout,
[all …]
|
| /tools/tradefederation/core/test_framework/com/android/tradefed/device/metric/ |
| D | ProcessMaxMemoryCollector.java | 79 for (String proc : mProcessNames) { in collect()
80 String dumpResult = device.executeShellCommand("dumpsys meminfo --checkin " + proc); in collect()
103 if (mPssMemoryPerProcess.get(device).get(proc) == null) { in collect()
104 mPssMemoryPerProcess.get(device).put(proc, NumericValues.newBuilder()); in collect()
106 mPssMemoryPerProcess.get(device).get(proc).addNumericValue(pss); in collect()
112 if (mUssMemoryPerProcess.get(device).get(proc) == null) { in collect()
113 mUssMemoryPerProcess.get(device).put(proc, NumericValues.newBuilder()); in collect()
115 mUssMemoryPerProcess.get(device).get(proc).addNumericValue(uss); in collect()
117 if (procPss.getOrDefault(proc, 0L) < pss) { in collect()
118 procPss.put(proc, pss); in collect()
[all …]
|
| /tools/test/connectivity/acts/framework/acts/ |
| D | utils.py | 41 from acts.libs.proc import job
398 proc = subprocess.Popen(cmd,
402 (out, err) = proc.communicate()
424 def _assert_subprocess_running(proc): argument
433 ret = proc.poll()
435 out, err = proc.communicate()
437 " stdout: %s" % (proc.pid, ret, err, out))
460 proc = subprocess.Popen(cmd,
468 _assert_subprocess_running(proc)
469 return proc
[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/loganalysis/src/com/android/loganalysis/item/ |
| D | GfxInfoItem.java | 83 JSONObject proc = new JSONObject(); in toJson() local
85 proc.put(PID_KEY, pid); in toJson()
86 proc.put(NAME_KEY, getName(pid)); in toJson()
87 proc.put(TOTAL_FRAMES_KEY, getTotalFrames(pid)); in toJson()
88 proc.put(PERCENTILE_90_KEY, getPrecentile90(pid)); in toJson()
89 proc.put(PERCENTILE_95_KEY, getPrecentile95(pid)); in toJson()
90 proc.put(PERCENTILE_99_KEY, getPrecentile99(pid)); in toJson()
91 processes.put(proc); in toJson()
|
| D | CompactMemInfoItem.java | 74 JSONObject proc = new JSONObject(); in toJson() local
76 proc.put(PID_JSON_KEY, pid); in toJson()
77 proc.put(NAME_JSON_KEY, getName(pid)); in toJson()
78 proc.put(PSS_JSON_KEY, getPss(pid)); in toJson()
79 proc.put(SWAP_JSON_KEY, getSwap(pid)); in toJson()
80 proc.put(TYPE_JSON_KEY, getType(pid)); in toJson()
81 proc.put(ACTIVITIES_JSON_KEY, hasActivities(pid)); in toJson()
82 processes.put(proc); in toJson()
|
| D | CpuInfoItem.java | 70 JSONObject proc = new JSONObject(); in toJson() local
72 proc.put(PID_KEY, pid); in toJson()
73 proc.put(PERCENT_KEY, getPercent(pid)); in toJson()
74 proc.put(NAME_KEY, getName(pid)); in toJson()
75 processes.put(proc); in toJson()
|
| /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
|
| /tools/tradefederation/core/atest/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
|
| /tools/acloud/internal/lib/ |
| D | ota_tools.py | 116 proc = None
130 proc = subprocess.Popen(command, **popen_args)
131 stdout, stderr = proc.communicate()
135 if proc.returncode != 0:
137 (command[0], proc.returncode))
139 if proc and proc.poll() is None:
141 proc.kill()
|
| D | adb_tools.py | 268 proc = subprocess.Popen(adb_cmd, stdin=subprocess.PIPE,
271 proc.communicate()
272 return proc.returncode
|
| /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()
|
| D | arduino_wifi_dongle.py | 198 proc = subprocess.Popen(cmd,
201 _, _ = proc.communicate()
202 return_code = proc.returncode
|
| /tools/acloud/create/ |
| D | goldfish_local_image_local_instance.py | 204 proc = self._StartEmulatorProcess(emulator_path, instance_dir,
212 self._WaitForEmulatorToStart(adb, proc, boot_timeout_secs)
223 if proc.poll() is None:
485 def _WaitForEmulatorToStart(self, adb, proc, timeout): argument
500 utils.PollAndWait(func=lambda: (proc.poll() is None and
506 if proc.poll() is not None:
508 proc.returncode)
|
| /tools/tradefederation/core/python-lib/tradefed_py/ |
| D | adb_handler.py | 29 proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
30 (out, err) = proc.communicate()
31 ret = proc.returncode
39 proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
40 (out, err) = proc.communicate()
41 ret = proc.returncode
|
| /tools/tradefederation/core/atest/ |
| D | atest_utils.py | 119 proc = subprocess.Popen(cmd, stdout=subprocess.PIPE,
125 while proc.poll() is None:
126 line = proc.stdout.readline()
144 proc.wait()
145 if proc.returncode != 0:
153 raise subprocess.CalledProcessError(proc.returncode, cmd, output)
|
| 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/asuite/atest/ |
| D | atest_utils.py | 138 proc = subprocess.Popen(cmd, stdout=subprocess.PIPE,
144 while proc.poll() is None:
145 line = proc.stdout.readline().decode('utf-8')
163 proc.wait()
164 if proc.returncode != 0:
172 raise subprocess.CalledProcessError(proc.returncode, cmd, output)
|
| /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/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/test/connectivity/acts_tests/tests/google/fuchsia/wlan/ |
| D | SoftApTest.py | 1106 for proc in [iperf_soft_ap, iperf_fuchsia_client]:
1107 proc.join(timeout=30)
1108 if proc.is_alive():
1109 raise RuntimeError('Failed to join process %s' % proc)
|
| /tools/test/connectivity/acts/framework/acts/test_utils/net/ |
| D | net_test_utils.py | 263 proc, argument
279 if proc is None:
282 stop_standing_subprocess(proc)
|
| /tools/test/connectivity/acts/framework/acts/controllers/utils_lib/ssh/ |
| D | connection.py | 27 from acts.libs.proc import job
390 tunnel.proc.kill()
391 tunnel.proc.wait()
|