| 617 | |
| 618 | static int is_running_queue; |
| 619 | static int fill_active_slot(void *data UNUSED) |
| 620 | { |
| 621 | struct transfer_request *request; |
| 622 | |
| 623 | if (aborted || !is_running_queue) |
| 624 | return 0; |
| 625 | |
| 626 | for (request = request_queue_head; request; request = request->next) { |
| 627 | if (request->state == NEED_FETCH) { |
| 628 | start_fetch_loose(request); |
| 629 | return 1; |
| 630 | } else if (pushing && request->state == NEED_PUSH) { |
| 631 | if (remote_dir_exists[request->obj->oid.hash[0]] == 1) { |
| 632 | start_put(request); |
| 633 | } else { |
| 634 | start_mkcol(request); |
| 635 | } |
| 636 | return 1; |
| 637 | } |
| 638 | } |
| 639 | return 0; |
| 640 | } |
| 641 | |
| 642 | static void get_remote_object_list(unsigned char parent); |
| 643 |
nothing calls this directly
no test coverage detected