| 265 | tot_files = okay_files = failed_files = verify_failed_files = 0 |
| 266 | |
| 267 | def process_func(): |
| 268 | (tot_files, okay_files, failed_files, verify_failed_files) = ( |
| 269 | 0, |
| 270 | 0, |
| 271 | 0, |
| 272 | 0, |
| 273 | ) |
| 274 | try: |
| 275 | while 1: |
| 276 | f = fqueue.get() |
| 277 | if f is None: |
| 278 | break |
| 279 | (t, o, f, v) = main(src_base, out_base, [f], [], outfile) |
| 280 | tot_files += t |
| 281 | okay_files += o |
| 282 | failed_files += f |
| 283 | verify_failed_files += v |
| 284 | except (Empty, KeyboardInterrupt): |
| 285 | pass |
| 286 | rqueue.put((tot_files, okay_files, failed_files, verify_failed_files)) |
| 287 | rqueue.close() |
| 288 | |
| 289 | try: |
| 290 | procs = [Process(target=process_func) for i in range(numproc)] |