fix cache

554325746@qq.com

2019-07-11 9dd7bb8196b8c03c19bc3f1fbfe8a1f93341fdfe

 shardmap/shardmap.go

@@ -4,8 +4,8 @@

import (
   "sync"
    "encoding/json"
    "fmt"
    //"encoding/json"
    //"fmt"
)

var commonmux sync.Mutex
@@ -78,11 +78,9 @@
}

// modify by long.
func (s *ShardMap) Walk(wf wfOp, cfrom []byte) ([]byte){
func (s *ShardMap) Walk(wf wfOp, cfrom []byte) ( map[string]float32 ){
    var wg sync.WaitGroup
    var second float32 
    var buf []byte
    var err error

    ids := make(map[string]float32)
   for _, si := range s.shards {
@@ -109,15 +107,9 @@
   }

    wg.Wait()
    fmt.Println("value of map: ",ids)

    buf, err = json.Marshal(ids)
    if err != nil {
        fmt.Println("compare json err")
            buf = nil 
        
    }
    return buf
    return ids

}

// print all