Method poll

src/IO/ReadBufferFromPocoSocket.cpp:143–155

}

bool ReadBufferFromPocoSocketBase::poll(size_t timeout_microseconds)
{
    /// For secure socket it is important to check if any remaining data available in underlying decryption buffer -
    /// read always retrieves the whole encrypted frame from the wire and puts it into underlying buffer while returning only requested size -
    /// further poll() can block though there is still data to read in the underlying decryption buffer.
    if (available() || socket.impl()->available())
        return true;

    Stopwatch watch;
    bool res = socket.impl()->poll(timeout_microseconds, Poco::Net::Socket::SELECT_READ | Poco::Net::Socket::SELECT_ERROR);
    ProfileEvents::increment(ProfileEvents::NetworkReceiveElapsedMicroseconds, watch.elapsedMicroseconds());
    return res;
}

void ReadBufferFromPocoSocketBase::setReceiveTimeout(size_t receive_timeout_microseconds)
{