From 0f45d9efa1dfd1580975ecc410d44de053f7af81 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期五, 05 七月 2019 09:45:05 +0800
Subject: [PATCH] remove base64
---
shardmap/shardmap.go | 14 +++++++++-----
1 files changed, 9 insertions(+), 5 deletions(-)
diff --git a/shardmap/shardmap.go b/shardmap/shardmap.go
index 8feb527..c19edd7 100644
--- a/shardmap/shardmap.go
+++ b/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
--
Gitblit v1.8.0