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

Two fixed for MIGRATE: fix TTL propagation and fix transferring of data bigger than 64k.

Browse Source
This commit is contained in:
antirez 2012-04-03 12:17:40 +02:00
parent fbce475270
commit bde80cb28b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/migrate.c
View File

@ -130,7 +130,7 @@ void migrateCommand(redisClient *c) {
int fd;
long timeout;
long dbid;
time_t ttl;
long long ttl;
robj *o;
rio cmd, payload;
@ -168,7 +168,8 @@ void migrateCommand(redisClient *c) {
redisAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,"SELECT",6));
redisAssertWithInfo(c,NULL,rioWriteBulkLongLong(&cmd,dbid));
ttl = getExpire(c->db,c->argv[3]);
ttl = getExpire(c->db,c->argv[3])-mstime();
if (ttl < 1) ttl = 1;
redisAssertWithInfo(c,NULL,rioWriteBulkCount(&cmd,'*',4));
redisAssertWithInfo(c,NULL,rioWriteBulkString(&cmd,"RESTORE",7));
redisAssertWithInfo(c,NULL,c->argv[3]->encoding == REDIS_ENCODING_RAW);
@ -190,7 +191,7 @@ void migrateCommand(redisClient *c) {
while ((towrite = sdslen(buf)-pos) > 0) {
towrite = (towrite > (64*1024) ? (64*1024) : towrite);
nwritten = syncWrite(fd,buf+nwritten,towrite,timeout);
nwritten = syncWrite(fd,buf+pos,towrite,timeout);
if (nwritten != (signed)towrite) goto socket_wr_err;
pos += nwritten;
}