From 16a1a6d32426265d37dbf0428c9fccb6d690fb09 Mon Sep 17 00:00:00 2001 From: beorn7 Date: Fri, 6 Feb 2015 18:30:33 +0100 Subject: [PATCH] Add another check for stopped scraper. --- retrieval/target.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/retrieval/target.go b/retrieval/target.go index 3e2a22f6728..7c4ba49f000 100644 --- a/retrieval/target.go +++ b/retrieval/target.go @@ -277,6 +277,13 @@ func (t *target) RunScraper(ingester extraction.Ingester, interval time.Duration // actual scrape interval increase as long as a scrape takes // longer than the interval we are aiming for. time.Sleep(took - interval) + // After the sleep, we should check again if we have been stopped. + select { + case <-t.scraperStopping: + return + default: + // Do nothing. + } t.scrape(ingester) } }