From 85c04db6b484e6cbd2c1a946f0e1d5b1ea167ef9 Mon Sep 17 00:00:00 2001
From: Tao Jiang <taoj@vmware.com>
Date: Mon, 21 May 2018 19:14:18 -0700
Subject: [PATCH] KCL: Fix the way in returning error

Fix bug when doing shard sync which removing shard info.

Jira ID: CNA-612

Change-Id: Ibaf55fffa39b793abbfe3bd57999e5d37f82a52f
---
 clientlibrary/worker/worker.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/clientlibrary/worker/worker.go b/clientlibrary/worker/worker.go
index d4f9a13..a71c3ae 100644
--- a/clientlibrary/worker/worker.go
+++ b/clientlibrary/worker/worker.go
@@ -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
 }