From 6bdce7f95bf09b666342ab80807b9ccb5f3aed77 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Thu, 15 Jun 2023 11:33:16 +0100 Subject: [PATCH] remove sequence id generator (#399) --- .../org/apache/pekko/io/dns/IdGenerator.scala | 21 ------------------- 1 file changed, 21 deletions(-) diff --git a/actor/src/main/scala/org/apache/pekko/io/dns/IdGenerator.scala b/actor/src/main/scala/org/apache/pekko/io/dns/IdGenerator.scala index 5bb3191f14..59c9e18c5a 100644 --- a/actor/src/main/scala/org/apache/pekko/io/dns/IdGenerator.scala +++ b/actor/src/main/scala/org/apache/pekko/io/dns/IdGenerator.scala @@ -13,8 +13,6 @@ import org.apache.pekko.annotation.InternalApi import java.security.SecureRandom import java.util.concurrent.ThreadLocalRandom -import java.util.concurrent.atomic.AtomicInteger -import scala.annotation.tailrec /** * INTERNAL API @@ -59,23 +57,4 @@ private[pekko] object IdGenerator { def random(rand: java.util.Random): IdGenerator = new IdGenerator { override def nextId(): Short = rand.nextInt(Short.MaxValue).toShort } - - /** - * @return a predictable sequence of ids for tests - */ - def sequence(): IdGenerator = new IdGenerator { - val requestId: AtomicInteger = new AtomicInteger(0) - - @tailrec - override final def nextId(): Short = { - val oldId = requestId.get() - val newId = (oldId + 1) % Short.MaxValue - - if (requestId.compareAndSet(oldId, newId.intValue())) { - newId.toShort - } else { - nextId() - } - } - } }