code: protected void checkDiskError(Exception e ) throws IOException {
      if (e instanceof ClosedByInterruptException
          || e instanceof java.io.InterruptedIOException) {
        return;
      }
      LOG.warn("checkDiskError: exception: ", e);
      
      if (e.getMessage() != null &&
          e.getMessage().startsWith("No space left on device")) {
        throw new DiskOutOfSpaceException("No space left on device");
      } else {
        checkDiskError();
      }
    }
docs: Check if there is no space in disk
  @param e that caused this checkDiskError call