reduce lofi connection manager chatter …

rescala-lang · Dec 12, 2024 · 195c9a3 · 195c9a3
1 parent d7d8e04
commit 195c9a3
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/Modules/Local-first Access Control/src/main/scala/lofi_acl/sync/ConnectionManager.scala b/Modules/Local-first Access Control/src/main/scala/lofi_acl/sync/ConnectionManager.scala
@@ -64,7 +64,7 @@ class ConnectionManager[MSG](
   }
 
   def acceptIncomingConnections(): Unit = {
-    println(s"$localPublicId is accepting connections on port ${connector.listenPort}")
+    if false then println(s"$localPublicId is accepting connections on port ${connector.listenPort}")
 
     def acceptConnection(): Unit =
       if stopped then running = false
@@ -73,7 +73,7 @@ class ConnectionManager[MSG](
         connectionFuture.onComplete {
           case Failure(exception) =>
             running = false
-            Console.err.println("Stopping listener")
+            if false then  Console.err.println("Stopping listener")
           case Success((socket, peerIdentity)) =>
             if peerIdentity == localPublicId
             then // We don't want to connect to ourselves.
@@ -136,7 +136,7 @@ class ConnectionManager[MSG](
         if expectedUser == peerId
         then connectionEstablished(socket, peerId, establishedByRemote = false)
         else {
-          Console.err.println(s"Expecting $expectedUser at $host:$port but connected to $peerId. Closing socket.")
+          if false then  Console.err.println(s"Expecting $expectedUser at $host:$port but connected to $peerId. Closing socket.")
           try {
             socket.close()
           } catch
@@ -154,7 +154,7 @@ class ConnectionManager[MSG](
       peerIdentity: PublicIdentity,
       establishedByRemote: Boolean
   ): Unit = {
-    println(s"Established connection with $peerIdentity at ${socket.getRemoteSocketAddress}")
+    if false then println(s"Established connection with $peerIdentity at ${socket.getRemoteSocketAddress}")
 
     this.synchronized {
       connections.get(peerIdentity) match

diff --git a/Modules/Local-first Access Control/src/test/scala/lofi_acl/sync/ConnectionManagerTest.scala b/Modules/Local-first Access Control/src/test/scala/lofi_acl/sync/ConnectionManagerTest.scala
@@ -20,10 +20,10 @@ class ConnectionManagerTest extends FunSuite {
   private val idC = IdentityFactory.createNewIdentity
   private val idD = IdentityFactory.createNewIdentity
 
-  println(s"idA = ${idA.getPublic.id}")
-  println(s"idB = ${idB.getPublic.id}")
-  println(s"idC = ${idC.getPublic.id}")
-  println(s"idD = ${idD.getPublic.id}")
+  if false then println(s"idA = ${idA.getPublic.id}")
+  if false then println(s"idB = ${idB.getPublic.id}")
+  if false then println(s"idC = ${idC.getPublic.id}")
+  if false then println(s"idD = ${idD.getPublic.id}")
 
   test("Only establish connection and don't send anything") {
     val receiverA = QueueAppendingMessageReceiver()
@@ -372,10 +372,10 @@ object ConnectionManagerTest {
     }
 
     override def connectionEstablished(publicIdentity: PublicIdentity): Unit =
-      println(s"${localId.map(_.id).getOrElse("Replica")} is now connected to ${publicIdentity.id}")
+      if false then println(s"${localId.map(_.id).getOrElse("Replica")} is now connected to ${publicIdentity.id}")
 
     override def connectionShutdown(publicIdentity: PublicIdentity): Unit =
-      println(s"${localId.map(_.id).getOrElse("Replica")} connectionShutdown to $publicIdentity")
+      if false then println(s"${localId.map(_.id).getOrElse("Replica")} connectionShutdown to $publicIdentity")
   }
 
   given JsonValueCodec[String]       = JsonCodecMaker.make