-
Notifications
You must be signed in to change notification settings - Fork 0
/
logsegment.go
95 lines (81 loc) · 2 KB
/
logsegment.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
package leveldb
import (
"github.com/robaho/leveldb/skip"
"os"
"path/filepath"
"runtime"
)
// logSegment is a read-only segment created from a previous run but not yet merged
type logSegment struct {
list skip.SkipList[KeyValue]
id uint64
path string
options Options
filesize uint64
}
func newLogSegment(path string, options Options) (segment, error) {
ls := new(logSegment)
list, err := readLogFile(path, options)
if err != nil {
return nil, err
}
ls.list = *list
ls.id = getSegmentID(path)
ls.path = path
ls.options = options
info, err := os.Stat(path)
if err != nil {
return nil, err
}
ls.filesize = uint64(info.Size())
return ls, nil
}
func (ls *logSegment) size() uint64 {
return ls.filesize
}
func (ls *logSegment) LowerID() uint64 {
return ls.id
}
func (ls *logSegment) UpperID() uint64 {
return ls.id
}
func (ls *logSegment) Get(key []byte) ([]byte, error) {
value, ok := ls.list.Get(Key(key))
if !ok {
return nil, KeyNotFound
}
return value.value, nil
}
func (ls *logSegment) Put(key []byte, value []byte) ([]byte, error) {
panic("Put called on immutable logSegment")
}
func (ls *logSegment) Write(wb WriteBatch) error {
panic("Write called on immutable logSegment")
}
func (ls *logSegment) Remove(key []byte) ([]byte, error) {
panic("Remove called on immutable logSegment")
}
func (ls *logSegment) Lookup(lower []byte, upper []byte) (LookupIterator, error) {
itr := ls.list.Iterator()
if lower != nil {
itr.Seek(Key(lower))
} else {
itr.SeekToFirst()
}
return &skiplistIterator{itr: itr, lower: Key(lower), upper: Key(upper), cmp: keyValueCompare(ls.options)}, nil
}
func (ls *logSegment) Close() error {
return nil
}
func (ls *logSegment) removeSegment() error {
var err0, err1 error
err0 = ls.Close()
err1 = os.Remove(ls.path)
return errn(err0, err1)
}
func (ls *logSegment) removeOnFinalize() {
runtime.SetFinalizer(ls, func(ls *logSegment) { ls.removeSegment() })
}
func (ls *logSegment) files() []string {
return []string{filepath.Base(ls.path)}
}