refactored FLUSHALL to work with shards added ExecuteAll and ExecuteReadAll methods to the db

1 files changed, 8 insertions, 8 deletions

diff --git a/handlers.go b/handlers.go
index 23efa9a..0b5267c 100644
--- a/handlers.go
+++ b/handlers.go
@@ -183,21 +183,21 @@ func handlePing(conn net.Conn, args []string) {
 	conn.Write(serializeRESP(SimpleString("PONG")))
 }
 
-/*
 func handleFlushall(conn net.Conn, args []string) {
-	db.mu.Lock()
-	defer db.mu.Unlock()
-
 	if len(args) != 1 {
         err := errors.New("wrong number of arguments for 'FLUSHALL'")
         conn.Write(serializeRESP(err))
 		return
     }
-
-	db.data = make(map[string]Item)
-	conn.Write(serializeRESP(SimpleString("OK")))
+	result := db.ExecuteAll(func(shards []*Shard)interface{}{
+		for _, shard := range shards{
+			shard.data = make(map[string]Item)
+		}
+		return SimpleString("OK")
+	})
+	conn.Write(serializeRESP(result))
 }
-
+/*
 func handleRpush(conn net.Conn, args []string) {
 	key := args[1]
 	newItems := args[2:]