From 45a1ec73bb3a0658a482e17c05ef27e2f1bd493a Mon Sep 17 00:00:00 2001 From: Daniel Smith Date: Fri, 6 Nov 2015 13:03:58 -0800 Subject: [PATCH] Lengthen delay --- pkg/storage/cacher.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/storage/cacher.go b/pkg/storage/cacher.go index b70854dec99..e3bad4b11de 100644 --- a/pkg/storage/cacher.go +++ b/pkg/storage/cacher.go @@ -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.