re
/
ledisdb
forked from mirror/ledisdb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

remove no used code

This commit is contained in:
siddontang 2017-03-14 22:15:17 +08:00
parent 350d7cd95e
commit b2e8658470
2 changed files with 0 additions and 126 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

75
ledis/multi.go
View File

@ -1,75 +0,0 @@
package ledis
// import (
// "errors"
// "fmt"
// )
// var (
// ErrNestMulti = errors.New("nest multi not supported")
// ErrMultiDone = errors.New("multi has been closed")
// )
// type Multi struct {
// *DB
// }
// func (db *DB) IsInMulti() bool {
// return db.status == DBInMulti
// }
// // begin a mutli to execute commands,
// // it will block any other write operations before you close the multi, unlike transaction, mutli can not rollback
// func (db *DB) Multi() (*Multi, error) {
// if db.IsInMulti() {
// return nil, ErrNestMulti
// }
// m := new(Multi)
// m.DB = new(DB)
// m.DB.status = DBInMulti
// m.DB.l = db.l
// m.l.wLock.Lock()
// m.DB.sdb = db.sdb
// m.DB.bucket = db.sdb
// m.DB.index = db.index
// m.DB.kvBatch = m.newBatch()
// m.DB.listBatch = m.newBatch()
// m.DB.hashBatch = m.newBatch()
// m.DB.zsetBatch = m.newBatch()
// // m.DB.binBatch = m.newBatch()
// m.DB.setBatch = m.newBatch()
// m.DB.lbkeys = db.lbkeys
// return m, nil
// }
// func (m *Multi) newBatch() *batch {
// return m.l.newBatch(m.bucket.NewWriteBatch(), &multiBatchLocker{}, nil)
// }
// func (m *Multi) Close() error {
// if m.bucket == nil {
// return ErrMultiDone
// }
// m.l.wLock.Unlock()
// m.bucket = nil
// return nil
// }
// func (m *Multi) Select(index int) error {
// if index < 0 || index >= int(m.l.cfg.Databases) {
// return fmt.Errorf("invalid db index %d", index)
// }
// m.DB.index = uint8(index)
// return nil
// }

51
ledis/multi_test.go
View File

@ -1,51 +0,0 @@
package ledis
// import (
// "sync"
// "testing"
// )
// func TestMulti(t *testing.T) {
// db := getTestDB()
// key := []byte("test_multi_1")
// v1 := []byte("v1")
// v2 := []byte("v2")
// m, err := db.Multi()
// if err != nil {
// t.Fatal(err)
// }
// wg := sync.WaitGroup{}
// wg.Add(1)
// go func() {
// if err := db.Set(key, v2); err != nil {
// t.Fatal(err)
// }
// wg.Done()
// }()
// if err := m.Set(key, v1); err != nil {
// t.Fatal(err)
// }
// if v, err := m.Get(key); err != nil {
// t.Fatal(err)
// } else if string(v) != string(v1) {
// t.Fatal(string(v))
// }
// m.Close()
// wg.Wait()
// if v, err := db.Get(key); err != nil {
// t.Fatal(err)
// } else if string(v) != string(v2) {
// t.Fatal(string(v))
// }
// }