mirror of https://github.com/hak5/bolt.git
Clean up after #636
freelist.lenall duplicated freelist.count. freelist.copyall and mergepgids docs had typos.master
parent
f0cf3bfd5b
commit
1858583b3b
15
freelist.go
15
freelist.go
|
@ -46,17 +46,8 @@ func (f *freelist) pending_count() int {
|
||||||
return count
|
return count
|
||||||
}
|
}
|
||||||
|
|
||||||
// lenall returns the combined number of all free ids and all pending ids.
|
// copyall copies into dst a list of all free ids and all pending ids in one sorted list.
|
||||||
func (f *freelist) lenall() int {
|
// f.count returns the minimum length required for dst.
|
||||||
n := len(f.ids)
|
|
||||||
for _, list := range f.pending {
|
|
||||||
n += len(list)
|
|
||||||
}
|
|
||||||
return n
|
|
||||||
}
|
|
||||||
|
|
||||||
// all copies into dst a list of all free ids and all pending ids in one sorted list.
|
|
||||||
// f.lenall returns the minimum length required for dst.
|
|
||||||
func (f *freelist) copyall(dst []pgid) {
|
func (f *freelist) copyall(dst []pgid) {
|
||||||
m := make(pgids, 0, len(f.pending)) // len(f.pending) undercounts, but it is a start
|
m := make(pgids, 0, len(f.pending)) // len(f.pending) undercounts, but it is a start
|
||||||
for _, list := range f.pending {
|
for _, list := range f.pending {
|
||||||
|
@ -200,7 +191,7 @@ func (f *freelist) write(p *page) error {
|
||||||
|
|
||||||
// The page.count can only hold up to 64k elements so if we overflow that
|
// The page.count can only hold up to 64k elements so if we overflow that
|
||||||
// number then we handle it by putting the size in the first element.
|
// number then we handle it by putting the size in the first element.
|
||||||
lenids := f.lenall()
|
lenids := f.count()
|
||||||
if lenids == 0 {
|
if lenids == 0 {
|
||||||
p.count = uint16(lenids)
|
p.count = uint16(lenids)
|
||||||
} else if lenids < 0xFFFF {
|
} else if lenids < 0xFFFF {
|
||||||
|
|
2
page.go
2
page.go
|
@ -154,7 +154,7 @@ func (a pgids) merge(b pgids) pgids {
|
||||||
return merged
|
return merged
|
||||||
}
|
}
|
||||||
|
|
||||||
// merge copies the sorted union of a and b into dst.
|
// mergepgids copies the sorted union of a and b into dst.
|
||||||
// If dst is too small, it panics.
|
// If dst is too small, it panics.
|
||||||
func mergepgids(dst, a, b pgids) {
|
func mergepgids(dst, a, b pgids) {
|
||||||
if len(dst) < len(a)+len(b) {
|
if len(dst) < len(a)+len(b) {
|
||||||
|
|
2
tx.go
2
tx.go
|
@ -381,7 +381,7 @@ func (tx *Tx) Check() <-chan error {
|
||||||
func (tx *Tx) check(ch chan error) {
|
func (tx *Tx) check(ch chan error) {
|
||||||
// Check if any pages are double freed.
|
// Check if any pages are double freed.
|
||||||
freed := make(map[pgid]bool)
|
freed := make(map[pgid]bool)
|
||||||
all := make([]pgid, tx.db.freelist.lenall())
|
all := make([]pgid, tx.db.freelist.count())
|
||||||
tx.db.freelist.copyall(all)
|
tx.db.freelist.copyall(all)
|
||||||
for _, id := range all {
|
for _, id := range all {
|
||||||
if freed[id] {
|
if freed[id] {
|
||||||
|
|
Loading…
Reference in New Issue