Skip to content

Commit 025ad75

Browse files
committed
configure mem pool buckets rotation
Signed-off-by: Hagar Meir <[email protected]>
1 parent 4be93f2 commit 025ad75

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

request/pool.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -93,15 +93,15 @@ func (rp *Pool) createPendingStore() *PendingStore {
9393
Inspector: rp.inspector,
9494
ReqIDGCInterval: rp.options.AutoRemoveTimeout / 4,
9595
ReqIDLifetime: rp.options.AutoRemoveTimeout,
96-
Time: time.NewTicker(time.Second).C,
96+
Time: time.NewTicker(rp.options.FirstStrikeThreshold / 10).C,
9797
StartTime: time.Now(),
9898
Logger: rp.logger,
9999
SecondStrikeThreshold: rp.options.SecondStrikeThreshold,
100100
FirstStrikeThreshold: rp.options.FirstStrikeThreshold,
101101
OnDelete: func(key string) {
102102
rp.semaphore.Release(1)
103103
},
104-
Epoch: time.Second,
104+
Epoch: rp.options.FirstStrikeThreshold / 10,
105105
FirstStrikeCallback: rp.striker.OnFirstStrikeTimeout,
106106
SecondStrikeCallback: rp.striker.OnSecondStrikeTimeout,
107107
}

0 commit comments

Comments
 (0)