# Added the test to check compatibility with old nodes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/c8ffaabb Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/c8ffaabb Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/c8ffaabb Branch: refs/heads/ignite-sprint-4 Commit: c8ffaabb96bdd0f4850c8fb1636e2e673722ecdf Parents: 6864315 Author: sevdokimov <sergey.evdoki...@jetbrains.com> Authored: Sun Apr 12 12:26:57 2015 +0300 Committer: sevdokimov <sergey.evdoki...@jetbrains.com> Committed: Sun Apr 12 12:26:57 2015 +0300 ---------------------------------------------------------------------- ...ClusterMetricsSnapshotSerializeSelfTest.java | 28 ++++++++++++++++++++ 1 file changed, 28 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/c8ffaabb/modules/core/src/test/java/org/apache/ignite/spi/discovery/ClusterMetricsSnapshotSerializeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/ClusterMetricsSnapshotSerializeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/ClusterMetricsSnapshotSerializeSelfTest.java index a9d6f8c..404c99f 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/ClusterMetricsSnapshotSerializeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/ClusterMetricsSnapshotSerializeSelfTest.java @@ -26,6 +26,20 @@ import org.apache.ignite.testframework.junits.common.*; */ @GridCommonTest(group = "Utils") public class ClusterMetricsSnapshotSerializeSelfTest extends GridCommonAbstractTest { + /** Metrics serialized by Ignite 1.0 */ + private static final byte[] METRICS_V1 = {0, 0, 0, 22, 0, 0, 0, 8, 64, 0, 0, 0, 0, 0, 0, 27, 0, 0, 0, 15, 64, + (byte)-32, 0, 0, 0, 0, 0, 26, 0, 0, 0, 14, 64, (byte)-64, 0, 0, 0, 0, 0, 23, 0, 0, 0, 9, 64, 64, 0, 0, 0, 0, 0, + 39, 0, 0, 0, 36, 0, 0, 0, 37, 0, 0, 0, 0, 0, 0, 0, 25, 0, 0, 0, 0, 0, 0, 0, 13, 64, 20, 0, 0, 0, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0, 24, 0, 0, 0, 0, 0, 0, 0, 12, 64, 16, 0, 0, 0, 0, 0, 0, (byte)-1, (byte)-1, (byte)-1, (byte)-1, 0, + 0, 0, 0, 0, 0, 0, 11, 0, 0, 0, 0, 0, 0, 0, 38, 0, 0, 0, 1, 64, 65, 0, 0, 0, 0, 0, 0, (byte)-65, (byte)-16, 0, 0, + 0, 0, 0, 0, (byte)-65, (byte)-16, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 18, 0, 0, 0, 0, 0, 0, 0, 20, 0, 0, 0, + 0, 0, 0, 0, 17, 0, 0, 0, 0, 0, 0, 0, 19, 0, 0, 0, 0, 0, 0, 0, 48, 0, 0, 0, 0, 0, 0, 0, 29, 0, 0, 0, 0, 0, 0, 0, + 31, 0, 0, 0, 0, 0, 0, 0, 28, 0, 0, 0, 0, 0, 0, 0, 30, 0, 0, 0, 0, 0, 0, 0, 47, 0, 0, 0, 0, 0, 0, 0, 33, + (byte)-1, (byte)-1, (byte)-1, (byte)-1, (byte)-1, (byte)-1, (byte)-1, (byte)-1, 0, 0, 0, 0, 0, 0, 0, 41, 0, 0, + 0, 35, 0, 0, 0, 32, 0, 0, 0, 0, 0, 0, 0, 40, 0, 0, 0, 16, (byte)-1, (byte)-1, (byte)-1, (byte)-1, (byte)-1, + (byte)-1, (byte)-1, (byte)-1, 0, 0, 0, 42, 0, 0, 0, 0, 0, 0, 0, 43, 0, 0, 0, 44, 0, 0, 0, 0, 0, 0, 0, 45, 0, 0, + 0, 46, (byte)-1, (byte)-1, (byte)-1, (byte)-1}; + /** */ public ClusterMetricsSnapshotSerializeSelfTest() { super(false /*don't start grid*/); @@ -66,6 +80,15 @@ public class ClusterMetricsSnapshotSerializeSelfTest extends GridCommonAbstractT } /** + * Checks compatibility with old serialized metrics. + */ + public void testMetricsCompatibility() { + ClusterMetrics metrics = ClusterMetricsSnapshot.deserialize(METRICS_V1, 0); + + assert metrics != null; + } + + /** * @return Test metrics. */ private ClusterMetrics createMetrics() { @@ -123,6 +146,11 @@ public class ClusterMetricsSnapshotSerializeSelfTest extends GridCommonAbstractT return metrics; } + /** + * @param obj Object. + * @param obj1 Object 1. + */ + @SuppressWarnings("FloatingPointEquality") private boolean isMetricsEquals(ClusterMetrics obj, ClusterMetrics obj1) { return obj.getAverageActiveJobs() == obj1.getAverageActiveJobs() &&
