@Override
    boolean waitForData() {
      region.getCache().getCancelCriterion().checkCancelInProgress(null);
      boolean interrupted = Thread.currentThread().isInterrupted();
      try {
        blockCond.await(StoppableCondition.TIME_TO_WAIT);
      } catch (InterruptedException ie) {
        interrupted = true;
        region.getCache().getCancelCriterion().checkCancelInProgress(ie);
        throw new TimeoutException(ie);
      } finally {
        if (interrupted) {
          Thread.currentThread().interrupt();
        }
      }
      return !internalIsEmpty();
    }
Identical to the releaseReadLock as there is only one type of Lock object in this class.

<p>
author Asif
geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java