* under the terms of the license (GNU LGPL) which comes with this package. */
#include "src/kernel/activity/MailboxImpl.hpp"
* under the terms of the license (GNU LGPL) which comes with this package. */
#include "src/kernel/activity/MailboxImpl.hpp"
while (not comm_queue_.empty()) {
auto comm = comm_queue_.back();
if (comm->get_state() == State::WAITING && not comm->is_detached()) {
comm->cancel();
while (not comm_queue_.empty()) {
auto comm = comm_queue_.back();
if (comm->get_state() == State::WAITING && not comm->is_detached()) {
comm->cancel();
}
CommImplPtr MailboxImpl::iprobe(int type, const std::function<bool(void*, void*, CommImpl*)>& match_fun, void* data)
}
CommImplPtr MailboxImpl::iprobe(int type, const std::function<bool(void*, void*, CommImpl*)>& match_fun, void* data)