Merge eb6609c into 04170fa

tikv · Dec 27, 2018 · fcbbcf5 · fcbbcf5
2 parents 04170fa + eb6609c
commit fcbbcf5
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 0 deletions.
diff --git a/server/core/levedb_kv.go b/server/core/levedb_kv.go
@@ -19,6 +19,8 @@ import (
 	"github.com/pkg/errors"
 	"github.com/syndtr/goleveldb/leveldb"
 	"github.com/syndtr/goleveldb/leveldb/util"
+
+	log "github.com/sirupsen/logrus"
 )
 
 type leveldbKV struct {
@@ -54,6 +56,7 @@ func (kv *leveldbKV) LoadRange(startKey, endKey string, limit int) ([]string, er
 		count++
 	}
 	iter.Release()
+	log.Infof("leveldb load range %d items", len(values))
 	return values, nil
 }
 

diff --git a/server/core/region_kv.go b/server/core/region_kv.go
@@ -144,6 +144,7 @@ func loadRegions(kv KVBase, regions *RegionsInfo) error {
 			nextID = region.GetId() + 1
 			overlaps := regions.SetRegion(NewRegionInfo(region, nil))
 			for _, item := range overlaps {
+				log.Warnf("exsist overlap item %+v", item)
 				if err := deleteRegion(kv, item); err != nil {
 					return err
 				}
@@ -164,6 +165,7 @@ func (kv *RegionKV) FlushRegion() error {
 }
 
 func (kv *RegionKV) flush() error {
+	log.Infof("regionkv persist %d items", len(kv.batchRegions))
 	if err := kv.SaveRegions(kv.batchRegions); err != nil {
 		return err
 	}

diff --git a/server/region_syncer/client.go b/server/region_syncer/client.go
@@ -124,6 +124,7 @@ func (s *RegionSyncer) StartSyncWithLeader(addr string) {
 				}
 				for _, r := range resp.GetRegions() {
 					err = s.server.GetStorage().SaveRegion(r)
+					log.Debugf("%s recv region %d", s.server.Name(), r.GetId())
 					if err == nil {
 						s.history.Record(core.NewRegionInfo(r, nil))
 					}