提升 mpi 请求m_handler的目的是什么

What is the purpose of boost mpi request's m_handler

本文关键字：是什么 handler mpi 请求 提升      更新时间：2023-10-16

我正在尝试测试一个 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函数中的代码，并意识到由于条件"first->m_handler"（以下代码中的第 5 行），它返回 false。 

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是干什么用的。

MPI 不支持本质上复杂的C++对象，例如 std::string 。这就是为什么 Boost.MPI 在以 MPI 消息的形式传递这些对象时对其进行序列化并相应地反序列化的原因。从语义的角度来看，一旦收到数据并正确填充std::string对象，irecv()启动的非阻塞操作就应该完成。处理收到的消息并对其进行反序列化的附加步骤由一个特殊的处理程序方法执行，其指针存储在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++对象上进行操作时。在这种情况下，不会附加处理程序，但类数据以两个单独消息的形式发送，并且要特别注意完成这两个发送。这就是第二个布尔表达式（m_requests[1] != MPI_REQUEST_NULL）的用途。

相关文章：