forked from mirror/ledisdb
Merge branch 'copy-bugfix'
This commit is contained in:
commit
5534390b6b
|
@ -196,14 +196,15 @@ func (s *FileStore) storeLog(l *Log) error {
|
|||
func (s *FileStore) PurgeExpired(n int64) error {
|
||||
s.rm.Lock()
|
||||
|
||||
purges := []*tableReader{}
|
||||
var purges []*tableReader
|
||||
|
||||
t := uint32(time.Now().Unix() - int64(n))
|
||||
|
||||
for i, r := range s.rs {
|
||||
if r.lastTime > t {
|
||||
purges = s.rs[0:i]
|
||||
s.rs = s.rs[i:]
|
||||
purges = append([]*tableReader{}, s.rs[0:i]...)
|
||||
n := copy(s.rs, s.rs[i:])
|
||||
s.rs = s.rs[0:n]
|
||||
break
|
||||
}
|
||||
}
|
||||
|
|
|
@ -137,8 +137,7 @@ func (s *snapshotStore) purge(create bool) {
|
|||
}
|
||||
|
||||
if num > 0 {
|
||||
names = s.names[0:num]
|
||||
|
||||
names = append([]string{}, s.names[0:num]...)
|
||||
n := copy(s.names, s.names[num:])
|
||||
s.names = s.names[0:n]
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue