Removed restore context parameters in AOFEngine

This commit is contained in:
Kelvin Clement Mwinuka
2024-02-25 15:19:16 +08:00
parent 8d7fe0225a
commit 83f070986d
3 changed files with 5 additions and 6 deletions

View File

@@ -106,11 +106,11 @@ func (engine *Engine) RewriteLog() error {
return nil return nil
} }
func (engine *Engine) Restore(ctx context.Context) error { func (engine *Engine) Restore() error {
if err := engine.preambleStore.Restore(ctx); err != nil { if err := engine.preambleStore.Restore(); err != nil {
log.Println(err) log.Println(err)
} }
if err := engine.appendStore.Restore(ctx); err != nil { if err := engine.appendStore.Restore(); err != nil {
log.Println(err) log.Println(err)
} }
return nil return nil

View File

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

View File

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