raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fix possible NPE in ClusterShardingLeaseSpec (#31161)

Browse source 
Set the test lease after variables have been initialised
This commit is contained in:
Peter Vlugter 2022-02-22 22:17:16 +13:00 • committed by GitHub
parent 3faeffd9b1
commit 16e35f6ea9
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-coordination/src/test/scala/akka/coordination/lease/TestLease.scala
View file

@ -64,16 +64,16 @@ class TestLease(settings: LeaseSettings, system: ExtendedActorSystem) extends Le
val log = Logging(system, classOf[TestLease]) val log = Logging(system, classOf[TestLease])
val probe = TestProbe()(system) val probe = TestProbe()(system)
log.info("Creating lease {}", settings)
TestLeaseExt(system).setTestLease(settings.leaseName, this)
val initialPromise = Promise[Boolean]() val initialPromise = Promise[Boolean]()
private val nextAcquireResult = new AtomicReference[Future[Boolean]](initialPromise.future) private val nextAcquireResult = new AtomicReference[Future[Boolean]](initialPromise.future)
private val nextCheckLeaseResult = new AtomicReference[Boolean](false) private val nextCheckLeaseResult = new AtomicReference[Boolean](false)
private val currentCallBack = new AtomicReference[Option[Throwable] => Unit](_ => ()) private val currentCallBack = new AtomicReference[Option[Throwable] => Unit](_ => ())
log.info("Creating lease {}", settings)
TestLeaseExt(system).setTestLease(settings.leaseName, this)
def setNextAcquireResult(next: Future[Boolean]): Unit = def setNextAcquireResult(next: Future[Boolean]): Unit =
nextAcquireResult.set(next) nextAcquireResult.set(next)