From 279e33bee7ababb69e614b3d862ddd0a3e44d0cf Mon Sep 17 00:00:00 2001
From: antirez <antirez@gmail.com>
Date: Sun, 27 Dec 2009 20:31:16 -0500
Subject: [PATCH] AOFSYNC command implemented

---
 redis.c | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/redis.c b/redis.c
index a97427cc8..3b86e0847 100644
--- a/redis.c
+++ b/redis.c
@@ -513,6 +513,7 @@ static void zscoreCommand(redisClient *c);
 static void zremrangebyscoreCommand(redisClient *c);
 static void multiCommand(redisClient *c);
 static void execCommand(redisClient *c);
+static void aofsyncCommand(redisClient *c);
 
 /*================================= Globals ================================= */
 
@@ -581,6 +582,7 @@ static struct redisCommand cmdTable[] = {
     {"save",saveCommand,1,REDIS_CMD_INLINE},
     {"bgsave",bgsaveCommand,1,REDIS_CMD_INLINE},
     {"bgrewriteaof",bgrewriteaofCommand,1,REDIS_CMD_INLINE},
+    {"aofsync",aofsyncCommand,1,REDIS_CMD_INLINE},
     {"shutdown",shutdownCommand,1,REDIS_CMD_INLINE},
     {"lastsave",lastsaveCommand,1,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) {
     char tmpfile[256];