fix: init storage error (#1486)
Signed-off-by: Jim Ma <majinjing3@gmail.com>
This commit is contained in:
parent
59060ef277
commit
c921c265c5
|
|
@ -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 {
|
||||
|
|
|
|||
Loading…
Reference in New Issue