Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

etcdserver: fix govet error

Browse Source
This commit is contained in:
Gyu-Ho Lee 2016-04-01 16:01:47 -07:00
parent 3083b6d11e
commit eea56d037e
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
etcdserver/raft_test.go
View File

@ -152,23 +152,23 @@ func TestCreateConfigChangeEnts(t *testing.T) {
func TestStopRaftWhenWaitingForApplyDone(t *testing.T) { func TestStopRaftWhenWaitingForApplyDone(t *testing.T) {
n := newNopReadyNode() n := newNopReadyNode()
r := raftNode{ srv := &EtcdServer{r: raftNode{
Node: n, Node: n,
storage: mockstorage.NewStorageRecorder(""), storage: mockstorage.NewStorageRecorder(""),
raftStorage: raft.NewMemoryStorage(), raftStorage: raft.NewMemoryStorage(),
transport: rafthttp.NewNopTransporter(), transport: rafthttp.NewNopTransporter(),
} }}
r.start(&EtcdServer{r: r}) srv.r.start(srv)
n.readyc <- raft.Ready{} n.readyc <- raft.Ready{}
select { select {
case <-r.applyc: case <-srv.r.applyc:
case <-time.After(time.Second): case <-time.After(time.Second):
t.Fatalf("failed to receive apply struct") t.Fatalf("failed to receive apply struct")
} }
r.stopped <- struct{}{} srv.r.stopped <- struct{}{}
select { select {
case <-r.done: case <-srv.r.done:
case <-time.After(time.Second): case <-time.After(time.Second):
t.Fatalf("failed to stop raft loop") t.Fatalf("failed to stop raft loop")
} }