| 471 | // ---------------------------------------------------------------------------------------- |
| 472 | |
| 473 | void bsp_context:: |
| 474 | send_data( |
| 475 | const std::vector<char>& item, |
| 476 | unsigned long target_node_id |
| 477 | ) |
| 478 | { |
| 479 | using namespace impl2; |
| 480 | if (_cons[target_node_id]->terminated) |
| 481 | throw socket_error("Attempt to send a message to a node that has terminated."); |
| 482 | |
| 483 | serialize(MESSAGE_HEADER, _cons[target_node_id]->stream); |
| 484 | serialize(current_epoch, _cons[target_node_id]->stream); |
| 485 | serialize(item, _cons[target_node_id]->stream); |
| 486 | _cons[target_node_id]->stream.flush(); |
| 487 | |
| 488 | notify_control_node(SENT_MESSAGE); |
| 489 | } |
| 490 | |
| 491 | // ---------------------------------------------------------------------------------------- |
| 492 |
nothing calls this directly
no test coverage detected