Method wait_until_sent

implementation/endpoints/src/tcp_client_endpoint_impl.cpp:783–804

}

void tcp_client_endpoint_impl::wait_until_sent(const boost::system::error_code& _error) {
    if (_error && _error != boost::asio::error::operation_aborted) {
        // This Function is usually called with boost::asio::error::operation_aborted
        // and therefore its part of its normal execution path.
        VSOMEIP_WARNING_P << _error.value() << ", message: " << _error.message();
    }
    std::unique_lock<std::recursive_mutex> its_lock(mutex_);
    if (!is_sending_ || !_error) {
        its_lock.unlock();
        if (!_error)
            VSOMEIP_WARNING_P << "Maximum wait time for send operation exceeded for tce.";

        std::shared_ptr<boardnet_endpoint_host> its_ep_host = endpoint_host_.lock();
        its_ep_host->on_disconnect(shared_from_this());
        restart(true);
    } else {
        std::chrono::milliseconds its_timeout(VSOMEIP_MAX_TCP_SENT_WAIT_TIME);
        sent_timer_.expires_after(its_timeout);
        sent_timer_.async_wait(std::bind(&tcp_client_endpoint_impl::wait_until_sent,
                                         std::dynamic_pointer_cast<tcp_client_endpoint_impl>(shared_from_this()), std::placeholders::_1));
    }
}

} // namespace vsomeip_v3