Process.hx 2.6 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. /*
  2. * Copyright (C)2005-2017 Haxe Foundation
  3. *
  4. * Permission is hereby granted, free of charge, to any person obtaining a
  5. * copy of this software and associated documentation files (the "Software"),
  6. * to deal in the Software without restriction, including without limitation
  7. * the rights to use, copy, modify, merge, publish, distribute, sublicense,
  8. * and/or sell copies of the Software, and to permit persons to whom the
  9. * Software is furnished to do so, subject to the following conditions:
  10. *
  11. * The above copyright notice and this permission notice shall be included in
  12. * all copies or substantial portions of the Software.
  13. *
  14. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  15. * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  16. * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  17. * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  18. * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  19. * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
  20. * DEALINGS IN THE SOFTWARE.
  21. */
  22. package sys.io;
  23. import python.io.IoTools;
  24. import python.lib.io.BufferedReader;
  25. import python.lib.io.BufferedWriter;
  26. import python.lib.io.TextIOWrapper;
  27. import python.lib.Subprocess;
  28. import python.lib.subprocess.Popen;
  29. class Process {
  30. public var stdout(default,null) : haxe.io.Input;
  31. public var stderr(default,null) : haxe.io.Input;
  32. public var stdin(default,null) : haxe.io.Output;
  33. var p:Popen;
  34. public function new( cmd : String, ?args : Array<String> ) : Void {
  35. p = Popen.create(args == null ? cmd : [cmd].concat(args), { shell : args == null, stdin : Subprocess.PIPE, stdout: Subprocess.PIPE, stderr : Subprocess.PIPE });
  36. this.stdout = IoTools.createFileInputFromText(new TextIOWrapper(new BufferedReader(p.stdout)));
  37. this.stderr = IoTools.createFileInputFromText(new TextIOWrapper(new BufferedReader(p.stderr)));
  38. this.stdin = IoTools.createFileOutputFromText(new TextIOWrapper(new BufferedWriter(p.stdin)));
  39. }
  40. public function getPid() : Int {
  41. return p.pid;
  42. }
  43. public function exitCode( block : Bool = true ) : Null<Int> {
  44. if( block == false )
  45. return p.poll();
  46. return p.wait();
  47. }
  48. public function close() : Void {
  49. var ver = python.lib.Sys.version_info;
  50. if (ver[0] > 3 || (ver[0] == 3 && ver[1] >= 3)) // >= 3.3
  51. try {
  52. p.terminate();
  53. } catch (e:python.Exceptions.ProcessLookupError) {
  54. // it has already terminated
  55. }
  56. else
  57. try {
  58. p.terminate();
  59. } catch (e:python.Exceptions.OSError) {
  60. // it has already terminated
  61. }
  62. }
  63. public function kill() : Void {
  64. p.kill();
  65. }
  66. }