You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by si...@apache.org on 2023/05/24 01:21:50 UTC
[ozone] branch master updated: HDDS-7598. Quota for snapshot handling (#4704)
This is an automated email from the ASF dual-hosted git repository.
siyao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new c848b1601e HDDS-7598. Quota for snapshot handling (#4704)
c848b1601e is described below
commit c848b1601e5fdb09971150f1643818670f0de769
Author: Sumit Agrawal <su...@gmail.com>
AuthorDate: Wed May 24 06:51:44 2023 +0530
HDDS-7598. Quota for snapshot handling (#4704)
---
.../om/response/key/OMDirectoriesPurgeResponseWithFSO.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
index 2314d93adf..a82ccc9d6e 100644
--- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
+++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/response/key/OMDirectoriesPurgeResponseWithFSO.java
@@ -85,6 +85,13 @@ public class OMDirectoriesPurgeResponseWithFSO extends OmKeyResponse {
} else {
processPaths(metadataManager, batchOp);
}
+
+ // update bucket quota in active db
+ for (OmBucketInfo omBucketInfo : volBucketInfoMap.values()) {
+ metadataManager.getBucketTable().putWithBatch(batchOp,
+ metadataManager.getBucketKey(omBucketInfo.getVolumeName(),
+ omBucketInfo.getBucketName()), omBucketInfo);
+ }
}
public void processPaths(OMMetadataManager omMetadataManager,
@@ -151,13 +158,6 @@ public class OMDirectoriesPurgeResponseWithFSO extends OmKeyResponse {
LOG.info("Purge Deleted Directory DBKey: {}", path.getDeletedDir());
}
}
-
- // update bucket usedBytes.
- for (OmBucketInfo omBucketInfo : volBucketInfoMap.values()) {
- omMetadataManager.getBucketTable().putWithBatch(batchOperation,
- omMetadataManager.getBucketKey(omBucketInfo.getVolumeName(),
- omBucketInfo.getBucketName()), omBucketInfo);
- }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org