Fix sharding benchmark streaming message counts (#6866)

* cap total number of iterations for Sharding end to end BDN can't wait all day for these to finish * fix message counts
akkadotnet · Aug 1, 2023 · 29cc42f · 29cc42f
1 parent fa561d5
commit 29cc42f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/benchmark/Akka.Cluster.Benchmarks/Sharding/ShardMessageRoutingBenchmarks.cs b/src/benchmark/Akka.Cluster.Benchmarks/Sharding/ShardMessageRoutingBenchmarks.cs
@@ -151,7 +151,7 @@ public async Task SingleRequestResponseToLocalEntity()
  await _shardRegion1.Ask<ShardedMessage>(_messageToSys1);
  }
 
- [Benchmark(OperationsPerInvoke = MsgCount * BatchSize)]
+ [Benchmark(OperationsPerInvoke = MsgCount)]
  public async Task StreamingToLocalEntity()
  {
  _batchActor.Tell(new BulkSendActor.BeginSend(_messageToSys1, _shardRegion1, BatchSize));
@@ -173,7 +173,7 @@ public async Task SingleRequestResponseToRemoteEntityWithLocalProxy()
  await _localRouter.Ask<ShardedMessage>(new SendShardedMessage(_messageToSys2.EntityId, _messageToSys2));
  }
 
- [Benchmark(OperationsPerInvoke = MsgCount*BatchSize)]
+ [Benchmark(OperationsPerInvoke = MsgCount)]
  public async Task StreamingToRemoteEntity()
  {
  _batchActor.Tell(new BulkSendActor.BeginSend(_messageToSys2, _shardRegion1, BatchSize));