Removed restore context parameters in AOFEngine

EchoVault · Feb 25, 2024 · 83f0709 · 83f0709
1 parent 8d7fe02
commit 83f0709
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/src/server/aof/engine.go b/src/server/aof/engine.go
@@ -106,11 +106,11 @@ func (engine *Engine) RewriteLog() error {
 	return nil
 }
 
-func (engine *Engine) Restore(ctx context.Context) error {
-	if err := engine.preambleStore.Restore(ctx); err != nil {
+func (engine *Engine) Restore() error {
+	if err := engine.preambleStore.Restore(); err != nil {
 		log.Println(err)
 	}
-	if err := engine.appendStore.Restore(ctx); err != nil {
+	if err := engine.appendStore.Restore(); err != nil {
 		log.Println(err)
 	}
 	return nil

diff --git a/src/server/aof/log/store.go b/src/server/aof/log/store.go
@@ -3,7 +3,6 @@ package log
 import (
 	"bufio"
 	"bytes"
-	"context"
 	"errors"
 	"io"
 	"log"
@@ -112,7 +111,7 @@ func (store *AppendStore) Sync() error {
 	return store.rw.Sync()
 }
 
-func (store *AppendStore) Restore(ctx context.Context) error {
+func (store *AppendStore) Restore() error {
 	store.mut.Lock()
 	defer store.mut.Unlock()
 

diff --git a/src/server/server.go b/src/server/server.go
@@ -244,7 +244,7 @@ func (server *Server) Start(ctx context.Context) {
 	} else {
 		// Restore from AOF by default if it's enabled
 		if conf.RestoreAOF {
-			err := server.AOFEngine.Restore(ctx)
+			err := server.AOFEngine.Restore()
 			if err != nil {
 				log.Println(err)
 			}