archeryue / godis Goto Github PK

Contributors

Stargazers

Forkers

scottlx cexll mf24271 resolliu zeaplau xsjzn terrence85561 cyae dumplinghuman jvbzephir 55jchen farmerchillax zhangqianggit-2018 damuguaye liaoxiaojian-cn shayne98 noblesport rick1216820014 cooperxj inspiration-lynn

func AcceptHandler(loop *AeLoop, fd int, extra interface{}) {
	nfd, err := Accept(fd)
	if err != nil {
		log.Printf("accept err: %v\n", err)
		return
	}
	client := CreateClient(nfd)
	//TODO: check max clients limit
	server.clients[fd] = client
	server.aeLoop.AddFileEvent(fd, AE_READABLE, ReadQueryFromClient, client)
}

func TestBulkBuf(t *testing.T) {
	client := NewClient(nil)
	fillQuery(client, "*3\r")
	ok, err := handleBulkBuf(client)
	assert.Nil(t, err)
	assert.Equal(t, false, ok)
}

func TestList(t *testing.T) {
	list := ListCreate(ListType{EqualFunc: GStrEqual})
	assert.Equal(t, list.Length(), 0)

        list.Append(CreateObject(GSTR, "1"))
        list.DelNode(list.First())
}