fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-19 17:10:50 +00:00
Code Issues Projects Releases Wiki Activity

make prototype of custom function to preload keys from the vm match the prototype of waitForMultipleSwappedKeys

Browse Source
This commit is contained in:
Pieter Noordhuis 2010-05-07 12:58:44 +02:00
parent 6f07874621
commit ca1788b560
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
redis.c
View File

@ -450,6 +450,7 @@ typedef struct pubsubPattern {
} pubsubPattern; } pubsubPattern;
typedef void redisCommandProc(redisClient *c); typedef void redisCommandProc(redisClient *c);
typedef void redisVmPreloadProc(redisClient *c, struct redisCommand *cmd, int argc, robj **argv);
struct redisCommand { struct redisCommand {
char *name; char *name;
redisCommandProc *proc; redisCommandProc *proc;
@ -458,7 +459,7 @@ struct redisCommand {
/* Use a function to determine which keys need to be loaded /* Use a function to determine which keys need to be loaded
* in the background prior to executing this command. Takes precedence * in the background prior to executing this command. Takes precedence
* over vm_firstkey and others, ignored when NULL */ * over vm_firstkey and others, ignored when NULL */
redisCommandProc *vm_preload_proc; redisVmPreloadProc *vm_preload_proc;
/* What keys should be loaded in background when calling this command? */ /* What keys should be loaded in background when calling this command? */
int vm_firstkey; /* The first argument that's a key (0 = no keys) */ int vm_firstkey; /* The first argument that's a key (0 = no keys) */
int vm_lastkey; /* THe last argument that's a key */ int vm_lastkey; /* THe last argument that's a key */
@ -608,7 +609,7 @@ static robj *vmReadObjectFromSwap(off_t page, int type);
static void waitEmptyIOJobsQueue(void); static void waitEmptyIOJobsQueue(void);
static void vmReopenSwapFile(void); static void vmReopenSwapFile(void);
static int vmFreePage(off_t page); static int vmFreePage(off_t page);
static void zunionInterBlockClientOnSwappedKeys(redisClient *c); static void zunionInterBlockClientOnSwappedKeys(redisClient *c, struct redisCommand *cmd, int argc, robj **argv);
static int blockClientOnSwappedKeys(struct redisCommand *cmd, redisClient *c); static int blockClientOnSwappedKeys(struct redisCommand *cmd, redisClient *c);
static int dontWaitForSwappedKey(redisClient *c, robj *key); static int dontWaitForSwappedKey(redisClient *c, robj *key);
static void handleClientsBlockedOnSwappedKey(redisDb *db, robj *key); static void handleClientsBlockedOnSwappedKey(redisDb *db, robj *key);
@ -9562,11 +9563,14 @@ static void waitForMultipleSwappedKeys(redisClient *c, struct redisCommand *cmd,
} }
/* Preload keys needed for the ZUNION and ZINTER commands. */ /* Preload keys needed for the ZUNION and ZINTER commands. */
static void zunionInterBlockClientOnSwappedKeys(redisClient *c) { static void zunionInterBlockClientOnSwappedKeys(redisClient *c, struct redisCommand *cmd, int argc, robj **argv) {
int i, num; int i, num;
num = atoi(c->argv[2]->ptr); REDIS_NOTUSED(cmd);
REDIS_NOTUSED(argc);
num = atoi(argv[2]->ptr);
for (i = 0; i < num; i++) { for (i = 0; i < num; i++) {
waitForSwappedKey(c,c->argv[3+i]); waitForSwappedKey(c,argv[3+i]);
} }
} }
@ -9582,7 +9586,7 @@ static void zunionInterBlockClientOnSwappedKeys(redisClient *c) {
* continue as the keys it is going to access appear to be in memory. */ * continue as the keys it is going to access appear to be in memory. */
static int blockClientOnSwappedKeys(struct redisCommand *cmd, redisClient *c) { static int blockClientOnSwappedKeys(struct redisCommand *cmd, redisClient *c) {
if (cmd->vm_preload_proc != NULL) { if (cmd->vm_preload_proc != NULL) {
cmd->vm_preload_proc(c); cmd->vm_preload_proc(c,cmd,c->argc,c->argv);
} else { } else {
waitForMultipleSwappedKeys(c,cmd,c->argc,c->argv); waitForMultipleSwappedKeys(c,cmd,c->argc,c->argv);
} }