File: process.py

package info (click to toggle)
chromium-browser 41.0.2272.118-1
  • links: PTS, VCS
  • area: main
  • in suites: jessie-kfreebsd
  • size: 2,189,132 kB
  • sloc: cpp: 9,691,462; ansic: 3,341,451; python: 712,689; asm: 518,779; xml: 208,926; java: 169,820; sh: 119,353; perl: 68,907; makefile: 28,311; yacc: 13,305; objc: 11,385; tcl: 3,186; cs: 2,225; sql: 2,217; lex: 2,215; lisp: 1,349; pascal: 1,256; awk: 407; ruby: 155; sed: 53; php: 14; exp: 11
file content (67 lines) | stat: -rw-r--r-- 1,943 bytes parent folder | download | duplicates (3)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
#!/usr/bin/python
# Copyright (c) 2012 The Native Client Authors. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.

"""Recipes for NativeClient toolchain packages.

The real entry plumbing is in toolchain_main.py.
"""

import os
import StringIO
import subprocess
import sys
import tempfile

class Process(object):
  def __init__(self, args, cwd=None, shell=False, env=None, pipe=True):
    print 'IN CWD=%s' % str(cwd)
    self.args = args
    self.cwd = cwd or os.getcwd()
    self.shell = shell
    self.env = env
    print 'CWD=' + self.cwd
    try:
      if not pipe:
        self.proc = subprocess.Popen(self.args,
                                     shell=self.shell,
                                     cwd=self.cwd,
                                     env=self.env)
      else:
        self.proc = subprocess.Popen(self.args,
                                     shell=self.shell,
                                     stdout=subprocess.PIPE,
                                     stderr=subprocess.PIPE,
                                     cwd=self.cwd,
                                     env=self.env)
    except:
      print 'Failed to run:\n\t%s> %s' % (self.cwd, ' '.join(self.args))
      raise

  def Run(self, outfile=None, verbose=True):
    if self.proc:
      out, err = self.proc.communicate()
      if outfile:
        if verbose:
          outfile.write(' '.join(self.args) + '\n')
        if out:
          outfile.write(out)
        if err:
          outfile.write(err)
      return self.proc.returncode
    return -1


def Start(args, cwd=None, shell=False, env=None):
  return Process(args, cwd, sell, env)


def Run(args, cwd=None, shell=False, env=None, outfile=None, verbose=True):
  return Process(args, cwd, shell, env, outfile).Run(outfile, verbose)


def WaitForAll(procs, outfile=None):
  for proc in procs:
    proc.Run(outfile)