| 620 | } |
| 621 | |
| 622 | void DFB::scheduleProcessing(const std::shared_ptr<mpicommon::Message> &message) |
| 623 | { |
| 624 | tasking::schedule([=]() { |
| 625 | auto *msg = (TileMessage *)message->data; |
| 626 | if (msg->command & MASTER_WRITE_TILE) { |
| 627 | throw std::runtime_error("#dfb: master msg should not be scheduled!"); |
| 628 | } else if (msg->command & WORKER_WRITE_TILE) { |
| 629 | this->processMessage((WriteTileMessage *)msg); |
| 630 | } else if (msg->command & PROGRESS_MESSAGE) { |
| 631 | updateProgress((ProgressMessage *)msg); |
| 632 | } else { |
| 633 | throw std::runtime_error("#dfb: unknown tile type processed!"); |
| 634 | } |
| 635 | }); |
| 636 | } |
| 637 | |
| 638 | void DFB::gatherFinalTiles() |
| 639 | { |
nothing calls this directly
no test coverage detected