Close implements Wal.Close.
()
| 179 | |
| 180 | // Close implements Wal.Close. |
| 181 | func (p *LevelDBWal) Close() { |
| 182 | if !atomic.CompareAndSwapUint32(&p.closed, 0, 1) { |
| 183 | return |
| 184 | } |
| 185 | |
| 186 | if p.it != nil { |
| 187 | p.it.Release() |
| 188 | p.it = nil |
| 189 | } |
| 190 | |
| 191 | if p.db != nil { |
| 192 | p.db.Close() |
| 193 | } |
| 194 | } |
| 195 | |
| 196 | func (p *LevelDBWal) load(logHeader []byte) (l *kt.Log, err error) { |
| 197 | l = new(kt.Log) |