1 write to _options
System.Threading.RateLimiting (1)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)
69
_options
= new TokenBucketRateLimiterOptions
30 references to _options
System.Threading.RateLimiting (30)
System\Threading\RateLimiting\TokenBucketRateLimiter.cs (30)
40
public override bool IsAutoReplenishing =>
_options
.AutoReplenishment;
43
public override TimeSpan ReplenishmentPeriod =>
_options
.ReplenishmentPeriod;
84
if (
_options
.AutoReplenishment)
86
_renewTimer = new Timer(Replenish, this,
_options
.ReplenishmentPeriod,
_options
.ReplenishmentPeriod);
107
if (tokenCount >
_options
.TokenLimit)
109
throw new ArgumentOutOfRangeException(nameof(tokenCount), tokenCount, SR.Format(SR.TokenLimitExceeded, tokenCount,
_options
.TokenLimit));
141
if (tokenCount >
_options
.TokenLimit)
143
throw new ArgumentOutOfRangeException(nameof(tokenCount), tokenCount, SR.Format(SR.TokenLimitExceeded, tokenCount,
_options
.TokenLimit));
164
Debug.Assert(
_options
.QueueLimit >= _queueCount);
165
if (
_options
.QueueLimit - _queueCount < tokenCount)
167
if (
_options
.QueueProcessingOrder == QueueProcessingOrder.NewestFirst && tokenCount <=
_options
.QueueLimit)
195
while (
_options
.QueueLimit - _queueCount < tokenCount);
208
Debug.Assert(_queueCount <=
_options
.QueueLimit);
219
Debug.Assert(
_options
.TokensPerPeriod > 0);
220
int replenishPeriods = Math.Max(replenishAmount /
_options
.TokensPerPeriod, 1);
222
return new TokenBucketLease(false, TimeSpan.FromTicks(
_options
.ReplenishmentPeriod.Ticks * replenishPeriods));
242
if (_queueCount == 0 || (_queueCount > 0 &&
_options
.QueueProcessingOrder == QueueProcessingOrder.NewestFirst))
266
if (
_options
.AutoReplenishment)
297
if (_tokenCount ==
_options
.TokenLimit)
305
if (
_options
.AutoReplenishment)
307
add =
_options
.TokensPerPeriod;
314
_tokenCount = Math.Min(
_options
.TokenLimit, _tokenCount + add);
321
Debug.Assert(_tokenCount <=
_options
.TokenLimit);
325
_options
.QueueProcessingOrder == QueueProcessingOrder.OldestFirst
334
_options
.QueueProcessingOrder == QueueProcessingOrder.OldestFirst
343
_options
.QueueProcessingOrder == QueueProcessingOrder.OldestFirst
381
if (_tokenCount ==
_options
.TokenLimit)
408
RequestRegistration next =
_options
.QueueProcessingOrder == QueueProcessingOrder.OldestFirst