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

remove sequence id generator (#399)

Browse source
This commit is contained in:
PJ Fanning 2023-06-15 11:33:16 +01:00 • committed by GitHub
parent 5e3ac25490
commit 6bdce7f95b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 21 deletions
Download patch file Download diff file Expand all files Collapse all files

21
actor/src/main/scala/org/apache/pekko/io/dns/IdGenerator.scala
View file

@ -13,8 +13,6 @@ import org.apache.pekko.annotation.InternalApi
import java.security.SecureRandom import java.security.SecureRandom
import java.util.concurrent.ThreadLocalRandom import java.util.concurrent.ThreadLocalRandom
import java.util.concurrent.atomic.AtomicInteger
import scala.annotation.tailrec
/** /**
* INTERNAL API * INTERNAL API
@ -59,23 +57,4 @@ private[pekko] object IdGenerator {
def random(rand: java.util.Random): IdGenerator = new IdGenerator { def random(rand: java.util.Random): IdGenerator = new IdGenerator {
override def nextId(): Short = rand.nextInt(Short.MaxValue).toShort 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()
}
}
}
} }