diff --git a/be2-scala/src/main/scala/ch/epfl/pop/decentralized/ConnectionMediator.scala b/be2-scala/src/main/scala/ch/epfl/pop/decentralized/ConnectionMediator.scala index 32549677fd..f55cf0f47f 100644 --- a/be2-scala/src/main/scala/ch/epfl/pop/decentralized/ConnectionMediator.scala +++ b/be2-scala/src/main/scala/ch/epfl/pop/decentralized/ConnectionMediator.scala @@ -74,6 +74,8 @@ final case class ConnectionMediator( if (serverMap.isEmpty) { monitorRef ! Monitor.AtLeastOneServerConnected gossipManagerRef ! Monitor.AtLeastOneServerConnected + } else { + gossipManagerRef ! ConnectionMediator.NewServerConnected(serverRef, greetServer) } serverMap += ((serverRef, greetServer)) diff --git a/be2-scala/src/test/scala/ch/epfl/pop/decentralized/GossipManagerSuite.scala b/be2-scala/src/test/scala/ch/epfl/pop/decentralized/GossipManagerSuite.scala index 23ccbaa19b..5e311c95f7 100644 --- a/be2-scala/src/test/scala/ch/epfl/pop/decentralized/GossipManagerSuite.scala +++ b/be2-scala/src/test/scala/ch/epfl/pop/decentralized/GossipManagerSuite.scala @@ -317,7 +317,6 @@ class GossipManagerSuite extends TestKit(ActorSystem("GossipManagerSuiteActorSys Await.result(output, duration) - // include rumor state peers.map(_.receiveOne(duration)).count(_ != null) shouldBe 1 } @@ -365,7 +364,7 @@ class GossipManagerSuite extends TestKit(ActorSystem("GossipManagerSuiteActorSys val response = Right(JsonRpcResponse( RpcValidator.JSON_RPC_VERSION, ResultObject(0), - Some(1) + Some(4) )) // by processing the reponse, gossipManager should send again a rumor to a new peer