Merge remote-tracking branch 'origin/unstable' into aof-fixes
This commit is contained in:
commit
fc96409f91
2
src/ae.c
2
src/ae.c
@ -86,6 +86,8 @@ aeEventLoop *aeCreateEventLoop(int setsize) {
|
|||||||
|
|
||||||
void aeDeleteEventLoop(aeEventLoop *eventLoop) {
|
void aeDeleteEventLoop(aeEventLoop *eventLoop) {
|
||||||
aeApiFree(eventLoop);
|
aeApiFree(eventLoop);
|
||||||
|
zfree(eventLoop->events);
|
||||||
|
zfree(eventLoop->fired);
|
||||||
zfree(eventLoop);
|
zfree(eventLoop);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -13,7 +13,7 @@ static int aeApiCreate(aeEventLoop *eventLoop) {
|
|||||||
aeApiState *state = zmalloc(sizeof(aeApiState));
|
aeApiState *state = zmalloc(sizeof(aeApiState));
|
||||||
|
|
||||||
if (!state) return -1;
|
if (!state) return -1;
|
||||||
state->events = zmalloc(sizeof(epoll_event)*eventLoop->setsize);
|
state->events = zmalloc(sizeof(struct epoll_event)*eventLoop->setsize);
|
||||||
if (!state->events) {
|
if (!state->events) {
|
||||||
zfree(state);
|
zfree(state);
|
||||||
return -1;
|
return -1;
|
||||||
|
@ -997,8 +997,12 @@ sds getAllClientsInfoString(void) {
|
|||||||
|
|
||||||
listRewind(server.clients,&li);
|
listRewind(server.clients,&li);
|
||||||
while ((ln = listNext(&li)) != NULL) {
|
while ((ln = listNext(&li)) != NULL) {
|
||||||
|
sds cs;
|
||||||
|
|
||||||
client = listNodeValue(ln);
|
client = listNodeValue(ln);
|
||||||
o = sdscatsds(o,getClientInfoString(client));
|
cs = getClientInfoString(client);
|
||||||
|
o = sdscatsds(o,cs);
|
||||||
|
sdsfree(cs);
|
||||||
o = sdscatlen(o,"\n",1);
|
o = sdscatlen(o,"\n",1);
|
||||||
}
|
}
|
||||||
return o;
|
return o;
|
||||||
|
@ -76,6 +76,7 @@ zskiplistNode *zslInsert(zskiplist *zsl, double score, robj *obj) {
|
|||||||
unsigned int rank[ZSKIPLIST_MAXLEVEL];
|
unsigned int rank[ZSKIPLIST_MAXLEVEL];
|
||||||
int i, level;
|
int i, level;
|
||||||
|
|
||||||
|
redisAssert(!isnan(score));
|
||||||
x = zsl->header;
|
x = zsl->header;
|
||||||
for (i = zsl->level-1; i >= 0; i--) {
|
for (i = zsl->level-1; i >= 0; i--) {
|
||||||
/* store rank that is crossed to reach the insert position */
|
/* store rank that is crossed to reach the insert position */
|
||||||
|
@ -1 +1 @@
|
|||||||
#define REDIS_VERSION "2.9.1"
|
#define REDIS_VERSION "2.9.2"
|
||||||
|
@ -34,6 +34,7 @@ set ::all_tests {
|
|||||||
unit/slowlog
|
unit/slowlog
|
||||||
unit/scripting
|
unit/scripting
|
||||||
unit/maxmemory
|
unit/maxmemory
|
||||||
|
unit/introspection
|
||||||
}
|
}
|
||||||
# Index to the next test to run in the ::all_tests list.
|
# Index to the next test to run in the ::all_tests list.
|
||||||
set ::next_test 0
|
set ::next_test 0
|
||||||
|
5
tests/unit/introspection.tcl
Normal file
5
tests/unit/introspection.tcl
Normal file
@ -0,0 +1,5 @@
|
|||||||
|
start_server {tags {"introspection"}} {
|
||||||
|
test {CLIENT LIST} {
|
||||||
|
r client list
|
||||||
|
} {*addr=*:* fd=* idle=* flags=N db=9 sub=0 psub=0 qbuf=0 obl=0 oll=0 events=r cmd=client*}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user