KCL: Fix the way in returning error

Fix bug when doing shard sync which removing shard info.

Jira ID: CNA-612

Change-Id: Ibaf55fffa39b793abbfe3bd57999e5d37f82a52f
This commit is contained in:
Tao Jiang 2018-05-21 19:14:18 -07:00
parent 2b9301cd47
commit 85c04db6b4

View file

@ -317,6 +317,10 @@ func (w *Worker) syncShard() error {
shardInfo := make(map[string]bool)
err := w.getShardIDs("", shardInfo)
if err != nil {
return err
}
for _, shard := range w.shardStatus {
// The cached shard no longer existed, remove it.
if _, ok := shardInfo[shard.ID]; !ok {
@ -328,5 +332,5 @@ func (w *Worker) syncShard() error {
}
}
return err
return nil
}