caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 08:38:27 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

AOFSYNC command implemented

Browse Source
This commit is contained in:
antirez 2009-12-27 20:31:16 -05:00
parent 7c8163b85b
commit 279e33bee7
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
redis.c
View File

@ -513,6 +513,7 @@ static void zscoreCommand(redisClient *c);
static void zremrangebyscoreCommand(redisClient *c); static void zremrangebyscoreCommand(redisClient *c);
static void multiCommand(redisClient *c); static void multiCommand(redisClient *c);
static void execCommand(redisClient *c); static void execCommand(redisClient *c);
static void aofsyncCommand(redisClient *c);
/*================================= Globals ================================= */ /*================================= Globals ================================= */
@ -581,6 +582,7 @@ static struct redisCommand cmdTable[] = {
{"save",saveCommand,1,REDIS_CMD_INLINE}, {"save",saveCommand,1,REDIS_CMD_INLINE},
{"bgsave",bgsaveCommand,1,REDIS_CMD_INLINE}, {"bgsave",bgsaveCommand,1,REDIS_CMD_INLINE},
{"bgrewriteaof",bgrewriteaofCommand,1,REDIS_CMD_INLINE}, {"bgrewriteaof",bgrewriteaofCommand,1,REDIS_CMD_INLINE},
{"aofsync",aofsyncCommand,1,REDIS_CMD_INLINE},
{"shutdown",shutdownCommand,1,REDIS_CMD_INLINE}, {"shutdown",shutdownCommand,1,REDIS_CMD_INLINE},
{"lastsave",lastsaveCommand,1,REDIS_CMD_INLINE}, {"lastsave",lastsaveCommand,1,REDIS_CMD_INLINE},
{"type",typeCommand,2,REDIS_CMD_INLINE}, {"type",typeCommand,2,REDIS_CMD_INLINE},
@ -6231,6 +6233,13 @@ static void bgrewriteaofCommand(redisClient *c) {
} }
} }
static void aofsyncCommand(redisClient *c) {
if (server.appendonly)
fsync(server.appendfd);
else
addReplySds(c,sdsnew("-ERR Append Only File is not active\r\n"));
}
static void aofRemoveTempFile(pid_t childpid) { static void aofRemoveTempFile(pid_t childpid) {
char tmpfile[256]; char tmpfile[256];