Method init

solr/core/src/java/org/apache/solr/update/UpdateLog.java:378–405

(PluginInfo info)

  }

  @Override
  public void init(PluginInfo info) {
    dataDir = (String) info.initArgs.get("dir");
    defaultSyncLevel = SyncLevel.getSyncLevel((String) info.initArgs.get("syncLevel"));

    numRecordsToKeep = objToInt(info.initArgs.get("numRecordsToKeep"), 100);
    maxNumLogsToKeep = objToInt(info.initArgs.get("maxNumLogsToKeep"), 10);
    if (info.initArgs.get("numVersionBuckets") != null) {
      log.warn("numVersionBuckets is obsolete");
    }

    if (info.initArgs.get("versionBucketLockTimeoutMs") != null) {
      log.warn("versionBucketLockTimeoutMs is mostly replaced by docLockTimeoutMs");
    }
    int timeoutMs =
        objToInt(
            info.initArgs.getOrDefault(
                "docLockTimeoutMs", info.initArgs.get("versionBucketLockTimeoutMs")),
            EnvUtils.getPropertyAsLong("solr.update.docLockTimeoutMs", 0L).intValue());
    updateLocks = new UpdateLocks(timeoutMs);

    log.info(
        "Initializing UpdateLog: dataDir={} defaultSyncLevel={} numRecordsToKeep={} maxNumLogsToKeep={}",
        dataDir,
        defaultSyncLevel,
        numRecordsToKeep,
        maxNumLogsToKeep);
  }

  private final AtomicBoolean initialized = new AtomicBoolean();