private synchronized void switchReader()

in src/main/java/com/spotify/sparkey/extra/ReloadableSparkeyReader.java [115:133]

• 15 lines of code
• 4 McCabe index (conditional complexity)

  private synchronized void switchReader(File logFile) {
    if (this.currentLogFile != null && this.currentLogFile.equals(logFile)) {
      log.debug("ignore reload (same log file)");
      return;
    }

    SparkeyReader newReader = createFromLogFile(logFile);
    SparkeyReader toClose = this.reader;

    this.currentLogFile = logFile;
    this.reader = newReader;

    long keys = reader.getLogHeader().getNumPuts() - reader.getLogHeader().getNumDeletes();
    log.info("loaded sparkey index {}, {} keys", logFile.getAbsolutePath(), keys);

    if (toClose != null) {
      toClose.close();
    }
  }