Merge pull request #58 from ucwong/dev

set fix

Author: ucwong

bolt/bolt.go

@@ -98,9 +98,9 @@ func (b *Bolt) Get(k []byte) (v []byte) {
 }
 
 func (b *Bolt) Set(k, v []byte) (err error) {
-	if _, err = b.ttl_map.Delete(string(k)); err != nil {
-		return
-	}
+	//if _, err = b.ttl_map.Delete(string(k)); err != nil {
+	//	return
+	//}
 
 	err = b.engine.Update(func(tx *bolt.Tx) error {
 		buk, e := tx.CreateBucketIfNotExists([]byte(GLOBAL))

leveldb/leveldb.go

@@ -86,9 +86,9 @@ func (ldb *LevelDB) Get(k []byte) (v []byte) {
 }
 
 func (ldb *LevelDB) Set(k, v []byte) (err error) {
-	if _, err = ldb.ttl_map.Delete(string(k)); err != nil {
-		return
-	}
+	//if _, err = ldb.ttl_map.Delete(string(k)); err != nil {
+	//	return
+	//}
 
 	err = ldb.engine.Put(k, v, nil)
 	return

pebble/pebble.go

@@ -80,9 +80,9 @@ func (peb *Pebble) Get(k []byte) (v []byte) {
 }
 
 func (peb *Pebble) Set(k, v []byte) (err error) {
-	if _, err = peb.ttl_map.Delete(string(k)); err != nil {
-		return
-	}
+	//if _, err = peb.ttl_map.Delete(string(k)); err != nil {
+	//	return
+	//}
 
 	err = peb.engine.Set(k, v, pebble.Sync)
 	return
@@ -136,6 +136,11 @@ func (peb *Pebble) Suffix(k []byte) (res [][]byte) {
 }
 
 func (peb *Pebble) Range(start, limit []byte) (res [][]byte) {
+	iter := peb.engine.NewIter(nil)
+	defer iter.Close()
+	for iter.SeekGEWithLimit(start, limit); iter.Valid(); iter.Next() {
+		res = append(res, common.SafeCopy(nil, iter.Value()))
+	}
 	return
 }