From 7fb3360d6f6992196bb6f91889a1e2583f1f9dbe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Thu, 23 Jan 2020 10:46:46 +0100 Subject: [PATCH] storage: Fix handing stop call --- storage/miner.go | 15 +-------------- 1 file changed, 1 insertion(+), 14 deletions(-) diff --git a/storage/miner.go b/storage/miner.go index 4cd2c675a..ce4f6a9e4 100644 --- a/storage/miner.go +++ b/storage/miner.go @@ -36,9 +36,6 @@ type Miner struct { worker address.Address sealing *sealing.Sealing - - stop chan struct{} - stopped chan struct{} } type storageMinerApi interface { @@ -76,9 +73,6 @@ func NewMiner(api storageMinerApi, addr address.Address, h host.Host, ds datasto tktFn: tktFn, maddr: addr, - - stop: make(chan struct{}), - stopped: make(chan struct{}), } return m, nil @@ -109,14 +103,7 @@ func (m *Miner) Run(ctx context.Context) error { func (m *Miner) Stop(ctx context.Context) error { defer m.sealing.Stop(ctx) - - close(m.stop) - select { - case <-m.stopped: - return nil - case <-ctx.Done(): - return ctx.Err() - } + return nil } func (m *Miner) runPreflightChecks(ctx context.Context) error {