From 6890dc184476829a022d424eda7dafa1ecd44bf7 Mon Sep 17 00:00:00 2001 From: ferhat elmas Date: Wed, 6 Dec 2017 10:52:03 +0100 Subject: [PATCH] Simplification --- provider/docker/docker.go | 9 ++------- provider/dynamodb/dynamodb.go | 6 ++---- provider/ecs/ecs.go | 6 ++---- 3 files changed, 6 insertions(+), 15 deletions(-) diff --git a/provider/docker/docker.go b/provider/docker/docker.go index d6e26da05..6e31b0615 100644 --- a/provider/docker/docker.go +++ b/provider/docker/docker.go @@ -190,13 +190,8 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s } else { pool.Go(func(stop chan bool) { - for { - select { - case <-stop: - cancel() - return - } - } + <-stop + cancel() }) f := filters.NewArgs() f.Add("type", "container") diff --git a/provider/dynamodb/dynamodb.go b/provider/dynamodb/dynamodb.go index 54898db6e..3fe0c3638 100644 --- a/provider/dynamodb/dynamodb.go +++ b/provider/dynamodb/dynamodb.go @@ -155,10 +155,8 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s pool.Go(func(stop chan bool) { ctx, cancel := context.WithCancel(context.Background()) safe.Go(func() { - select { - case <-stop: - cancel() - } + <-stop + cancel() }) operation := func() error { diff --git a/provider/ecs/ecs.go b/provider/ecs/ecs.go index 21ed99a58..1f11c7e0c 100644 --- a/provider/ecs/ecs.go +++ b/provider/ecs/ecs.go @@ -114,10 +114,8 @@ func (p *Provider) Provide(configurationChan chan<- types.ConfigMessage, pool *s pool.Go(func(stop chan bool) { ctx, cancel := context.WithCancel(context.Background()) safe.Go(func() { - select { - case <-stop: - cancel() - } + <-stop + cancel() }) operation := func() error {