util/pbs/pbs.py

32     def __init__(self, cmd, input = None, output = None, bufsize = -1):
33         self.status = -1
37             self.tochild = os.fdopen(p2c_write, 'w', bufsize)
52             self.fromchild = os.fdopen(c2p_read, 'r', bufsize)
65         self.pid = os.fork()
66         if self.pid == 0:
78     def poll(self):
79         if self.status < 0:
80             pid, status = os.waitpid(self.pid, os.WNOHANG)
81             if pid == self.pid:
82                 self.status = status
83         return self.status
85     def wait(self):
86         if self.status < 0:
87             pid, status = os.waitpid(self.pid, 0)
88             if pid == self.pid:
89                 self.status = status
90         return self.status
93     def __init__(self):
94         self.afterok = None
95         self.hold = False
96         self.join = False
97         self.keep_stdout = False
98         self.keep_stderr = False
99         self.node_type = None
100         self.mail_abort = False
101         self.mail_begin = False
102         self.mail_end = False
103         self.name = None
104         self.stdout = None
105         self.priority = None
106         self.queue = None
107         self.pbshost = None
108         self.qsub = 'qsub'
109         self.env = {}
111     def build(self, script, args = []):
112         self.cmd = [ self.qsub ]
114         if self.env:
116             arg += ','.join([ '%s=%s' % i for i in self.env.iteritems() ])
117             self.cmd.append(arg)
119         if self.hold:
120             self.cmd.append('-h')
122         if self.stdout:
123             self.cmd.append('-olocalhost:' + self.stdout)
125         if self.keep_stdout and self.keep_stderr:
126             self.cmd.append('-koe')
127         elif self.keep_stdout:
128             self.cmd.append('-ko')
129         elif self.keep_stderr:
130             self.cmd.append('-ke')
132             self.cmd.append('-kn')
134         if self.join:
135             self.cmd.append('-joe')
137         if self.node_type:
138             self.cmd.append('-lnodes=' + self.node_type)
140         if self.mail_abort or self.mail_begin or self.mail_end:
142             if self.mail_abort:
144             if self.mail_begin:
146             if self.mail_end:
149                 self.cmd.append('-m ' + flags)
151             self.cmd.append('-mn')
153         if self.name:
154             self.cmd.append("-N%s" % self.name)
156         if self.priority:
157             self.cmd.append('-p' + self.priority)
159         if self.queue:
160             self.cmd.append('-q' + self.queue)
162         if self.afterok:
163             self.cmd.append('-Wdepend=afterok:%s' % self.afterok)
165         self.cmd.extend(args)
166         self.script = script
167         self.command = ' '.join(self.cmd + [ self.script ])
169     def do(self):
170         pbs = MyPOpen(self.cmd + [ self.script ])
171         self.result = pbs.fromchild.read()
174         if ec != 0 and self.pbshost:
175             cmd = ' '.join(self.cmd + [ '-' ])
176             cmd = [ 'ssh', '-x', self.pbshost, cmd ]
177             self.command = ' '.join(cmd)
178             ssh = MyPOpen(cmd, input = self.script)
179             self.result = ssh.fromchild.read()