digital-asset/daml
1
1
Fork 0
mirror of https://github.com/digital-asset/daml.git synced 2024-09-20 09:17:43 +03:00
Code Issues Projects Releases Wiki Activity

sandbox: Increase the timeout in StaticTimeIT. (#3774)

Browse Source 
It's currently quite flaky in CI; I think increasing it a little will
help.

Also fixes some warnings in the same file.
This commit is contained in:
Samir Talwar 2019-12-09 08:53:40 +01:00 committed by mergify[bot]
parent 19d2a22b0b
commit 1d1c7e9033
1 changed files with 16 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
ledger/sandbox/src/test/suite/scala/com/digitalasset/platform/sandbox/services/time/StaticTimeIT.scala
View File

@ -13,16 +13,17 @@ import com.digitalasset.ledger.api.testing.utils.{
SuiteResourceManagementAroundAll
}
import com.digitalasset.ledger.api.v1.testing.time_service.TimeServiceGrpc
import com.digitalasset.ledger.api.v1.testing.time_service.TimeServiceGrpc.TimeServiceStub
import com.digitalasset.ledger.client.services.testing.time.StaticTime
import com.digitalasset.platform.sandbox.services.SandboxFixture
import io.grpc.Status
import org.awaitility.Awaitility
import org.scalatest.concurrent.ScalaFutures
import org.scalatest.{Matchers, WordSpec}
import org.scalatest.time.{Seconds, Span}
import org.scalatest.{Assertion, Matchers, WordSpec}
import scalaz.syntax.tag._
import scala.concurrent.Await
import scala.concurrent.duration._
import scala.concurrent.{Await, ExecutionContext}
class StaticTimeIT
extends WordSpec
@ -31,7 +32,10 @@ class StaticTimeIT
with ScalaFutures
with Matchers {
implicit private def ec = materializer.executionContext
override implicit val patienceConfig: PatienceConfig =
PatienceConfig(timeout = scaled(Span(1, Seconds)))
implicit private def ec: ExecutionContext = materializer.executionContext
private lazy val notLedgerId: domain.LedgerId = domain.LedgerId(s"not-${ledgerId().unwrap}")
@ -39,7 +43,7 @@ class StaticTimeIT
override protected def packageFiles: List[File] = Nil
def clientStub = TimeServiceGrpc.stub(channel)
def clientStub: TimeServiceStub = TimeServiceGrpc.stub(channel)
"StaticTime" when {
@ -86,7 +90,10 @@ class StaticTimeIT
}
}
private def assertTimeIsSynchronized(timeSetter: StaticTime, getTimeReader: => StaticTime) = {
private def assertTimeIsSynchronized(
timeSetter: StaticTime,
getTimeReader: => StaticTime,
): Assertion = {
val oldTime = timeSetter.getCurrentTime
val timeToSet = oldTime.plus(duration)
@ -110,14 +117,13 @@ class StaticTimeIT
}
}
private def withStaticTime[T](ledgerId: domain.LedgerId)(action: StaticTime => T) = {
private def withStaticTime[T](ledgerId: domain.LedgerId)(action: StaticTime => T): T = {
val staticTime = createStaticTime(ledgerId)
val res = action(staticTime)
staticTime.close()
res
}
private def createStaticTime(ledgerId: domain.LedgerId) = {
Await.result(StaticTime.updatedVia(clientStub, ledgerId.unwrap), 30.seconds)
}
private def createStaticTime(ledgerId: domain.LedgerId) =
Await.result(StaticTime.updatedVia(clientStub, ledgerId.unwrap), patienceConfig.timeout)
}