---

panlei

2019-07-02 a873ac0f7ca7639441bbacf927a728ce7ec3bb81

 cache/cache.go

@@ -20,8 +20,9 @@


func Init(initChan chan bool,dbIp string,surveyPort int,pubSubPort int){
   urlSurvey := dbIp + strconv.Itoa(surveyPort)
   urlPubSub := dbIp + strconv.Itoa(pubSubPort)
   cMap = shardmap.New(uint8(32))
   urlSurvey := "tcp://" + dbIp + ":" + strconv.Itoa(surveyPort)
   urlPubSub := "tcp://" + dbIp + ":" + strconv.Itoa(pubSubPort)
   client, _ := gopherdiscovery.ClientWithSub(urlSurvey, urlPubSub, uuid.NewV4().String())
   recvMsg := client.HeartBeatMsg()
   fmt.Println(<-recvMsg)