* ParallelSlotsWaitCompletion * * Wait for all connections to finish, returning false if at least one * error has been found on the way. */
| 470 | * error has been found on the way. |
| 471 | */ |
| 472 | bool |
| 473 | ParallelSlotsWaitCompletion(ParallelSlotArray *sa) |
| 474 | { |
| 475 | int i; |
| 476 | |
| 477 | for (i = 0; i < sa->numslots; i++) |
| 478 | { |
| 479 | if (sa->slots[i].connection == NULL) |
| 480 | continue; |
| 481 | if (!consumeQueryResult(&sa->slots[i])) |
| 482 | return false; |
| 483 | } |
| 484 | |
| 485 | return true; |
| 486 | } |
| 487 | |
| 488 | /* |
| 489 | * TableCommandResultHandler |
no test coverage detected