| 26 | } |
| 27 | |
| 28 | int RNode::submitAndWait(const Task& task, |
| 29 | const Message::Callback& recv_handle) { |
| 30 | MessagePtr msg(new Message(task)); |
| 31 | if (recv_handle) msg->recv_handle = recv_handle; |
| 32 | msg->wait = true; |
| 33 | return submit(msg); |
| 34 | } |
| 35 | |
| 36 | int RNode::submit(const std::vector<Task>& tasks, |
| 37 | const Message::Callback& recv_handle) { |