(vol, key string, data []byte)
| 197 | } |
| 198 | |
| 199 | func (bm *bcacheManager) cacheDirect(vol, key string, data []byte) { |
| 200 | diskKv := bm.selectDiskKv(key) |
| 201 | if diskKv.flushKey(vol, key, data) == nil { |
| 202 | bm.Lock() |
| 203 | item := &cacheItem{ |
| 204 | key: key, |
| 205 | size: uint32(len(data)), |
| 206 | } |
| 207 | element := bm.lrulist.PushBack(item) |
| 208 | bm.bcacheKeys[key] = element |
| 209 | bm.Unlock() |
| 210 | } |
| 211 | } |
| 212 | |
| 213 | func (bm *bcacheManager) read(key string, offset uint64, len uint32) (io.ReadCloser, error) { |
| 214 | var err error |