fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-04-01 15:21:03 +00:00
Code Issues Projects Releases Wiki Activity

minor bug fixed in WATCH

Browse Source
This commit is contained in:
antirez 2010-05-25 13:21:23 +02:00
parent 37ab76c99d
commit 87c68815c3
3 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
redis-cli.c
View File

@ -175,6 +175,8 @@ static struct redisCommand cmdTable[] = {
{"psubscribe",-2,CMDFLAG_NONE}, {"psubscribe",-2,CMDFLAG_NONE},
{"punsubscribe",-1,CMDFLAG_NONE}, {"punsubscribe",-1,CMDFLAG_NONE},
{"publish",3,CMDFLAG_NONE}, {"publish",3,CMDFLAG_NONE},
{"watch",-2,CMDFLAG_NONE},
{"unwatch",1,CMDFLAG_NONE},
{NULL,0,CMDFLAG_NONE} {NULL,0,CMDFLAG_NONE}
}; };

1
redis.c
View File

@ -2743,6 +2743,7 @@ static redisClient *createClient(int fd) {
c->blocking_keys = NULL; c->blocking_keys = NULL;
c->blocking_keys_num = 0; c->blocking_keys_num = 0;
c->io_keys = listCreate(); c->io_keys = listCreate();
c->watched_keys = listCreate();
listSetFreeMethod(c->io_keys,decrRefCount); listSetFreeMethod(c->io_keys,decrRefCount);
c->pubsub_channels = dictCreate(&setDictType,NULL); c->pubsub_channels = dictCreate(&setDictType,NULL);
c->pubsub_patterns = listCreate(); c->pubsub_patterns = listCreate();

5
staticsymbols.h
View File

@ -289,6 +289,7 @@ static struct redisFunctionSym symsTable[] = {
{"syncReadLine",(unsigned long)syncReadLine}, {"syncReadLine",(unsigned long)syncReadLine},
{"syncWithMaster",(unsigned long)syncWithMaster}, {"syncWithMaster",(unsigned long)syncWithMaster},
{"syncWrite",(unsigned long)syncWrite}, {"syncWrite",(unsigned long)syncWrite},
{"touchWatchedKey",(unsigned long)touchWatchedKey},
{"tryFreeOneObjectFromFreelist",(unsigned long)tryFreeOneObjectFromFreelist}, {"tryFreeOneObjectFromFreelist",(unsigned long)tryFreeOneObjectFromFreelist},
{"tryObjectEncoding",(unsigned long)tryObjectEncoding}, {"tryObjectEncoding",(unsigned long)tryObjectEncoding},
{"tryResizeHashTables",(unsigned long)tryResizeHashTables}, {"tryResizeHashTables",(unsigned long)tryResizeHashTables},
@ -297,6 +298,8 @@ static struct redisFunctionSym symsTable[] = {
{"unblockClientWaitingData",(unsigned long)unblockClientWaitingData}, {"unblockClientWaitingData",(unsigned long)unblockClientWaitingData},
{"unlockThreadedIO",(unsigned long)unlockThreadedIO}, {"unlockThreadedIO",(unsigned long)unlockThreadedIO},
{"unsubscribeCommand",(unsigned long)unsubscribeCommand}, {"unsubscribeCommand",(unsigned long)unsubscribeCommand},
{"unwatchAllKeys",(unsigned long)unwatchAllKeys},
{"unwatchCommand",(unsigned long)unwatchCommand},
{"updateDictResizePolicy",(unsigned long)updateDictResizePolicy}, {"updateDictResizePolicy",(unsigned long)updateDictResizePolicy},
{"updateSlavesWaitingBgsave",(unsigned long)updateSlavesWaitingBgsave}, {"updateSlavesWaitingBgsave",(unsigned long)updateSlavesWaitingBgsave},
{"usage",(unsigned long)usage}, {"usage",(unsigned long)usage},
@ -325,6 +328,8 @@ static struct redisFunctionSym symsTable[] = {
{"waitEmptyIOJobsQueue",(unsigned long)waitEmptyIOJobsQueue}, {"waitEmptyIOJobsQueue",(unsigned long)waitEmptyIOJobsQueue},
{"waitForMultipleSwappedKeys",(unsigned long)waitForMultipleSwappedKeys}, {"waitForMultipleSwappedKeys",(unsigned long)waitForMultipleSwappedKeys},
{"waitForSwappedKey",(unsigned long)waitForSwappedKey}, {"waitForSwappedKey",(unsigned long)waitForSwappedKey},
{"watchCommand",(unsigned long)watchCommand},
{"watchForKey",(unsigned long)watchForKey},
{"xorDigest",(unsigned long)xorDigest}, {"xorDigest",(unsigned long)xorDigest},
{"xorObjectDigest",(unsigned long)xorObjectDigest}, {"xorObjectDigest",(unsigned long)xorObjectDigest},
{"yesnotoi",(unsigned long)yesnotoi}, {"yesnotoi",(unsigned long)yesnotoi},