Searched refs:my_block_number (Results 1 – 3 of 3) sorted by relevance
| /third_party/boost/boost/graph/distributed/detail/ |
| D | mpi_process_group.ipp | 231 pg.send_impl(dest, pg.encode_tag(pg.my_block_number(), tag), value,
240 pg.send_impl(dest, pg.encode_tag(pg.my_block_number(), tag),
283 pg.array_send_impl(dest, pg.encode_tag(pg.my_block_number(), tag),
312 incoming.next_header[my_block_number()];
329 while (incoming.next_header[my_block_number()] != incoming.headers.end()
330 && incoming.next_header[my_block_number()]->tag == -1)
331 ++incoming.next_header[my_block_number()];
333 if (incoming.next_header[my_block_number()] == incoming.headers.end()) {
361 incoming.next_header[my_block_number()];
376 while (incoming.next_header[my_block_number()] != incoming.headers.end()
[all …]
|
| /third_party/boost/libs/graph_parallel/src/ |
| D | mpi_process_group.cpp | 271 if (my_block_number() >= (int)impl_->incoming[i].next_header.size()) { in mpi_process_group()
275 impl_->incoming[i].next_header[my_block_number()] = in mpi_process_group()
281 std::cerr << "Allocated tag block " << my_block_number() << std::endl; in mpi_process_group()
307 impl_->blocks[my_block_number()]->on_receive = handler; in replace_handler()
313 if (my_block_number() == 0) { in make_distributed_object()
317 if (my_block_number() >= (int)impl_->incoming[i].next_header.size()) { in make_distributed_object()
321 impl_->incoming[i].next_header[my_block_number()] = in make_distributed_object()
327 std::cerr << "Allocated tag block " << my_block_number() << std::endl; in make_distributed_object()
334 .swap(impl_->blocks[my_block_number()]->triggers); in make_distributed_object()
338 impl_->blocks[my_block_number()]->on_receive = 0; in make_distributed_object()
[all …]
|
| /third_party/boost/boost/graph/distributed/ |
| D | mpi_process_group.hpp | 344 int my_block_number() const { return block_num? *block_num : 0; } in my_block_number() function in boost::graph::distributed::mpi_process_group
|