Track forwarded activation metrics in partition identity tests (#2269)

Author: rogeralsing

tests/Proto.Cluster.PartitionIdentity.Tests/PartitionIdentityTests.cs

@@ -53,13 +53,15 @@ PartitionIdentityLookup.Send send
 
         var activationRequestsSent = 0L;
         var activationRequestsReceived = 0L;
+        var activationRequestsForwarded = 0L;
         using var listener = new MeterListener
         {
             InstrumentPublished = (instrument, l) =>
             {
                 if (instrument.Meter.Name == ProtoMetrics.MeterName &&
                     (instrument.Name == "protocluster_identity_activation_request_sent_count" ||
-                     instrument.Name == "protocluster_activator_activation_request_received_count"))
+                     instrument.Name == "protocluster_activator_activation_request_received_count" ||
+                     instrument.Name == "protocluster_activator_activation_request_forwarded_count"))
                 {
                     l.EnableMeasurementEvents(instrument);
                 }
@@ -76,6 +78,10 @@ PartitionIdentityLookup.Send send
             {
                 Interlocked.Add(ref activationRequestsReceived, measurement);
             }
+            else if (instrument.Name == "protocluster_activator_activation_request_forwarded_count")
+            {
+                Interlocked.Add(ref activationRequestsForwarded, measurement);
+            }
         });
 
         listener.Start();
@@ -129,18 +135,26 @@ PartitionIdentityLookup.Send send
 
         var sentActivationRequests = activationRequestsSent;
         var receivedActivationRequests = activationRequestsReceived;
+        var forwardedActivationRequests = activationRequestsForwarded;
 
         _output.WriteLine(
             $"{totalCalls} requests, {restarts} restarts, {receivedActivationRequests} activation requests against " +
             actorStates.Count + " identities");
         _output.WriteLine($"{sentActivationRequests} activation requests sent by identity lookups");
+        _output.WriteLine($"{forwardedActivationRequests} activation requests forwarded by activators");
 
         // Ensure every activation request sent by lookups was handled by an activator
-        sentActivationRequests.Should().Be(receivedActivationRequests);
+        sentActivationRequests.Should().Be(
+            receivedActivationRequests,
+            $"sent {sentActivationRequests}, received {receivedActivationRequests}, forwarded {forwardedActivationRequests}"
+        );
 
         // Some activation requests may target actors that are already running
         // so the number of received requests can exceed actual actor starts
-        receivedActivationRequests.Should().BeGreaterOrEqualTo(totalStarts);
+        receivedActivationRequests.Should().BeGreaterOrEqualTo(
+            totalStarts,
+            $"received {receivedActivationRequests}, actor starts {totalStarts}, forwarded {forwardedActivationRequests}"
+        );
 
         foreach (var actorState in actorStates)
         {