@@ -20,7 +20,7 @@ public interface ISloContext
2020public abstract class SloTableContext < T > : ISloContext
2121{
2222 private const int IntervalMs = 100 ;
23-
23+
2424 protected static readonly ILogger Logger = ISloContext . Factory . CreateLogger < SloTableContext < T > > ( ) ;
2525
2626 private volatile int _maxId ;
@@ -97,11 +97,13 @@ public async Task Run(RunConfig runConfig)
9797
9898 var writeLimiter = new FixedWindowRateLimiter ( new FixedWindowRateLimiterOptions
9999 {
100- Window = TimeSpan . FromMilliseconds ( IntervalMs ) , PermitLimit = runConfig . WriteRps / 10 , QueueLimit = int . MaxValue
100+ Window = TimeSpan . FromMilliseconds ( IntervalMs ) , PermitLimit = runConfig . WriteRps / 10 ,
101+ QueueLimit = int . MaxValue
101102 } ) ;
102103 var readLimiter = new FixedWindowRateLimiter ( new FixedWindowRateLimiterOptions
103104 {
104- Window = TimeSpan . FromMilliseconds ( IntervalMs ) , PermitLimit = runConfig . ReadRps / 10 , QueueLimit = int . MaxValue
105+ Window = TimeSpan . FromMilliseconds ( IntervalMs ) , PermitLimit = runConfig . ReadRps / 10 ,
106+ QueueLimit = int . MaxValue
105107 } ) ;
106108
107109 var cancellationTokenSource = new CancellationTokenSource ( ) ;
@@ -210,9 +212,9 @@ Task ShootingTask(RateLimiter rateLimitPolicy, string operationType,
210212
211213 _ = Task . Run ( async ( ) =>
212214 {
213- await Task . Delay ( TimeSpan . FromSeconds ( Random . Shared . Next ( IntervalMs ) ) ,
215+ await Task . Delay ( TimeSpan . FromSeconds ( Random . Shared . Next ( IntervalMs ) ) ,
214216 cancellationToken : cancellationTokenSource . Token ) ;
215-
217+
216218 try
217219 {
218220 pendingOperations . Inc ( ) ;
0 commit comments