boost mpi 请求的目的是什么 m_handler

Question

我正在尝试测试一个 mpi 请求是否完成。但是，有一个问题我想不通。如果我使用如下 test_all 方法，那么我会看到请求未完成。

string msg;
boost::mpi::request req = world->irecv(some_rank, 0, msg);

vector<boost::mpi::request> waitingRequests;
waitingRequests.push_back(req);
if(boost::mpi::test_all(waitingRequests.begin(), waitingRequests.end()))
    cout << "test_all done" << endl;

当我尝试此代码时，我看到请求已完成：

string msg;
boost::mpi::request req = world->irecv(some_rank, 0, msg);

if(req.test())
    cout << "test done" << endl;

所以，我查看了 test_all 函数中的代码，并意识到它 returns false 因为条件 "first->m_handler" （下面代码中的第 5 行）。

template<typename ForwardIterator> bool test_all(ForwardIterator first, ForwardIterator last) {
    std::vector<MPI_Request> requests;
    for (; first != last; ++first) {
    // If we have a non-trivial request, then no requests can be completed.
        if (first->m_handler || first->m_requests[1] != MPI_REQUEST_NULL)
            return false;

        requests.push_back(first->m_requests[0]);
    }

    int flag = 0;
    int n = requests.size();
    BOOST_MPI_CHECK_RESULT(MPI_Testall, 
                     (n, &requests[0], &flag, MPI_STATUSES_IGNORE));
    return flag != 0;
}

现在，我想知道 m_handler 是干什么用的。

Answer 1

MPI 不支持本质上复杂的 C++ 对象，例如 std::string。这就是为什么 Boost.MPI 在以 MPI 消息的形式传递这些对象时序列化并相应地反序列化这些对象。从语义的角度来看，由 irecv() 开始的非阻塞操作应该在接收到数据并适当填充 std::string 对象后完成。处理接收到的消息并将其反序列化的附加步骤由特殊的处理程序方法执行，指向该方法的指针存储在 m_handler 变量中：

...
if (m_handler) {
  // This request is a receive for a serialized type. Use the
  // handler to test for completion.
  return m_handler(this, ra_test);
} else ...

简单数据类型不需要这样的处理。

isend() 对 C++ 对象进行操作时也是如此。在这种情况下，不附加处理程序，但 class 数据以两个单独的消息的形式发送，并且要特别注意完成两个发送。这就是第二个布尔表达式 (m_requests[1] != MPI_REQUEST_NULL) 的用途。

boost mpi 请求的目的是什么 m_handler

What is the purpose of boost mpi request's m_handler

c++

asynchronous

boost

request

mpi