Merge pull request #39 from ucwong/dev

bolt, leveldb ttl rollback func added

Author: ucwong

bolt/bolt.go

@@ -186,6 +186,11 @@ func (b *Bolt) SetTTL(k, v []byte, expire time.Duration) (err error) {
 		return buk.Put(k, v)
 	})
 
+	if err != nil {
+		// TODO
+		b.ttl_map.Delete(string(k))
+	}
+
 	return
 }
 

leveldb/leveldb.go

@@ -141,6 +141,11 @@ func (ldb *LevelDB) SetTTL(k, v []byte, expire time.Duration) (err error) {
 
 	err = ldb.engine.Put(k, v, nil)
 
+	if err != nil {
+		// TODO
+		ldb.ttl_map.Delete(string(k))
+	}
+
 	return
 }