wip

leveldb/db.go

@@ -8,7 +8,6 @@ package leveldb
 
 import (
 	"container/list"
-	"context"
 	"fmt"
 	"io"
 	"os"
@@ -18,7 +17,7 @@ import (
 	"sync/atomic"
 	"time"
 
-	"github.com/go-redis/redis/v8"
+	"github.com/go-redis/redis"
 	"github.com/maurodelazeri/goleveldb/leveldb/cache"
 	"github.com/maurodelazeri/goleveldb/leveldb/errors"
 	"github.com/maurodelazeri/goleveldb/leveldb/iterator"
@@ -872,20 +871,20 @@ func (db *DB) has(auxm *memdb.DB, auxt tFiles, key []byte, seq uint64, ro *opt.R
 func (db *DB) Get(key []byte, ro *opt.ReadOptions) (value []byte, err error) {
 	fmt.Println("GET BABY key", string(key))
 
-	val2, err := db.rdb.Get(context.Background(), string(key)).Result()
-	if err == redis.Nil {
-		return nil, nil
-	} else if err != nil {
-		return nil, err
-	}
-	return []byte(val2), nil
+	// val2, err := db.rdb.Get(context.Background(), string(key)).Result()
+	// if err == redis.Nil {
+	// 	return nil, nil
+	// } else if err != nil {
+	// 	return nil, err
+	// }
+	// return []byte(val2), nil
 
-	//fmt.Println("GET BABY key", string(key))
+	// //fmt.Println("GET BABY key", string(key))
 
-	err = db.ok()
-	if err != nil {
-		return
-	}
+	// err = db.ok()
+	// if err != nil {
+	// 	return
+	// }
 
 	se := db.acquireSnapshot()
 	defer db.releaseSnapshot(se)
@@ -896,19 +895,19 @@ func (db *DB) Get(key []byte, ro *opt.ReadOptions) (value []byte, err error) {
 //
 // It is safe to modify the contents of the argument after Has returns.
 func (db *DB) Has(key []byte, ro *opt.ReadOptions) (ret bool, err error) {
-	fmt.Println("HAS BABY key", string(key))
-	_, err = db.rdb.Get(context.Background(), string(key)).Result()
-	if err == redis.Nil {
-		return false, nil
-	} else if err != nil {
-		return false, err
-	}
-	return true, nil
-
-	err = db.ok()
-	if err != nil {
-		return
-	}
+	// fmt.Println("HAS BABY key", string(key))
+	// _, err = db.rdb.Get(context.Background(), string(key)).Result()
+	// if err == redis.Nil {
+	// 	return false, nil
+	// } else if err != nil {
+	// 	return false, err
+	// }
+	// return true, nil
+
+	// err = db.ok()
+	// if err != nil {
+	// 	return
+	// }
 
 	se := db.acquireSnapshot()
 	defer db.releaseSnapshot(se)