std::deque<CommImplPtr> comm_queue_;
// messages already received in the permanent receive mode
std::deque<CommImplPtr> done_comm_queue_;
std::deque<CommImplPtr> comm_queue_;
// messages already received in the permanent receive mode
std::deque<CommImplPtr> done_comm_queue_;