GEODE-9289: Configuration compatibile with pre-1.12.0 versions. (#6592)
* This part of the commit was missed as a part of the original commit
(cherry picked from commit c1e59b23a89d4eac89334f525cd4a8bfaebefe1d)
diff --git a/geode-core/src/integrationTest/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt b/geode-core/src/integrationTest/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
index b45a267..ec0b06e 100644
--- a/geode-core/src/integrationTest/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
+++ b/geode-core/src/integrationTest/resources/org/apache/geode/codeAnalysis/sanctionedDataSerializables.txt
@@ -1954,9 +1954,11 @@
fromData,17
toData,17
-org/apache/geode/management/internal/configuration/domain/Configuration,2
+org/apache/geode/management/internal/configuration/domain/Configuration,4
fromData,112
+fromDataPre_GEODE_1_12_0_0,71
toData,79
+toDataPre_GEODE_1_12_0_0,63
org/apache/geode/management/internal/configuration/domain/ConfigurationChangeResult,2
fromData,31
diff --git a/geode-core/src/main/java/org/apache/geode/management/internal/configuration/domain/Configuration.java b/geode-core/src/main/java/org/apache/geode/management/internal/configuration/domain/Configuration.java
index daeee1e..25720ad 100644
--- a/geode-core/src/main/java/org/apache/geode/management/internal/configuration/domain/Configuration.java
+++ b/geode-core/src/main/java/org/apache/geode/management/internal/configuration/domain/Configuration.java
@@ -37,8 +37,8 @@
import org.w3c.dom.Document;
import org.xml.sax.SAXException;
-import org.apache.geode.DataSerializable;
import org.apache.geode.DataSerializer;
+import org.apache.geode.internal.VersionedDataSerializable;
import org.apache.geode.internal.serialization.Version;
import org.apache.geode.internal.serialization.VersionOrdinal;
import org.apache.geode.internal.serialization.Versioning;
@@ -49,7 +49,7 @@
* Domain object for all the configuration related data.
*
*/
-public class Configuration implements DataSerializable {
+public class Configuration implements VersionedDataSerializable {
private static final long serialVersionUID = 1L;
private String configName;
private String cacheXmlContent;
@@ -158,6 +158,16 @@
return deployments.keySet();
}
+ public void toDataPre_GEODE_1_12_0_0(DataOutput out) throws IOException {
+ DataSerializer.writeString(configName, out);
+ DataSerializer.writeString(cacheXmlFileName, out);
+ DataSerializer.writeString(cacheXmlContent, out);
+ DataSerializer.writeString(propertiesFileName, out);
+ DataSerializer.writeProperties(gemfireProperties, out);
+ HashSet<String> jarNames = new HashSet<>(deployments.keySet());
+ DataSerializer.writeHashSet(jarNames, out);
+ }
+
@Override
public void toData(DataOutput out) throws IOException {
DataSerializer.writeString(configName, out);
@@ -174,6 +184,19 @@
DataSerializer.writeHashMap(deployments, out);
}
+ public void fromDataPre_GEODE_1_12_0_0(DataInput in) throws IOException, ClassNotFoundException {
+ this.configName = DataSerializer.readString(in);
+ this.cacheXmlFileName = DataSerializer.readString(in);
+ this.cacheXmlContent = DataSerializer.readString(in);
+ this.propertiesFileName = DataSerializer.readString(in);
+ this.gemfireProperties = DataSerializer.readProperties(in);
+ HashSet<String> jarNames = DataSerializer.readHashSet(in);
+ jarNames.stream()
+ .map(x -> new Deployment(x, null, null))
+ .forEach(deployment -> deployments.put(deployment.getJarFileName(),
+ deployment));
+ }
+
@Override
public void fromData(DataInput in) throws IOException, ClassNotFoundException {
configName = DataSerializer.readString(in);
@@ -234,4 +257,8 @@
gemfireProperties, deployments);
}
+ @Override
+ public Version[] getSerializationVersions() {
+ return new Version[] {Version.GEODE_1_12_0};
+ }
}
