go/sugardb
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: go:main
Branches Tags
go:main
go:v0.0.3
go:v0.0.2
go:v0.0.1
..
compare: go:v0.0.1
Branches Tags
go:main
go:v0.0.3
go:v0.0.2
go:v0.0.1

No commits in common. "main" and "v0.0.1" have entirely different histories.
main ... v0.0.1

2 changed files with 4 additions and 5 deletions
Show Stats Expand all files Collapse all files

8
internal/aof/log/store.go
View File

@ -148,8 +148,7 @@ func (store *Store) Write(database int, command []byte) error {
// log the SELECT command before logging the incoming command. // log the SELECT command before logging the incoming command.
// This allows us to switch databases appropriately when restoring the state on startup. // This allows us to switch databases appropriately when restoring the state on startup.
if database != store.currentDatabase { if database != store.currentDatabase {
dbStr := strconv.Itoa(database) _, err := store.rw.Write([]byte(fmt.Sprintf("*2\r\n$6\r\nSELECT\r\n$1\r\n%s\r\n", strconv.Itoa(database))))
_, err := store.rw.Write([]byte(fmt.Sprintf("*2\r\n$6\r\nSELECT\r\n$%d\r\n%s\r\n", len(dbStr), dbStr)))
if err != nil { if err != nil {
return fmt.Errorf("log select error: %+v", err) return fmt.Errorf("log select error: %+v", err)
} }
@ -238,9 +237,8 @@ func (store *Store) Truncate() error {
} }
// Add command to select the current database at the top of the file. // Add command to select the current database at the top of the file.
dbStr := strconv.Itoa(store.currentDatabase) _, err := store.rw.Write([]byte(
_, err := store.rw.Write([]byte( fmt.Sprintf("*2\r\n$6\r\nSELECT\r\n$1\r\n%s\r\n", strconv.Itoa(store.currentDatabase))))
fmt.Sprintf("*2\r\n$6\r\nSELECT\r\n$%d\r\n%s\r\n", len(dbStr), dbStr)))
if err != nil { if err != nil {
return fmt.Errorf("truncate: log select error: %+v", err) return fmt.Errorf("truncate: log select error: %+v", err)
} }

1
sugardb/keyspace.go
View File

@ -351,6 +351,7 @@ func (server *SugarDB) deleteKey(ctx context.Context, key string) error {
server.lruCache.cache[database].Delete(key) server.lruCache.cache[database].Delete(key)
} }
log.Printf("deleted key %s\n", key)
return nil return nil
} }