database/tidb
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Rename lw to lmb

Browse Source
This commit is contained in:
ngaut
2015-11-24 10:56:01 +08:00
parent 68b6ef9a86
commit 8aca043d43
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
kv/union_store.go
View File

@ -58,39 +58,39 @@ type lazyMemBuffer struct {
mb MemBuffer
}
func (lw *lazyMemBuffer) Get(k Key) ([]byte, error) {
if lw.mb == nil {
func (lmb *lazyMemBuffer) Get(k Key) ([]byte, error) {
if lmb.mb == nil {
return nil, ErrNotExist
}
return lw.mb.Get(k)
return lmb.mb.Get(k)
}
func (lw *lazyMemBuffer) Set(key []byte, value []byte) error {
if lw.mb == nil {
lw.mb = p.Get().(MemBuffer)
func (lmb *lazyMemBuffer) Set(key []byte, value []byte) error {
if lmb.mb == nil {
lmb.mb = p.Get().(MemBuffer)
}
return lw.mb.Set(key, value)
return lmb.mb.Set(key, value)
}
func (lw *lazyMemBuffer) NewIterator(param interface{}) Iterator {
if lw.mb == nil {
lw.mb = p.Get().(MemBuffer)
func (lmb *lazyMemBuffer) NewIterator(param interface{}) Iterator {
if lmb.mb == nil {
lmb.mb = p.Get().(MemBuffer)
}
return lw.mb.NewIterator(param)
return lmb.mb.NewIterator(param)
}
func (lw *lazyMemBuffer) Release() {
if lw.mb == nil {
func (lmb *lazyMemBuffer) Release() {
if lmb.mb == nil {
return
}
lw.mb.Release()
lmb.mb.Release()
p.Put(lw.mb)
lw.mb = nil
p.Put(lmb.mb)
lmb.mb = nil
}
// Get implements the Store Get interface.