.

Author: rogeralsing

cluster/identitylookup/disthash/placement_actor.go

@@ -48,6 +48,8 @@ func (p *placementActor) Receive(ctx actor.Context) {
 
 func (p *placementActor) onTerminated(msg *actor.Terminated) {
 	found, key, meta := p.pidToMeta(msg.Who)
+	clusterKind := p.cluster.GetClusterKind(meta.ID.Kind)
+	clusterKind.Dec()
 
 	activationTerminated := &clustering.ActivationTerminated{
 		Pid:             msg.Who,
@@ -98,6 +100,7 @@ func (p *placementActor) onActivationRequest(msg *clustering.ActivationRequest,
 	props := clustering.WithClusterIdentity(clusterKind.Props, msg.ClusterIdentity)
 
 	pid := ctx.SpawnPrefix(props, msg.ClusterIdentity.Identity)
+	clusterKind.Inc()
 
 	p.actors[key] = GrainMeta{
 		ID:  msg.ClusterIdentity,

cluster/kind.go

@@ -52,6 +52,6 @@ func (ak *ActivatedKind) Inc() {
 	atomic.AddInt32(&ak.count, 1)
 }
 
-func (ak *ActivatedKind) Dev() {
+func (ak *ActivatedKind) Dec() {
 	atomic.AddInt32(&ak.count, -1)
 }

examples/cluster-gossip/node1/main.go

@@ -49,8 +49,13 @@ func startNode() *cluster.Cluster {
 
 			as := &cluster.ActorStatistics{}
 
+			fmt.Printf("Member %v\n", msg.MemberID)
 			if unpackErr := msg.Value.UnmarshalTo(as); unpackErr != nil {
-				fmt.Printf("\nActorStatistics %v\n\n", as)
+				//loop over as.ActorCount map
+				for k, v := range as.ActorCount {
+					fmt.Printf("ActorCount %v %v\n", k, v)
+				}
+
 			}
 		}
 	})