public static List getOmKeyLocationInfos()

in hadoop-ozone/ozonefs-common/src/main/java/org/apache/hadoop/fs/ozone/LeaseRecoveryClientDNHandler.java [52:120]
57 lines of code
21 McCabe index (conditional complexity)

  public static List<OmKeyLocationInfo> getOmKeyLocationInfos(LeaseKeyInfo leaseKeyInfo,
      OzoneClientAdapter adapter, boolean forceRecovery) throws IOException {
    OmKeyLocationInfoGroup keyLatestVersionLocations = leaseKeyInfo.getKeyInfo().getLatestVersionLocations();
    List<OmKeyLocationInfo> keyLocationInfoList = keyLatestVersionLocations.getLocationList();
    OmKeyLocationInfoGroup openKeyLatestVersionLocations = leaseKeyInfo.getOpenKeyInfo().getLatestVersionLocations();
    List<OmKeyLocationInfo> openKeyLocationInfoList = openKeyLatestVersionLocations.getLocationList();

    int openKeyLocationSize = openKeyLocationInfoList.size();
    int keyLocationSize = keyLocationInfoList.size();
    OmKeyLocationInfo openKeyFinalBlock = null;
    OmKeyLocationInfo openKeyPenultimateBlock = null;
    OmKeyLocationInfo keyFinalBlock;

    if (keyLocationSize > 0) {
      // Block info from fileTable
      keyFinalBlock = keyLocationInfoList.get(keyLocationSize - 1);
      // Block info from openFileTable
      if (openKeyLocationSize > 1) {
        openKeyFinalBlock = openKeyLocationInfoList.get(openKeyLocationSize - 1);
        openKeyPenultimateBlock = openKeyLocationInfoList.get(openKeyLocationSize - 2);
      } else if (openKeyLocationSize > 0) {
        openKeyFinalBlock = openKeyLocationInfoList.get(0);
      }
      // Finalize the final block and get block length
      try {
        // CASE 1: When openFileTable has more block than fileTable
        // Try to finalize last block of openFileTable
        // Add that block into fileTable locationInfo
        if (openKeyLocationSize > keyLocationSize) {
          openKeyFinalBlock.setLength(adapter.finalizeBlock(openKeyFinalBlock));
          keyLocationInfoList.add(openKeyFinalBlock);
        }
        // CASE 2: When openFileTable penultimate block length is not equal to fileTable block length of last block
        // Finalize and get the actual block length and update in fileTable last block
        if ((openKeyPenultimateBlock != null && keyFinalBlock != null) &&
            openKeyPenultimateBlock.getLength() != keyFinalBlock.getLength() &&
            openKeyPenultimateBlock.getBlockID().getLocalID() == keyFinalBlock.getBlockID().getLocalID()) {
          keyFinalBlock.setLength(adapter.finalizeBlock(keyFinalBlock));
        }
        // CASE 3: When openFileTable has same number of blocks as fileTable
        // Finalize and get actual length of fileTable final block
        if (keyLocationInfoList.size() == openKeyLocationInfoList.size() && keyFinalBlock != null) {
          keyFinalBlock.setLength(adapter.finalizeBlock(keyFinalBlock));
        }
      } catch (Throwable e) {
        if (e instanceof StorageContainerException &&
            (((StorageContainerException) e).getResult().equals(NO_SUCH_BLOCK)
            || ((StorageContainerException) e).getResult().equals(CONTAINER_NOT_FOUND))
            && openKeyPenultimateBlock != null && keyFinalBlock != null &&
            openKeyPenultimateBlock.getBlockID().getLocalID() == keyFinalBlock.getBlockID().getLocalID()) {
          try {
            keyFinalBlock.setLength(adapter.finalizeBlock(keyFinalBlock));
          } catch (Throwable exp) {
            if (!forceRecovery) {
              throw exp;
            }
            LOG.warn("Failed to finalize block. Continue to recover the file since {} is enabled.",
                FORCE_LEASE_RECOVERY_ENV, exp);
          }
        } else if (!forceRecovery) {
          throw e;
        } else {
          LOG.warn("Failed to finalize block. Continue to recover the file since {} is enabled.",
              FORCE_LEASE_RECOVERY_ENV, e);
        }
      }
    }
    return keyLocationInfoList;
  }