This is an automated email from the ASF dual-hosted git repository.
weichiu 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 d9a1662494 HDDS-7781. Change Get Key Info to return HSync info (#4460)
d9a1662494 is described below
commit d9a1662494268cae93a2ea25f49dfefb52854876
Author: Wei-Chiu Chuang <[email protected]>
AuthorDate: Tue Mar 28 08:29:51 2023 -0700
HDDS-7781. Change Get Key Info to return HSync info (#4460)
---
.../src/main/java/org/apache/hadoop/ozone/om/helpers/OmKeyInfo.java | 4 ++++
.../test/java/org/apache/hadoop/ozone/om/helpers/TestOmKeyInfo.java | 6 ++++++
2 files changed, 10 insertions(+)
diff --git
a/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/helpers/OmKeyInfo.java
b/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/helpers/OmKeyInfo.java
index 4bb6050697..752e5b04d3 100644
---
a/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/helpers/OmKeyInfo.java
+++
b/hadoop-ozone/common/src/main/java/org/apache/hadoop/ozone/om/helpers/OmKeyInfo.java
@@ -190,6 +190,10 @@ public final class OmKeyInfo extends WithParentObjectId {
return isFile;
}
+ public boolean isHsync() {
+ return metadata.containsKey(OzoneConsts.HSYNC_CLIENT_ID);
+ }
+
/**
* updates the length of the each block in the list given.
* This will be called when the key is being committed to OzoneManager.
diff --git
a/hadoop-ozone/common/src/test/java/org/apache/hadoop/ozone/om/helpers/TestOmKeyInfo.java
b/hadoop-ozone/common/src/test/java/org/apache/hadoop/ozone/om/helpers/TestOmKeyInfo.java
index f4e5fc9932..0d421dc152 100644
---
a/hadoop-ozone/common/src/test/java/org/apache/hadoop/ozone/om/helpers/TestOmKeyInfo.java
+++
b/hadoop-ozone/common/src/test/java/org/apache/hadoop/ozone/om/helpers/TestOmKeyInfo.java
@@ -27,6 +27,7 @@ import org.apache.hadoop.hdds.scm.pipeline.Pipeline;
import org.apache.hadoop.hdds.scm.pipeline.PipelineID;
import org.apache.hadoop.ozone.ClientVersion;
import org.apache.hadoop.ozone.OzoneAcl;
+import org.apache.hadoop.ozone.OzoneConsts;
import org.apache.hadoop.ozone.om.helpers.OmKeyInfo.Builder;
import org.apache.hadoop.ozone.protocol.proto.OzoneManagerProtocolProtos;
import org.apache.hadoop.ozone.security.acl.IAccessAuthorizer;
@@ -59,6 +60,10 @@ public class TestOmKeyInfo {
key.getProtobuf(ClientVersion.CURRENT_VERSION));
Assert.assertEquals(key, keyAfterSerialization);
+
+ Assert.assertFalse(key.isHsync());
+ key.getMetadata().put(OzoneConsts.HSYNC_CLIENT_ID, "clientid");
+ Assert.assertTrue(key.isHsync());
}
@Test
@@ -82,6 +87,7 @@ public class TestOmKeyInfo {
// EC Config
key = createOmKeyInfo(new ECReplicationConfig(3, 2));
+ Assert.assertFalse(key.isHsync());
omKeyProto = key.getProtobuf(ClientVersion.CURRENT_VERSION);
Assert.assertEquals(3, omKeyProto.getEcReplicationConfig().getData());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
