| /third_party/python/Lib/test/ |
| D | test_file_eintr.py | 27 self._process = None
30 if self._process and self._process.poll() is None:
32 self._process.kill()
59 if self._process.poll() is None:
62 self._process.terminate() # Ensure it dies.
66 stdout_end, stderr_end = self._process.communicate()
91 self._process = subprocess.Popen(
105 worm_sign = self._process.stderr.read(len(b'Worm Sign!\n'))
109 self._process.stdin.write(data_to_write)
119 rlist, _, _ = select.select([self._process.stderr], (), (), 0.05)
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-zlib-random-byte-pipes.js | 58 this._process = this._process.bind(this);
60 process.nextTick(this._process);
72 this._process();
75 _process() { method in RandomReadStream
109 process.nextTick(this._process);
|
| D | test-global-setters.js | 4 const _process = require('process'); constant
7 assert.strictEqual(process, _process);
12 global.process = _process;
13 assert.strictEqual(process, _process);
|
| /third_party/flutter/engine/flutter/shell/testing/observatory/ |
| D | launcher.dart | 13 final Process _process;
15 ShellProcess(this._process) : assert(_process != null) {
17 _process.stdout.transform(utf8.decoder)
29 if (_process == null) {
32 return _process.kill();
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/fuchsia/ |
| D | fuchsia_pm.dart | 186 Process _process;
200 if (_process != null) {
209 _process = await fuchsiaSdk.fuchsiaPM.serve(_repo, _host, _port);
210 // Put a completer on _process.exitCode to watch for error.
211 unawaited(_process.exitCode.whenComplete(() {
212 // If _process is null, then the server was stopped deliberately.
213 if (_process != null) {
222 if (_process != null) {
223 _process.kill();
224 _process = null;
[all …]
|
| /third_party/grpc/tools/run_tests/python_utils/ |
| D | jobset.py | 300 self._process = try_start()
309 self._process = try_start()
320 if self._state == _RUNNING and self._process.poll() is not None:
323 if self._process.returncode != 0:
327 (self._spec.shortname, self._process.returncode,
328 self._process.pid),
341 (self._spec.shortname, self._process.returncode,
342 self._process.pid, elapsed),
347 self.result.returncode = self._process.returncode
381 (self._spec.shortname, self._process.pid),
[all …]
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/dart/ |
| D | analysis.dart | 25 Process _process;
47 _process = await processManager.start(command);
49 unawaited(_process.exitCode.whenComplete(() => _process = null));
52 _process.stderr.transform<String>(utf8.decoder).transform<String>(const LineSplitter());
56 _process.stdout.transform<String>(utf8.decoder).transform<String>(const LineSplitter());
71 Future<int> get onExit => _process.exitCode;
79 _process.stdin.writeln(message);
145 return _process?.kill();
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/tester/ |
| D | flutter_tester.dart | 52 Process _process;
159 _process = await processManager.start(command,
165 unawaited(_process.exitCode.then<void>((_) => _isRunning = false));
166 _process.stdout
172 _process.stderr
197 _process?.kill();
198 _process = null;
|
| /third_party/node/deps/npm/node_modules/glob/ |
| D | sync.js | 48 this._process(this.minimatch.set[i], i, false)
77 GlobSync.prototype._process = function (pattern, index, inGlobStar) { method in GlobSync
207 this._process(newPattern.concat(remain), index, inGlobStar)
364 this._process(noGlobStar, index, false)
380 this._process(instead, index, true)
383 this._process(below, index, true)
|
| D | glob.js | 170 this._process(this.minimatch.set[i], i, false, done)
292 this._process(p[0], p[1], p[2], p[3])
298 Glob.prototype._process = function (pattern, index, inGlobStar, cb) { method in Glob
449 this._process([e].concat(remain), index, inGlobStar, cb)
646 this._process(noGlobStar, index, false, cb)
662 this._process(instead, index, true, cb)
665 this._process(below, index, true, cb)
|
| /third_party/node/test/common/ |
| D | inspector-helper.js | 338 this._process = spawnChildProcess(inspectorFlags, scriptContents,
344 this._process.stdout.on('data', makeBufferingDataCallback(
350 this._process.stderr.on('data', makeBufferingDataCallback(
354 this._process.once('exit', (exitCode, signal) => {
371 process._debugProcess(instance._process.pid);
466 this._process.stdin.write(message);
470 this._process.kill();
|
| /third_party/flutter/flutter/packages/flutter_tools/test/integration.shard/ |
| D | test_driver.dart | 45 Process _process;
98 _process = await _processManager.start(
108 unawaited(_process.exitCode.then((int code) {
112 transformToLines(_process.stdout).listen((String line) => _stdout.add(line));
113 transformToLines(_process.stderr).listen((String line) => _stderr.add(line));
156 return _process.exitCode.timeout(quitTimeout, onTimeout: _killForcefully);
162 return _process.exitCode;
475 // _process.kill() (`flutter` is a shell script so _process itself is a
517 if (_process == null) {
527 _process.exitCode,
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests/fork/ |
| D | methods.py | 131 self._process = multiprocessing.Process(target=record_exceptions)
134 self._process.start()
137 self._process.join(timeout=_CHILD_FINISH_TIMEOUT_S)
138 if self._process.is_alive():
140 if self._process.exitcode != 0:
142 self._process.exitcode)
|
| /third_party/grpc/src/python/grpcio_testing/grpc_testing/ |
| D | _time.py | 60 def _process(state, now): function
140 delta = _process(self._state, now)
221 delta = _process(self._state, self._time)
228 delta = _process(self._state, self._time)
|
| /third_party/python/Doc/tools/extensions/ |
| D | escape4chm.py | 14 def _process(string): function
34 context['body'] = _process(body)
|
| /third_party/node/lib/internal/bootstrap/ |
| D | pre_execution.js | 294 let _process = process;
297 return _process;
300 _process = value;
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/web/ |
| D | chrome.dart | 181 }) : _process = process,
185 final Process _process;
199 _process?.kill();
200 await _process?.exitCode;
|
| /third_party/python/Lib/multiprocessing/ |
| D | managers.py | 555 self._process = self._ctx.Process(
560 ident = ':'.join(str(i) for i in self._process._identity)
561 self._process.name = type(self).__name__ + '-' + ident
562 self._process.start()
573 args=(self._process, self._address, self._authkey,
617 if self._process is not None:
618 self._process.join(timeout)
619 if not self._process.is_alive():
620 self._process = None
|
| /third_party/json/third_party/amalgamate/ |
| D | amalgamate.py | 249 def _process(self): member in TranslationUnit
267 self._process()
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/ios/ |
| D | devices.dart | 536 Process _process;
546 _process = process;
547 …_process.stdout.transform<String>(utf8.decoder).transform<String>(const LineSplitter()).listen(_ne…
548 …_process.stderr.transform<String>(utf8.decoder).transform<String>(const LineSplitter()).listen(_ne…
549 _process.exitCode.whenComplete(() {
588 _process?.kill();
|
| /third_party/boost/libs/graph_parallel/doc/ |
| D | simple_trigger.rst | 64 .. _process group: process_group.html
|
| D | mpi_bsp_process_group.rst | 125 .. _process group: process_group.html
|
| D | index.rst | 117 .. _process groups: process_group.html
|
| /third_party/flutter/flutter/packages/flutter_tools/lib/src/android/ |
| D | android_device.dart | 798 Process _process;
825 _process = process;
829 …_process.stdout.transform<String>(decoder).transform<String>(const LineSplitter()).listen(_onLine);
830 …_process.stderr.transform<String>(decoder).transform<String>(const LineSplitter()).listen(_onLine);
831 _process.exitCode.whenComplete(() {
943 _process?.kill();
|
| /third_party/node/benchmark/ |
| D | README.md | 21 | child\_process | Benchmarks for the `child_process` subsystem. …
|