You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by se...@apache.org on 2021/01/26 12:14:56 UTC

[ignite-3] branch main updated: IGNITE-14060 Compilation error fix (#36)

This is an automated email from the ASF dual-hosted git repository.

sergeychugunov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 6ab4060  IGNITE-14060 Compilation error fix (#36)
6ab4060 is described below

commit 6ab4060d306838389fa3c11e0bfb9287eb4fdb34
Author: Sergey Chugunov <se...@gmail.com>
AuthorDate: Tue Jan 26 15:13:51 2021 +0300

    IGNITE-14060 Compilation error fix (#36)
---
 .../ignite/configuration/sample/UsageTest.java     | 84 +++++++++++-----------
 1 file changed, 43 insertions(+), 41 deletions(-)

diff --git a/modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/UsageTest.java b/modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/UsageTest.java
index 3aa68a9..adb62d5 100644
--- a/modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/UsageTest.java
+++ b/modules/configuration-annotation-processor/src/test/java/org/apache/ignite/configuration/sample/UsageTest.java
@@ -20,6 +20,7 @@ package org.apache.ignite.configuration.sample;
 import java.io.Serializable;
 import java.util.Collections;
 import java.util.function.Consumer;
+import org.apache.ignite.configuration.ConfigurationRegistry;
 import org.apache.ignite.configuration.Configurator;
 import org.apache.ignite.configuration.PublicConfigurator;
 import org.apache.ignite.configuration.internal.NamedList;
@@ -29,6 +30,8 @@ import org.apache.ignite.configuration.validation.ConfigurationValidationExcepti
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
 /**
  * Simple usage test of generated configuration schema.
  */
@@ -93,45 +96,44 @@ public class UsageTest {
         PublicConfigurator<LocalConfiguration> con = new PublicConfigurator<>(configurator);
     }
 
-    // TODO: IGNITE-14060
-//    /**
-//     * Test to show an API to work with multiroot configurations.
-//     */
-//    @Test
-//    public void multiRootConfigurationTest() {
-//        ConfigurationRegistry sysConf = new ConfigurationRegistry();
-//
-//        int failureDetectionTimeout = 30_000;
-//        int joinTimeout = 10_000;
-//
-//        long autoAdjustTimeout = 30_000L;
-//
-//        InitNetwork initNetwork = new InitNetwork().withDiscovery(
-//            new InitDiscovery()
-//                .withFailureDetectionTimeout(failureDetectionTimeout)
-//                .withJoinTimeout(joinTimeout)
-//        );
-//
-//        InitLocal initLocal = new InitLocal().withBaseline(
-//            new InitBaseline().withAutoAdjust(
-//                new InitAutoAdjust().withEnabled(true)
-//                    .withTimeout(autoAdjustTimeout))
-//        );
-//
-//        Configurator<LocalConfigurationImpl> localConf = Configurator.create(storage,
-//            LocalConfigurationImpl::new, initLocal);
-//
-//        sysConf.registerConfigurator(localConf);
-//
-//        Configurator<NetworkConfigurationImpl> networkConf = Configurator.create(storage,
-//            NetworkConfigurationImpl::new, initNetwork);
-//
-//        sysConf.registerConfigurator(networkConf);
-//
-//        assertEquals(failureDetectionTimeout,
-//            sysConf.getConfiguration(NetworkConfigurationImpl.KEY).discovery().failureDetectionTimeout().value());
-//
-//        assertEquals(autoAdjustTimeout,
-//            sysConf.getConfiguration(LocalConfigurationImpl.KEY).baseline().autoAdjust().timeout().value());
-//    }
+    /**
+     * Test to show an API to work with multiroot configurations.
+     */
+    @Test
+    public void multiRootConfigurationTest() {
+        ConfigurationRegistry sysConf = new ConfigurationRegistry();
+
+        int failureDetectionTimeout = 30_000;
+        int joinTimeout = 10_000;
+
+        long autoAdjustTimeout = 30_000L;
+
+        InitNetwork initNetwork = new InitNetwork().withDiscovery(
+            new InitDiscovery()
+                .withFailureDetectionTimeout(failureDetectionTimeout)
+                .withJoinTimeout(joinTimeout)
+        );
+
+        InitLocal initLocal = new InitLocal().withBaseline(
+            new InitBaseline().withAutoAdjust(
+                new InitAutoAdjust().withEnabled(true)
+                    .withTimeout(autoAdjustTimeout))
+        );
+
+        Configurator<LocalConfigurationImpl> localConf = Configurator.create(storage,
+            LocalConfigurationImpl::new, initLocal);
+
+        sysConf.registerConfigurator(localConf);
+
+        Configurator<NetworkConfigurationImpl> networkConf = Configurator.create(storage,
+            NetworkConfigurationImpl::new, initNetwork);
+
+        sysConf.registerConfigurator(networkConf);
+
+        assertEquals(failureDetectionTimeout,
+            sysConf.getConfiguration(NetworkConfigurationImpl.KEY).discovery().failureDetectionTimeout().value());
+
+        assertEquals(autoAdjustTimeout,
+            sysConf.getConfiguration(LocalConfigurationImpl.KEY).baseline().autoAdjust().timeout().value());
+    }
 }