equal
deleted
inserted
replaced
137 self.timeout = Timer(timeout, self.endlog) |
137 self.timeout = Timer(timeout, self.endlog) |
138 self.timeout.start() |
138 self.timeout.start() |
139 else: |
139 else: |
140 self.timeout = None |
140 self.timeout = None |
141 |
141 |
|
142 if _debug: |
|
143 self.logger.write("(DEBUG) launching:\n" + self.Command_str + "\n") |
|
144 |
142 self.Proc = subprocess.Popen(self.Command, **popenargs) |
145 self.Proc = subprocess.Popen(self.Command, **popenargs) |
143 |
146 |
144 self.outt = outputThread( |
147 self.outt = outputThread( |
145 self.Proc, |
148 self.Proc, |
146 self.Proc.stdout, |
149 self.Proc.stdout, |
189 self.startsem.acquire() |
192 self.startsem.acquire() |
190 self.startsem.release() |
193 self.startsem.release() |
191 if self.timeout: |
194 if self.timeout: |
192 self.timeout.cancel() |
195 self.timeout.cancel() |
193 self.exitcode = ecode |
196 self.exitcode = ecode |
194 if _debug or self.exitcode != 0: |
197 if self.exitcode != 0: |
195 self.log_the_end(ecode, pid) |
198 self.log_the_end(ecode, pid) |
196 if self.finish_callback is not None: |
199 if self.finish_callback is not None: |
197 self.finish_callback(self, ecode, pid) |
200 self.finish_callback(self, ecode, pid) |
198 self.errt.join() |
201 self.errt.join() |
199 self.finishsem.release() |
202 self.finishsem.release() |