6

context/context_test.go

@@ -6,7 +6,7 @@ import (
 	"testing"
 	"time"
 
-	"git.wecise.com/wecise/common/logger"
+	"github.com/wecisecode/util/logger
 )
 
 func TestContext(t *testing.T) {

dfstest/dfstest.go

@@ -17,7 +17,7 @@ import (
 	"git.wecise.com/wecise/common/cassandra"
 	"git.wecise.com/wecise/common/dfs"
 	"git.wecise.com/wecise/common/etcd"
-	"git.wecise.com/wecise/common/matrix/logger"
+	"github.com/wecisecode/util/logger"
 	"gopkg.in/src-d/go-billy.v4"
 )
 

grpc-odbserver/main.go

@@ -7,9 +7,9 @@ import (
 	"trial/grpc-odbserver/mnode"
 	"trial/grpc-odbserver/msn"
 
-	"git.wecise.com/wecise/common/matrix/logger"
 	"git.wecise.com/wecise/common/matrix/util"
 	z "git.wecise.com/wecise/odbserver/mring/z/m"
+	"github.com/wecisecode/util/logger"
 )
 
 var _ = z.RunShadowCount(5, 0, 0, -1)

ping/ping.go

@@ -17,10 +17,10 @@ import (
 	"trial/ping/probing/icmp"
 	"trial/ping/utils"
 
-	"git.wecise.com/wecise/common/matrix/cfg"
-	"git.wecise.com/wecise/common/matrix/logger"
 	"git.wecise.com/wecise/common/matrix/util"
 	"github.com/scylladb/go-set/strset"
+	"github.com/wecisecode/util/cfg"
+	"github.com/wecisecode/util/logger"
 )
 
 type task struct {

ping/probing/cfglog.go

@@ -1,8 +1,8 @@
 package probing
 
 import (
-	cfg "git.wecise.com/wecise/common/matrix/cfg"
-	log "git.wecise.com/wecise/common/matrix/logger"
+	cfg "github.com/wecisecode/util/cfg"
+	log "github.com/wecisecode/util/logger"
 )
 
 var mcfg = cfg.MConfig()

ping/utils/utils.go

@@ -2,16 +2,17 @@ package utils
 
 import (
 	"fmt"
-	"git.wecise.com/wecise/common/logger"
-	"io/ioutil"
+	"github.com/wecisecode/util/logger
 	"os"
 	"strings"
 	"sync"
 	"time"
+
+	"github.com/wecisecode/util/logger"
 )
 
 var (
-	dataStats = make(map[string]*DataStat) // <title-name>:DataStat
+	dataStats   = make(map[string]*DataStat) // <title-name>:DataStat
 	dataStatsMu sync.Mutex
 )
 
@@ -56,7 +57,7 @@ type DataStat struct {
 func NewDataStat(title, name string, interval int, chanSize int) *DataStat {
 	dataStatsMu.Lock()
 	defer dataStatsMu.Unlock()
-	key := title+"-"+name
+	key := title + "-" + name
 	if ds, ok := dataStats[key]; ok {
 		if ds.statChan != nil {
 			close(ds.statChan)
@@ -103,9 +104,9 @@ func (ds *DataStat) Close() {
 }
 
 func (ds *DataStat) Start() {
-	tc := time.NewTicker(time.Duration(ds.Interval)*time.Second)
+	tc := time.NewTicker(time.Duration(ds.Interval) * time.Second)
 	startTime := time.Now()
-	ds.StartTime = startTime.UnixNano()/int64(time.Millisecond)
+	ds.StartTime = startTime.UnixNano() / int64(time.Millisecond)
 	ds.running = true
 	defer func() {
 		ds.running = false
@@ -113,30 +114,30 @@ func (ds *DataStat) Start() {
 L:
 	for {
 		select {
-		case <- tc.C:
+		case <-tc.C:
 			now := time.Now()
-			speed := float64(ds.Success + ds.Fail + ds.Ignore) / now.Sub(startTime).Seconds()
+			speed := float64(ds.Success+ds.Fail+ds.Ignore) / now.Sub(startTime).Seconds()
 			startTime = now
 			logger.Infof("Stat %s %s: success:%d fail:%d ignore:%d within %ds, total success:%d total fail:%d total ignore:%d speed:%.1f/s.\n", ds.title, ds.name, ds.Success, ds.Fail, ds.Ignore, ds.Interval, ds.TotalSuccess, ds.TotalFail, ds.TotalIgnore, speed)
-			ds.StatTime = now.UnixNano()/int64(time.Millisecond)
+			ds.StatTime = now.UnixNano() / int64(time.Millisecond)
 			ds.Success = 0
 			ds.Fail = 0
 			ds.Ignore = 0
-		case n, ok := <- ds.statChan:
+		case n, ok := <-ds.statChan:
 			if !ok {
 				break L
 			}
-			ds.LastTime = time.Now().UnixNano()/int64(time.Millisecond)
+			ds.LastTime = time.Now().UnixNano() / int64(time.Millisecond)
 			switch n {
 			case 0:
-				ds.Success ++
-				ds.TotalSuccess ++
+				ds.Success++
+				ds.TotalSuccess++
 			case 1:
-				ds.Fail ++
-				ds.TotalFail ++
+				ds.Fail++
+				ds.TotalFail++
 			case 2:
-				ds.Ignore ++
-				ds.TotalIgnore ++
+				ds.Ignore++
+				ds.TotalIgnore++
 			}
 		}
 	}
@@ -188,4 +189,4 @@ func (ds *DataStat) GetName() string {
 //			}
 //		}
 //	}
-//}
+//}