From c921c265c5f72cbf2452a4798d8681d30dd1f272 Mon Sep 17 00:00:00 2001 From: Jim Ma Date: Mon, 25 Jul 2022 21:18:33 +0800 Subject: [PATCH] fix: init storage error (#1486) Signed-off-by: Jim Ma --- client/daemon/peer/peertask_manager.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/client/daemon/peer/peertask_manager.go b/client/daemon/peer/peertask_manager.go index 19b9ff31d..232c16baa 100644 --- a/client/daemon/peer/peertask_manager.go +++ b/client/daemon/peer/peertask_manager.go @@ -234,7 +234,14 @@ func (ptm *peerTaskManager) getOrCreatePeerTaskConductor( ptm.conductorLock.Unlock() metrics.PeerTaskCount.Add(1) logger.Debugf("peer task created: %s/%s", ptc.taskID, ptc.peerID) - return ptc, true, ptc.initStorage(desiredLocation) + + err := ptc.initStorage(desiredLocation) + if err != nil { + ptc.Errorf("init storage error: %s", err) + ptc.cancel(base.Code_ClientError, err.Error()) + return nil, false, err + } + return ptc, true, nil } func (ptm *peerTaskManager) enabledPrefetch(rg *util.Range) bool {