554325746@qq.com
2019-06-25 f9ecff08394b734fb8420044bcba471df1af352c
shardmap/shardmap.go
@@ -5,6 +5,8 @@
import (
   "sync"
    "fmt"
    "basic.com/pubsub/protomsg.git"
)
const (
@@ -81,11 +83,11 @@
}
// modify by long.
func (s *ShardMap) Walk(wf wfOp, cfrom string) []interface{} {
func (s *ShardMap) Walk(wf wfOp, cfrom string) []protomsg.Baseinfo{
    var wg sync.WaitGroup
    var second float32 
    var baseinfos []interface{}
    var baseinfos []protomsg.Baseinfo
   for _, si := range s.shards {
        wg.Add(1)
@@ -97,12 +99,14 @@
                 if second == -1 {
                        continue 
                 }
                 fmt.Println("比对分数: ", second)
                 baseinfos = append(baseinfos, value )
                 if info, ok := value.(protomsg.Baseinfo) ;ok {
                    fmt.Println("比对分数: ", second)
                    info.CompareScore = second
                    baseinfos = append(baseinfos,info)
                 }
         }
         s.RUnlock()
      }(si,wf, cfrom)
   }
    wg.Wait()
    return baseinfos