edgehandler receives msg after starting

Change-Id: Ic663a908d3d247916f6e9041878833356b57f822

Author: huangxuxin

?pkg/clustershim/shimclient.go

@@ -34,7 +34,7 @@ import (
 )
 
 const (
-	shimRespChanLen = 100
+	shimRespChanLen = 10000
 )
 
 // ShimServiceClient is the client interface to a cluster shim.

?pkg/edgehandler/edgehandler.go

@@ -103,7 +103,6 @@ func (e *edgeHandler) Start() error {
 		return fmt.Errorf("fail to init shim client")
 	}
 
-	go e.handleRespFromShimClient()
 	e.edgeTunnel = tunnel.NewEdgeTunnel(e.conf)
 	e.edgeTunnel.RegistReceiveMessageHandler(e.receiveMessageFromTunnel)
 	e.edgeTunnel.RegistAfterConnectToHook(e.afterConnect)
@@ -112,6 +111,8 @@ func (e *edgeHandler) Start() error {
 		return err
 	}
 
+	go e.handleRespFromShimClient()
+
 	go e.sendMessageToTunnel()
 	return nil
 }

?pkg/edgehandler/edgehandler_test.go

@@ -31,6 +31,7 @@ import (
 	"github.com/baidu/ote-stack/pkg/clustershim"
 	"github.com/baidu/ote-stack/pkg/config"
 	oteclient "github.com/baidu/ote-stack/pkg/generated/clientset/versioned"
+	"github.com/baidu/ote-stack/pkg/generated/clientset/versioned/fake"
 	"github.com/baidu/ote-stack/pkg/tunnel"
 )
 
@@ -489,6 +490,25 @@ func TestStart(t *testing.T) {
 			},
 			ExpectErr: true,
 		},
+		{
+			Name: "shim is ready",
+			Conf: &config.ClusterControllerConfig{
+				ClusterName:           "child",
+				ClusterUserDefineName: "child",
+				K8sClient:             fake.NewSimpleClientset(),
+				ParentCluster:         "127.0.0.1:8287",
+				KubeConfig:            "",
+				TunnelListenAddr:      "test",
+			},
+			ExpectErr: false,
+		},
+	}
+
+	ctInter := tunnel.NewCloudTunnel("127.0.0.1:8287")
+
+	err := ctInter.Start()
+	if err != nil {
+		t.Errorf("start cloud tunnel failed")
 	}
 
 	for _, ct := range casetest {