distributed/talent-plan-tinykv
1
0
Fork 0
mirror of https://github.com/talent-plan/tinykv.git synced 2025-03-28 21:10:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

try to stable tests (#142)

Browse Source 
* try to stable tests

Signed-off-by: Connor <zbk602423539@gmail.com>
This commit is contained in:
Connor 2020-03-29 21:51:17 +08:00
parent b19552c109
commit bb9739ae6e
3 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Makefile
View File

@ -9,7 +9,7 @@ endif
GO := GO111MODULE=on go
GOBUILD := $(GO) build $(BUILD_FLAG) -tags codes
GOTEST := $(GO) test -p 8
GOTEST := $(GO) test
TEST_LDFLAGS := ""

2
kv/config/config.go
View File

@ -85,7 +85,7 @@ func NewTestConfig() *Config {
return &Config{
LogLevel: "info",
Raft: true,
RaftBaseTickInterval: 10 * time.Millisecond,
RaftBaseTickInterval: 50 * time.Millisecond,
RaftHeartbeatTicks: 2,
RaftElectionTimeoutTicks: 10,
RaftLogGCTickInterval: 50 * time.Millisecond,

10
kv/test_raftstore/test_test.go
View File

@ -184,14 +184,17 @@ func GenericTest(t *testing.T, part string, nclients int, unreliable bool, crash
cfg.RaftLogGcCountLimit = uint64(maxraftlog)
}
if split {
cfg.RegionMaxSize = 800
cfg.RegionSplitSize = 500
cfg.RegionMaxSize = 300
cfg.RegionSplitSize = 200
}
cluster := NewTestCluster(nservers, cfg)
cluster.Start()
defer cluster.Shutdown()
electionTimeout := cfg.RaftBaseTickInterval * time.Duration(cfg.RaftElectionTimeoutTicks)
// Wait for leader election
time.Sleep(2 * electionTimeout)
done_partitioner := int32(0)
done_confchanger := int32(0)
done_clients := int32(0)
@ -243,7 +246,7 @@ func GenericTest(t *testing.T, part string, nclients int, unreliable bool, crash
time.Sleep(100 * time.Millisecond)
go confchanger(t, cluster, ch_confchange, &done_confchanger)
}
time.Sleep(2 * time.Second)
time.Sleep(5 * time.Second)
atomic.StoreInt32(&done_clients, 1) // tell clients to quit
atomic.StoreInt32(&done_partitioner, 1) // tell partitioner to quit
atomic.StoreInt32(&done_confchanger, 1) // tell confchanger to quit
@ -548,6 +551,7 @@ func TestBasicConfChange3B(t *testing.T) {
cluster.Start()
defer cluster.Shutdown()
cluster.MustTransferLeader(1, NewPeer(1, 1))
cluster.MustRemovePeer(1, NewPeer(2, 2))
cluster.MustRemovePeer(1, NewPeer(3, 3))
cluster.MustRemovePeer(1, NewPeer(4, 4))