From 91511d1089078eef8021e284734e2db58bcabdd8 Mon Sep 17 00:00:00 2001 From: Ruslan Shevchenko Date: Wed, 17 Jul 2024 18:50:25 +0300 Subject: [PATCH] added diagniostics for sopecific failed tests --- native/src/test/scala/cps/ComputationBound.scala | 11 +++++++---- .../cps/context/TestAccidentContextResolving.scala | 2 +- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/native/src/test/scala/cps/ComputationBound.scala b/native/src/test/scala/cps/ComputationBound.scala index e8a46ddc9..b270287cb 100644 --- a/native/src/test/scala/cps/ComputationBound.scala +++ b/native/src/test/scala/cps/ComputationBound.scala @@ -45,18 +45,21 @@ trait ComputationBound[+T] { case Error(e) => Future.failed(e) case Thunk(x) => x().runTicksDeadline(deadline) - case Wait(ref, op) => + case w@Wait(ref, op) => val timeRest = deadline - System.currentTimeMillis if (timeRest > 0) then ComputationBound.advanceDeferredQueueTicks(timeRest, ref.get().isDefined).flatMap{ r => ref.get match case Some(v) => op(v).runTicksDeadline(deadline) - case None => Future failed (new TimeoutException()) + case None => + Future failed (new TimeoutException(s"ref $ref is empty")) } else - Future failed (new TimeoutException()) + println(s"failed: wwaiting for $ref in $w") + Future failed (new TimeoutException("timedRest < 0 when processing $w")) else - Future failed (new TimeoutException()) + println(s"failed because we behind deadline") + Future failed (new TimeoutException("rest <= 0")) def checkProgress(timeout: Duration = Duration.Inf): Either[Try[T],ComputationBound[T]] = diff --git a/shared/src/test/scala/cps/context/TestAccidentContextResolving.scala b/shared/src/test/scala/cps/context/TestAccidentContextResolving.scala index b47163809..27a985314 100644 --- a/shared/src/test/scala/cps/context/TestAccidentContextResolving.scala +++ b/shared/src/test/scala/cps/context/TestAccidentContextResolving.scala @@ -30,7 +30,7 @@ class TestAccidentContextResolving { val x = await(fun()) x+1 } - val fr = c.runTicks(1.second) + val fr = c.runTicks(2.second) val r = fr.map(x => assert(x == 2)) FutureCompleter(r)