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

Count vclock stats when published, not for each received gossip

Browse source
This commit is contained in:
Patrik Nordwall 2013-06-15 23:17:05 +02:00
parent 981bce5dd0
commit bc367aae96
1 changed files with 6 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
View file

@ -235,7 +235,6 @@ private[cluster] final class ClusterCoreDaemon(publisher: ActorRef) extends Acto
val statsEnabled = PublishStatsInterval.isFinite
var gossipStats = GossipStats()
var vclockStats = VectorClockStats()
var seedNodeProcess: Option[ActorRef] = None
@ -616,9 +615,6 @@ private[cluster] final class ClusterCoreDaemon(publisher: ActorRef) extends Acto
case Some(x) if x < 0 ⇒ gossipStats.incrementNewerCount
case _ ⇒ gossipStats.incrementOlderCount
}
vclockStats = VectorClockStats(
versionSize = latestGossip.version.versions.size,
latestGossip.members.count(m ⇒ latestGossip.seenByNode(m.uniqueAddress)))
}
publish(latestGossip)
@ -917,7 +913,12 @@ private[cluster] final class ClusterCoreDaemon(publisher: ActorRef) extends Acto
if (PublishStatsInterval == Duration.Zero) publishInternalStats()
}
def publishInternalStats(): Unit = publisher ! CurrentInternalStats(gossipStats, vclockStats)
def publishInternalStats(): Unit = {
val vclockStats = VectorClockStats(
versionSize = latestGossip.version.versions.size,
seenLatest = latestGossip.members.count(m ⇒ latestGossip.seenByNode(m.uniqueAddress)))
publisher ! CurrentInternalStats(gossipStats, vclockStats)
}
}