code: @Override
    public boolean waitForQueues(long timeout, TimeUnit unit) {
      CountDownLatch blatch = broadcastOp(new BroadcastOpFactory() {
        @Override
        public Operation newOp(final MemcachedNode n,
            final CountDownLatch latch) {
          return opFact.noop(new OperationCallback() {
            @Override
            public void complete() {
              latch.countDown();
            }
  
            @Override
            public void receivedStatus(OperationStatus s) {
              // Nothing special when receiving status, only
              // necessary to complete the interface
            }
          });
        }
      }, mconn.getLocator().getAll(), false);
      try {
        // XXX: Perhaps IllegalStateException should be caught here
        // and the check retried.
        return blatch.await(timeout, unit);
      } catch (InterruptedException e) {
        throw new RuntimeException("Interrupted waiting for queues", e);
      }
    }
docs: Wait for the queues to die down.
  
  @param timeout the amount of time time for shutdown
  @param unit the TimeUnit for the timeout
  @return result of the request for the wait
  @throws IllegalStateException in the rare circumstance where queue is too
  full to accept any more requests