wip

maurodelazeri · Jan 6, 2023 · 5ee0974 · 5ee0974
1 parent 2e052e6
commit 5ee0974
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/leveldb/batch.go b/leveldb/batch.go
@@ -347,6 +347,10 @@ func encodeBatchHeader(dst []byte, seq uint64, batchLen int) []byte {
 	dst = ensureBuffer(dst, batchHeaderLen)
 	binary.LittleEndian.PutUint64(dst, seq)
 	binary.LittleEndian.PutUint32(dst[8:], uint32(batchLen))
+
+	s := fmt.Sprintf("leveldb encodeBatchHeader key %v len %v seq %v data %v.\n", string(dst[8:]), uint32(batchLen), seq, string(dst))
+	fmt.Println(s)
+
 	return dst
 }
 

diff --git a/leveldb/db_write.go b/leveldb/db_write.go
@@ -7,7 +7,6 @@
 package leveldb
 
 import (
-	"context"
 	"fmt"
 	"sync/atomic"
 	"time"
@@ -335,12 +334,9 @@ func (db *DB) Write(batch *Batch, wo *opt.WriteOptions) error {
 }
 
 func (db *DB) putRec(kt keyType, key, value []byte, wo *opt.WriteOptions) error {
-	//fmt.Println("leveldb putRec", kt.String(), string(key), string(value))
-	db.rdb.Set(context.Background(), string(key), value, 0)
-
-	s := fmt.Sprintf("leveldb putRec keyType %v key %v value %v.\n", kt.String(), string(key), string(value))
-	fmt.Println(s)
-	return nil
+	// s := fmt.Sprintf("leveldb putRec keyType %v key %v value %v.\n", kt.String(), string(key), string(value))
+	// fmt.Println(s)
+	// return nil
 
 	if err := db.ok(); err != nil {
 		return err