|
@@ -308,8 +308,9 @@ func (c *cluster) RemoveMember(t *testing.T, id uint64) {
|
|
|
select {
|
|
select {
|
|
|
case <-m.s.StopNotify():
|
|
case <-m.s.StopNotify():
|
|
|
m.Terminate(t)
|
|
m.Terminate(t)
|
|
|
- case <-time.After(time.Second):
|
|
|
|
|
- t.Fatalf("failed to remove member %s in one second", m.s.ID())
|
|
|
|
|
|
|
+ // stop delay / election timeout + 1s disk and network delay
|
|
|
|
|
+ case <-time.After(time.Duration(electionTicks)*tickDuration + time.Second):
|
|
|
|
|
+ t.Fatalf("failed to remove member %s in time", m.s.ID())
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|