Function TestGroupPromote

pkg/topom/topom_group_test.go:137–200

(x *testing.T)

}

func TestGroupPromote(x *testing.T) {
	t := openTopom()
	defer t.Close()

	s := newFakeServer()
	defer s.Close()

	const sid = 100
	const gid = 200
	const server1 = "server1:port"
	server2 := s.Addr

	reset := func() {
		g := &models.Group{Id: gid}
		g.Servers = []*models.GroupServer{
			&models.GroupServer{Addr: server1},
			&models.GroupServer{Addr: server2},
		}
		contextUpdateGroup(t, g)
	}

	reset()

	assert.Must(t.GroupPromoteServer(gid, server1) != nil)
	g1 := getGroup(t, gid)
	assert.Must(g1.Promoting.State == models.ActionNothing)
	assert.Must(len(g1.Servers) == 2)
	assert.Must(g1.Servers[0].Addr == server1)
	assert.Must(g1.Servers[1].Addr == server2)

	reset()

	assert.MustNoError(t.GroupPromoteServer(gid, server2))
	g2 := getGroup(t, gid)
	assert.Must(g2.Promoting.State == models.ActionNothing)
	assert.Must(len(g2.Servers) == 2)
	assert.Must(g2.Servers[0].Addr == server2)
	assert.Must(g2.Servers[1].Addr == server1)

	reset()

	m := &models.SlotMapping{Id: sid}
	m.Action.State = models.ActionMigrating
	m.Action.TargetId = gid
	contextUpdateSlotMapping(t, m)

	p, c := openProxy()
	defer c.Shutdown()

	contextCreateProxy(t, p)
	assert.MustNoError(c.Shutdown())

	assert.Must(t.GroupPromoteServer(gid, server2) != nil)

	g3 := getGroup(t, gid)
	assert.Must(g3.Promoting.State == models.ActionPreparing)
	contextRemoveProxy(t, p)
	assert.MustNoError(t.GroupPromoteServer(gid, server2))