Bump timeout on bind to avoid spurious ci failures hopefully (#2791)

* Bump timeout on bind to avoid spurious ci failures hopefully

* Actually pass the timeout

* Bump to 30 seconds
This commit is contained in:
Chris Stewart 2021-03-11 12:24:28 -06:00 committed by GitHub
parent 49544fc7f3
commit 7764828b3a

View file

@ -25,12 +25,12 @@ import scala.concurrent.{ExecutionContext, Future}
case class PeerMessageSender(client: P2PClient)(implicit conf: NodeAppConfig)
extends P2PLogger {
private val socket = client.peer.socket
implicit private val timeout = Timeout(10.seconds)
implicit private val timeout = Timeout(30.seconds)
/** Initiates a connection with the given peer */
def connect(): Unit = {
logger.info(s"Attempting to connect to peer=$socket")
(client.actor ! Tcp.Connect(socket))
(client.actor ! Tcp.Connect(socket, timeout = Some(timeout.duration)))
}
def isConnected()(implicit ec: ExecutionContext): Future[Boolean] = {