Function TestConcurrentMoveLeader

tests/integration/cluster_test.go:540–557

(t *testing.T)

}

func TestConcurrentMoveLeader(t *testing.T) {
	integration.BeforeTest(t, integration.WithFailpoint("afterIsMemberExist", `sleep("1s")`))
	c := integration.NewCluster(t, &integration.ClusterConfig{Size: 1})
	defer c.Terminate(t)

	addResp, err := c.Members[0].Client.MemberAddAsLearner(context.Background(), []string{"http://localhost:123"})
	require.NoError(t, err)
	removeID := addResp.Member.ID
	done := make(chan struct{})
	go func() {
		time.Sleep(time.Second / 2)
		c.Members[0].Client.MoveLeader(context.Background(), removeID)
		close(done)
	}()
	_, err = c.Members[0].Client.MemberRemove(context.Background(), removeID)
	require.NoError(t, err)
	<-done
}