import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public void close()
{
    try
    {
        FBUtilities.waitOnFutures(repairResults, DatabaseDescriptor.getWriteRpcTimeout());
    }
    catch (TimeoutException ex)
    {
        // We got all responses, but timed out while repairing
        int blockFor = consistency.blockFor(keyspace);
        if (Tracing.isTracing())
            Tracing.trace("Timed out while read-repairing after receiving all {} data and digest responses", blockFor);
        else
            logger.debug("Timeout while read-repairing after receiving all {} data and digest responses", blockFor);

        throw new ReadTimeoutException(consistency, blockFor-1, blockFor, true);
    }
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public TResolved get() throws ReadTimeoutException, DigestMismatchException
{
    long timeout = command.getTimeout() - (System.currentTimeMillis() - startTime);
    boolean success;
    try
    {
        success = condition.await(timeout, TimeUnit.MILLISECONDS);
    }
    catch (InterruptedException ex)
    {
        throw new AssertionError(ex);
    }

    if (!success)
        throw new ReadTimeoutException(consistencyLevel, received.get(), blockfor, resolver.isDataPresent());

    return blockfor == 1 ? resolver.getData() : resolver.resolve();
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public TResolved get() throws ReadTimeoutException, DigestMismatchException
{
    if (!await(command.getTimeout(), TimeUnit.MILLISECONDS))
    {
        // Same as for writes, see AbstractWriteResponseHandler
        int acks = received;
        if (resolver.isDataPresent() && acks >= blockfor)
            acks = blockfor - 1;
        ReadTimeoutException ex = new ReadTimeoutException(consistencyLevel, received, blockfor, resolver.isDataPresent());
        if (logger.isDebugEnabled())
            logger.debug("Read timeout: {}", ex.toString());
        throw ex;
    }

    return blockfor == 1 ? resolver.getData() : resolver.resolve();
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public TResolved get() throws ReadTimeoutException, DigestMismatchException
{
    long timeout = command.getTimeout() - (System.currentTimeMillis() - startTime);
    boolean success;
    try
    {
        success = condition.await(timeout, TimeUnit.MILLISECONDS);
    }
    catch (InterruptedException ex)
    {
        throw new AssertionError(ex);
    }

    if (!success)
    {
        // Same as for writes, see AbstractWriteResponseHandler
        int acks = received.get();
        if (resolver.isDataPresent() && acks >= blockfor)
            acks = blockfor - 1;
        throw new ReadTimeoutException(consistencyLevel, acks, blockfor, resolver.isDataPresent());
    }

    return blockfor == 1 ? resolver.getData() : resolver.resolve();
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public TResolved get() throws ReadTimeoutException, DigestMismatchException
{
    if (!await(command.getTimeout(), TimeUnit.MILLISECONDS))
    {
        // Same as for writes, see AbstractWriteResponseHandler
        ReadTimeoutException ex = new ReadTimeoutException(consistencyLevel, received, blockfor, resolver.isDataPresent());

        if (logger.isDebugEnabled())
            logger.debug("Read timeout: {}", ex.toString());
        throw ex;
    }

    return blockfor == 1 ? resolver.getData() : resolver.resolve();
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public TResolved get() throws ReadTimeoutException, DigestMismatchException
{
    if (!await(command.getTimeout(), TimeUnit.MILLISECONDS))
    {
        ReadTimeoutException ex = new ReadTimeoutException(consistencyLevel, received.get(), blockfor, resolver.isDataPresent());
        if (logger.isDebugEnabled())
            logger.debug("Read timeout: {}", ex.toString());
        throw ex;
    }

    return blockfor == 1 ? resolver.getData() : resolver.resolve();
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
public PartitionIterator get() throws ReadFailureException, ReadTimeoutException, DigestMismatchException
{
    awaitResults();

    PartitionIterator result = blockfor == 1 ? resolver.getData() : resolver.resolve();
    if (logger.isTraceEnabled())
        logger.trace("Read: {} ms.", TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start));
    return result;
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
/**
 * wait for an answer.  Blocks until success or timeout, so it is caller's
 * responsibility to call maybeTryAdditionalReplicas first.
 */
public Row get() throws ReadTimeoutException, DigestMismatchException
{
    return handler.get();
}
 

import org.apache.cassandra.exceptions.ReadTimeoutException; //导入依赖的package包/类
/**
 * wait for an answer.  Blocks until success or timeout, so it is caller's
 * responsibility to call maybeTryAdditionalReplicas first.
 */
public PartitionIterator get() throws ReadFailureException, ReadTimeoutException, DigestMismatchException
{
    return handler.get();
}