| 635 | |
| 636 | |
| 637 | static void transport(Message&& message, ProcessBase* sender = nullptr) |
| 638 | { |
| 639 | if (message.to.address == __address__) { |
| 640 | // Local message. |
| 641 | MessageEvent* event = new MessageEvent(std::move(message)); |
| 642 | process_manager->deliver(event->message.to, event, sender); |
| 643 | } else { |
| 644 | // Remote message. |
| 645 | socket_manager->send(std::move(message)); |
| 646 | } |
| 647 | } |
| 648 | |
| 649 | |
| 650 | static void transport( |