refactor: gossip module names and extract FallenBehindManager to gossip module

platform-sdk/consensus-gossip-impl/src/main/java/module-info.java

@@ -1,6 +1,6 @@
-module com.hedera.consensus.gossip.impl {
-    requires transitive com.hedera.service.gossip;
+module org.hiero.consensus.gossip.impl {
+    requires transitive org.hiero.consensus.gossip;
 
-    provides com.hedera.service.gossip.GossipService with
-            com.hedera.service.gossip.impl.GossipServiceImpl;
+    provides org.hiero.consensus.gossip.Gossip with
+            org.hiero.consensus.gossip.impl.GossipImpl;
 }

platform-sdk/consensus-gossip-impl/src/main/java/com/hedera/service/gossip/impl/GossipServiceImpl.java → platform-sdk/consensus-gossip-impl/src/main/java/org/hiero/consensus/gossip/impl/GossipImpl.java

@@ -14,11 +14,11 @@
  * limitations under the License.
  */
 
-package com.hedera.service.gossip.impl;
+package org.hiero.consensus.gossip.impl;
 
-import com.hedera.service.gossip.GossipService;
+import org.hiero.consensus.gossip.Gossip;
 
 /**
  * Implementation for the mock gossip service.
  */
-public final class GossipServiceImpl implements GossipService {}
+public final class GossipImpl implements Gossip {}

platform-sdk/consensus-gossip/src/main/java/module-info.java

@@ -1,3 +1,6 @@
-module com.hedera.service.gossip {
-    exports com.hedera.service.gossip;
+module org.hiero.consensus.gossip {
+    exports org.hiero.consensus.gossip;
+
+    requires transitive com.swirlds.common;
+    requires static com.github.spotbugs.annotations;
 }

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/gossip/FallenBehindManager.java → platform-sdk/consensus-gossip/src/main/java/org/hiero/consensus/gossip/FallenBehindManager.java

@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package com.swirlds.platform.gossip;
+package org.hiero.consensus.gossip;
 
 import com.swirlds.common.platform.NodeId;
 import edu.umd.cs.findbugs.annotations.NonNull;

platform-sdk/consensus-gossip/src/main/java/com/hedera/service/gossip/GossipService.java → platform-sdk/consensus-gossip/src/main/java/org/hiero/consensus/gossip/Gossip.java

@@ -14,9 +14,9 @@
  * limitations under the License.
  */
 
-package com.hedera.service.gossip;
+package org.hiero.consensus.gossip;
 
 /**
- * Mock gossip service.
+ * Mock gossip.
  */
-public interface GossipService {}
+public interface Gossip {}

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/gossip/FallenBehindManagerImpl.java

@@ -30,6 +30,7 @@
 import java.util.Objects;
 import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * A thread-safe implementation of {@link FallenBehindManager}

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/gossip/shadowgraph/ShadowgraphSynchronizer.java

@@ -36,7 +36,6 @@
 import com.swirlds.platform.event.AncientMode;
 import com.swirlds.platform.event.PlatformEvent;
 import com.swirlds.platform.eventhandling.EventConfig;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.gossip.IntakeEventCounter;
 import com.swirlds.platform.gossip.SyncException;
 import com.swirlds.platform.gossip.sync.config.SyncConfig;
@@ -59,6 +58,7 @@
 import java.util.stream.Collectors;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * The goal of the ShadowgraphSynchronizer is to compare graphs with a remote node, and update them so both sides have

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/gossip/sync/SyncManagerImpl.java

@@ -22,12 +22,12 @@
 import com.swirlds.common.context.PlatformContext;
 import com.swirlds.common.metrics.FunctionGauge;
 import com.swirlds.common.platform.NodeId;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import edu.umd.cs.findbugs.annotations.NonNull;
 import java.util.List;
 import java.util.Objects;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * A class that manages information about who we need to sync with, and whether we need to reconnect

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/gossip/sync/protocol/SyncProtocol.java

@@ -22,7 +22,6 @@
 import com.swirlds.common.platform.NodeId;
 import com.swirlds.common.threading.pool.ParallelExecutionException;
 import com.swirlds.platform.Utilities;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.gossip.IntakeEventCounter;
 import com.swirlds.platform.gossip.SyncException;
 import com.swirlds.platform.gossip.permits.SyncPermitProvider;
@@ -39,6 +38,7 @@
 import java.util.Objects;
 import java.util.function.BooleanSupplier;
 import java.util.function.Supplier;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * Executes the sync protocol where events are exchanged with a peer and all events are sent and received in topological

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/network/protocol/ReconnectProtocolFactory.java

@@ -21,7 +21,6 @@
 import com.swirlds.common.platform.NodeId;
 import com.swirlds.common.threading.manager.ThreadManager;
 import com.swirlds.config.api.Configuration;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.metrics.ReconnectMetrics;
 import com.swirlds.platform.reconnect.ReconnectController;
 import com.swirlds.platform.reconnect.ReconnectProtocol;
@@ -33,6 +32,7 @@
 import java.time.Duration;
 import java.util.Objects;
 import java.util.function.Supplier;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * Implementation of a factory for reconnect protocol

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/network/protocol/SyncProtocolFactory.java

@@ -18,7 +18,6 @@
 
 import com.swirlds.common.context.PlatformContext;
 import com.swirlds.common.platform.NodeId;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.gossip.IntakeEventCounter;
 import com.swirlds.platform.gossip.permits.SyncPermitProvider;
 import com.swirlds.platform.gossip.shadowgraph.ShadowgraphSynchronizer;
@@ -30,6 +29,7 @@
 import java.util.Objects;
 import java.util.function.BooleanSupplier;
 import java.util.function.Supplier;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * Implementation of a factory for sync protocol

platform-sdk/swirlds-platform-core/src/main/java/com/swirlds/platform/reconnect/ReconnectProtocol.java

@@ -26,7 +26,6 @@
 import com.swirlds.common.threading.manager.ThreadManager;
 import com.swirlds.common.utility.throttle.RateLimitedLogger;
 import com.swirlds.config.api.Configuration;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.metrics.ReconnectMetrics;
 import com.swirlds.platform.network.Connection;
 import com.swirlds.platform.network.NetworkProtocolException;
@@ -41,6 +40,7 @@
 import java.util.function.Supplier;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 /**
  * Implements the reconnect protocol over a bidirectional network

platform-sdk/swirlds-platform-core/src/main/java/module-info.java

@@ -140,6 +140,7 @@
     requires transitive com.hedera.pbj.runtime;
     requires transitive info.picocli;
     requires transitive org.apache.logging.log4j;
+    requires transitive org.hiero.consensus.gossip;
     requires com.swirlds.config.extensions;
     requires com.swirlds.logging;
     requires com.swirlds.merkle;

platform-sdk/swirlds-platform-core/src/test/java/com/swirlds/platform/reconnect/ReconnectProtocolTests.java

@@ -41,7 +41,6 @@
 import com.swirlds.common.utility.ValueReference;
 import com.swirlds.config.api.Configuration;
 import com.swirlds.config.extensions.test.fixtures.TestConfigBuilder;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.metrics.ReconnectMetrics;
 import com.swirlds.platform.network.Connection;
 import com.swirlds.platform.network.protocol.Protocol;
@@ -59,6 +58,7 @@
 import java.util.List;
 import java.util.stream.LongStream;
 import java.util.stream.Stream;
+import org.hiero.consensus.gossip.FallenBehindManager;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;

platform-sdk/swirlds-platform-core/src/test/java/com/swirlds/platform/sync/protocol/SyncProtocolFactoryTests.java

@@ -31,7 +31,6 @@
 import com.swirlds.common.platform.NodeId;
 import com.swirlds.common.test.fixtures.platform.TestPlatformContextBuilder;
 import com.swirlds.common.threading.pool.ParallelExecutionException;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.gossip.IntakeEventCounter;
 import com.swirlds.platform.gossip.SyncException;
 import com.swirlds.platform.gossip.permits.SyncPermitProvider;
@@ -47,6 +46,7 @@
 import java.io.IOException;
 import java.time.Duration;
 import java.util.List;
+import org.hiero.consensus.gossip.FallenBehindManager;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;

platform-sdk/swirlds-unit-tests/core/swirlds-platform-test/build.gradle.kts

@@ -34,5 +34,6 @@ testModuleInfo {
     requires("org.mockito.junit.jupiter")
     requires("com.swirlds.metrics.api")
     requires("org.mockito")
+    requires("org.hiero.consensus.gossip")
     requiresStatic("com.github.spotbugs.annotations")
 }

platform-sdk/swirlds-unit-tests/core/swirlds-platform-test/src/test/java/com/swirlds/platform/test/reconnect/FallenBehindManagerTest.java

@@ -25,7 +25,6 @@
 import com.swirlds.common.test.fixtures.Randotron;
 import com.swirlds.config.extensions.test.fixtures.TestConfigBuilder;
 import com.swirlds.platform.Utilities;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import com.swirlds.platform.gossip.FallenBehindManagerImpl;
 import com.swirlds.platform.network.PeerInfo;
 import com.swirlds.platform.network.topology.NetworkTopology;
@@ -35,6 +34,7 @@
 import com.swirlds.platform.test.fixtures.addressbook.RandomAddressBookBuilder;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicInteger;
+import org.hiero.consensus.gossip.FallenBehindManager;
 import org.junit.jupiter.api.Test;
 
 class FallenBehindManagerTest {

platform-sdk/swirlds-unit-tests/core/swirlds-platform-test/src/test/java/com/swirlds/platform/test/sync/TestingSyncManager.java

@@ -17,8 +17,8 @@
 package com.swirlds.platform.test.sync;
 
 import com.swirlds.common.platform.NodeId;
-import com.swirlds.platform.gossip.FallenBehindManager;
 import java.util.List;
+import org.hiero.consensus.gossip.FallenBehindManager;
 
 public class TestingSyncManager implements FallenBehindManager {
     /** whether we have fallen behind or not */