From 6aebb5bb1d35016bc8e3bed04e971614898cb6ff Mon Sep 17 00:00:00 2001 From: alex Date: Thu, 9 Jul 2026 16:26:00 +0200 Subject: refactored FLUSHALL to work with shards added ExecuteAll and ExecuteReadAll methods to the db --- handlers.go | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) (limited to 'handlers.go') 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:] -- cgit v1.2.3