Method asyncSendPendingMsg

src/io/network/endpoint.cc:537–554

}

void NetworkThread::asyncSendPendingMsg(EndPoint *ep) {
  // simply put the pending msgs to the send queue

  LOG(INFO) << "There are " << ep->send_.size() << " to-send msgs, and "
            << ep->to_ack_.size() << " to-ack msgs";

  if (!ep->to_ack_.empty()) {
    while (!ep->send_.empty()) {
      ep->to_ack_.push(ep->send_.front());
      ep->send_.pop();
    }
    std::swap(ep->send_, ep->to_ack_);
  }

  if (ep->send_.size() > 0) {
    notify(SIG_MSG);
  }
}

/**
 * @brief non-locking send;