diff --git a/db/db.go b/db/db.go index 5b631896..b7efcd08 100644 --- a/db/db.go +++ b/db/db.go @@ -273,10 +273,10 @@ func dbPrefix(ns string, id []byte) []byte { return prefix } -func sysPrefix(ns string, id int) []byte { +func sysPrefix(ns string, id byte) []byte { b := []byte{} b = append(b, sysNamespace...) - b = append(b, ':', byte(sysDatabaseID), ':') + b = append(b, ':', id, ':') return b } diff --git a/db/kv.go b/db/kv.go index 5ff427f9..1a6aebef 100644 --- a/db/kv.go +++ b/db/kv.go @@ -192,8 +192,8 @@ func (kv *Kv) FlushAll(ctx context.Context) error { if err := unsafeDeleteRange(ctx, kv.txn.db, prefix, endKey); err != nil { return ErrStorageRetry } - sysStart := sysPrefix(sysNamespace, sysDatabaseID) - sysEnd := sysPrefix(sysNamespace, sysDatabaseID+1) + sysStart := sysPrefix(sysNamespace, byte(sysDatabaseID)) + sysEnd := sysPrefix(sysNamespace, byte(sysDatabaseID+1)) if err := unsafeDeleteRange(ctx, kv.txn.db, sysStart, sysEnd); err != nil { return ErrStorageRetry }