| 637 | } |
| 638 | |
| 639 | static void write_items_sequentially(struct checkout *state) |
| 640 | { |
| 641 | size_t i; |
| 642 | |
| 643 | for (i = 0; i < parallel_checkout.nr; i++) { |
| 644 | struct parallel_checkout_item *pc_item = ¶llel_checkout.items[i]; |
| 645 | write_pc_item(pc_item, state); |
| 646 | if (pc_item->status != PC_ITEM_COLLIDED) |
| 647 | advance_progress_meter(); |
| 648 | } |
| 649 | } |
| 650 | |
| 651 | int run_parallel_checkout(struct checkout *state, int num_workers, int threshold, |
| 652 | struct progress *progress, unsigned int *progress_cnt) |
no test coverage detected