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

Mima filters

Browse source
This commit is contained in:
Johan Andrén 2018-08-28 17:25:20 +02:00
parent 18b2d85216
commit 60e95557be
2 changed files with 16 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-distributed-data/src/main/mima-filters/2.5.15.backwards.excludes Normal file
View file

@ -0,0 +1,4 @@
# #25543 allow BigInt increment and decrements in PNCounter
ProblemFilters.exclude[IncompatibleMethTypeProblem]("akka.cluster.ddata.PNCounter.increment")
ProblemFilters.exclude[IncompatibleMethTypeProblem]("akka.cluster.ddata.PNCounter.decrement")
ProblemFilters.exclude[IncompatibleMethTypeProblem]("akka.cluster.ddata.PNCounter.change")

17
akka-distributed-data/src/main/scala/akka/cluster/ddata/PNCounter.scala
View file

@ -9,6 +9,8 @@ import akka.cluster.UniqueAddress
import akka.util.HashCode import akka.util.HashCode
import java.math.BigInteger import java.math.BigInteger
import akka.annotation.InternalApi
object PNCounter { object PNCounter {
val empty: PNCounter = new PNCounter(GCounter.empty, GCounter.empty) val empty: PNCounter = new PNCounter(GCounter.empty, GCounter.empty)
def apply(): PNCounter = empty def apply(): PNCounter = empty
@ -122,12 +124,17 @@ final class PNCounter private[akka] (
def decrement(node: Cluster, n: java.math.BigInteger): PNCounter = def decrement(node: Cluster, n: java.math.BigInteger): PNCounter =
decrement(node.selfUniqueAddress, n) decrement(node.selfUniqueAddress, n)
private[akka] def increment(key: UniqueAddress, n: BigInt): PNCounter = change(key, n) /** Internal API */
private[akka] def increment(key: UniqueAddress): PNCounter = increment(key, 1) @InternalApi private[akka] def increment(key: UniqueAddress, n: BigInt): PNCounter = change(key, n)
private[akka] def decrement(key: UniqueAddress, n: BigInt): PNCounter = change(key, -n) /** Internal API */
private[akka] def decrement(key: UniqueAddress): PNCounter = decrement(key, 1) @InternalApi private[akka] def increment(key: UniqueAddress): PNCounter = increment(key, 1)
/** Internal API */
@InternalApi private[akka] def decrement(key: UniqueAddress, n: BigInt): PNCounter = change(key, -n)
/** Internal API */
@InternalApi private[akka] def decrement(key: UniqueAddress): PNCounter = decrement(key, 1)
private[akka] def change(key: UniqueAddress, n: BigInt): PNCounter = /** Internal API */
@InternalApi private[akka] def change(key: UniqueAddress, n: BigInt): PNCounter =
if (n > 0) copy(increments = increments.increment(key, n)) if (n > 0) copy(increments = increments.increment(key, n))
else if (n < 0) copy(decrements = decrements.increment(key, -n)) else if (n < 0) copy(decrements = decrements.increment(key, -n))
else this else this