Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
smengcl committed Aug 10, 2023
1 parent 55b932f commit d058d50
Show file tree
Hide file tree
Showing 3 changed files with 14 additions and 26 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -151,10 +151,8 @@ public OMClientResponse validateAndUpdateCache(OzoneManager ozoneManager,
omMetrics.incNumKeyCommits();
}

if (LOG.isDebugEnabled()) {
LOG.debug("isHSync = {}, volumeName = {}, bucketName = {}, keyName = {}",
isHSync, volumeName, bucketName, keyName);
}
LOG.debug("isHSync = {}, volumeName = {}, bucketName = {}, keyName = {}",
isHSync, volumeName, bucketName, keyName);

try {
commitKeyArgs = resolveBucketLink(ozoneManager, commitKeyArgs, auditMap);
Expand Down Expand Up @@ -324,11 +322,9 @@ public OMClientResponse validateAndUpdateCache(OzoneManager ozoneManager,
processResult(commitKeyRequest, volumeName, bucketName, keyName,
omMetrics, exception, omKeyInfo, result);
} else {
// Debug logging for HSync
if (LOG.isDebugEnabled()) {
LOG.debug("Key successfully committed with isHSync = {}, " +
"omKeyInfo = {}", isHSync, omKeyInfo);
}
// Debug logging for HSync key commits
LOG.debug("Key successfully committed with isHSync = {}, " +
"omKeyInfo = {}", isHSync, omKeyInfo);
}

return omClientResponse;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -108,10 +108,8 @@ public OMClientResponse validateAndUpdateCache(OzoneManager ozoneManager,
omMetrics.incNumKeyCommits();
}

if (LOG.isDebugEnabled()) {
LOG.debug("isHSync = {}, volumeName = {}, bucketName = {}, keyName = {}",
isHSync, volumeName, bucketName, keyName);
}
LOG.debug("isHSync = {}, volumeName = {}, bucketName = {}, keyName = {}",
isHSync, volumeName, bucketName, keyName);

OMMetadataManager omMetadataManager = ozoneManager.getMetadataManager();

Expand Down Expand Up @@ -279,11 +277,9 @@ public OMClientResponse validateAndUpdateCache(OzoneManager ozoneManager,
processResult(commitKeyRequest, volumeName, bucketName, keyName,
omMetrics, exception, omKeyInfo, result);
} else {
// Debug logging for HSync
if (LOG.isDebugEnabled()) {
LOG.debug("Key successfully committed with isHSync = {}, " +
"omKeyInfo = {}", isHSync, omKeyInfo);
}
// Debug logging for HSync key commits
LOG.debug("Key successfully committed with isHSync = {}, " +
"omKeyInfo = {}", isHSync, omKeyInfo);
}

return omClientResponse;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -863,10 +863,8 @@ protected OmKeyInfo wrapUncommittedBlocksAsPseudoKey(
protected void filterOutBlocksStillInUse(OmKeyInfo referenceKey,
RepeatedOmKeyInfo keysToBeFiltered) {

if (LOG.isDebugEnabled()) {
LOG.debug("Before block filtering, keysToBeFiltered = {}",
keysToBeFiltered);
}
LOG.debug("Before block filtering, keysToBeFiltered = {}",
keysToBeFiltered);

// A HashSet for fast lookup. Gathers all ContainerBlockID entries inside
// the referenceKey.
Expand Down Expand Up @@ -944,9 +942,7 @@ protected void filterOutBlocksStillInUse(OmKeyInfo referenceKey,
}
}

if (LOG.isDebugEnabled()) {
LOG.debug("After block filtering, keysToBeFiltered = {}",
keysToBeFiltered);
}
LOG.debug(" After block filtering, keysToBeFiltered = {}",
keysToBeFiltered);
}
}

0 comments on commit d058d50

Please sign in to comment.