Lengthen delay
This commit is contained in:
@@ -469,7 +469,7 @@ func (c *cacheWatcher) stop() {
|
||||
func (c *cacheWatcher) add(event watchCacheEvent) {
|
||||
select {
|
||||
case c.input <- event:
|
||||
case <-time.After(time.Second):
|
||||
case <-time.After(5 * time.Second):
|
||||
// This means that we couldn't send event to that watcher.
|
||||
// Since we don't want to blockin on it infinitely,
|
||||
// we simply terminate it.
|
||||
|
||||
Reference in New Issue
Block a user