fix sys prefix

distributedio · Mar 4, 2019 · cab88ec · cab88ec
1 parent 386752b
commit cab88ec
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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
 	}