private void checkAndFixReplication() throws ReplicationException, IOException {
    ReplicationChecker checker = new ReplicationChecker(getConf(), zkw, connection, errors);

    if (!checker.checkHasDataInQueues()) {
      return;
    }

    checker.checkUnDeletedQueues();

    if (checker.hasUnDeletedQueues() && this.fixReplication) {
      checker.fixUnDeletedQueues();
      setShouldRerun();
    }
  }
Gets the entry in regionInfo corresponding to the the given encoded region name. If the region
has not been seen yet, a new entry is added and returned.
hbase-server/src/main/java/org/apache/hadoop/hbase/util/HBaseFsck.java