(out, returncode)
| 1282 | write_lock = Lock() |
| 1283 | |
| 1284 | def write_output(out, returncode): |
| 1285 | if returncode != 0: |
| 1286 | error.set() |
| 1287 | |
| 1288 | with write_lock: |
| 1289 | sys.stdout.buffer.write(out + b"\n") |
| 1290 | sys.stdout.buffer.flush() |
| 1291 | |
| 1292 | def tfunc(): |
| 1293 | while not error.is_set(): |