gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rewrite INCRBYFLOAT as SETs for AOF/replication

Browse Source
This commit is contained in:
antirez 2011-11-14 10:15:13 +01:00
parent 5574b53eae
commit 5244d6e54e
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/t_string.c
View File

@ -385,7 +385,7 @@ void decrbyCommand(redisClient *c) {
void incrbyfloatCommand(redisClient *c) { void incrbyfloatCommand(redisClient *c) {
long double incr, value; long double incr, value;
robj *o, *new; robj *o, *new, *aux;
o = lookupKeyWrite(c->db,c->argv[1]); o = lookupKeyWrite(c->db,c->argv[1]);
if (o != NULL && checkType(c,o,REDIS_STRING)) return; if (o != NULL && checkType(c,o,REDIS_STRING)) return;
@ -406,6 +406,14 @@ void incrbyfloatCommand(redisClient *c) {
signalModifiedKey(c->db,c->argv[1]); signalModifiedKey(c->db,c->argv[1]);
server.dirty++; server.dirty++;
addReplyBulk(c,new); addReplyBulk(c,new);
/* Always replicate INCRBYFLOAT as a SET command with the final value
* in order to make sure that differences in float pricision or formatting
* will not create differences in replicas or after an AOF restart. */
aux = createStringObject("SET",3);
rewriteClientCommandArgument(c,0,aux);
decrRefCount(aux);
rewriteClientCommandArgument(c,2,new);
} }
void appendCommand(redisClient *c) { void appendCommand(redisClient *c) {