chore: Fix connections (#22445)

Signed-off-by: Michael Heinrichs <[email protected]>

Author: netopyr

platform-sdk/consensus-otter-tests/src/testFixtures/java/org/hiero/otter/fixtures/internal/AbstractNetwork.java

@@ -629,6 +629,7 @@ public void restoreBandwidthLimitsForAllConnections(@NonNull final Node node) {
     @Override
     public void restoreConnectivity() {
         networkPartitions.clear();
+        connected.clear();
         latencyOverrides.clear();
         bandwidthOverrides.clear();
         updateConnections();
@@ -1213,15 +1214,19 @@ public Node receiver() {
          */
         @Override
         public void disconnect() {
+            log.info("Disconnecting connection from node {} to node {}", sender.selfId(), receiver.selfId());
             connected.put(connectionKey, false);
+            updateConnections();
         }
 
         /**
          * {@inheritDoc}
          */
         @Override
         public void connect() {
+            log.info("Connecting connection from node {} to node {}", sender.selfId(), receiver.selfId());
             connected.put(connectionKey, true);
+            updateConnections();
         }
 
         /**
@@ -1237,6 +1242,7 @@ public boolean isConnected() {
          */
         @Override
         public void restoreConnectivity() {
+            log.info("Restoring connectivity from node {} to node {}", sender.selfId(), receiver.selfId());
             connected.remove(connectionKey);
             restoreLatency();
             restoreBandwidthLimit();
@@ -1257,7 +1263,9 @@ public Duration latency() {
         @Override
         public void latency(@NonNull final Duration latency) {
             requireNonNull(latency);
+            log.info("Setting latency from node {} to node {} to {}", sender.selfId(), receiver.selfId(), latency);
             latencyOverrides.put(connectionKey, new LatencyOverride(latency, jitter()));
+            updateConnections();
         }
 
         /**
@@ -1275,15 +1283,19 @@ public Percentage jitter() {
         @Override
         public void jitter(@NonNull final Percentage jitter) {
             requireNonNull(jitter);
+            log.info("Setting jitter from node {} to node {} to {}", sender.selfId(), receiver.selfId(), jitter);
             latencyOverrides.put(connectionKey, new LatencyOverride(latency(), jitter));
+            updateConnections();
         }
 
         /**
          * {@inheritDoc}
          */
         @Override
         public void restoreLatency() {
+            log.info("Restoring latency from node {} to node {}", sender.selfId(), receiver.selfId());
             latencyOverrides.remove(connectionKey);
+            updateConnections();
         }
 
         /**
@@ -1301,15 +1313,23 @@ public BandwidthLimit bandwidthLimit() {
         @Override
         public void bandwidthLimit(@NonNull final BandwidthLimit bandwidthLimit) {
             requireNonNull(bandwidthLimit);
+            log.info(
+                    "Setting bandwidth limit from node {} to node {} to {}",
+                    sender.selfId(),
+                    receiver.selfId(),
+                    bandwidthLimit);
             bandwidthOverrides.put(connectionKey, bandwidthLimit);
+            updateConnections();
         }
 
         /**
          * {@inheritDoc}
          */
         @Override
         public void restoreBandwidthLimit() {
+            log.info("Restoring bandwidth limit from node {} to node {}", sender.selfId(), receiver.selfId());
             bandwidthOverrides.remove(connectionKey);
+            updateConnections();
         }
     }