database/tidb
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #475 from pingcap/goroutine/compactor-clean-up

Browse Source 
compactor: Tiny clean up
This commit is contained in:
goroutine
2015-10-28 19:30:18 +08:00
parent 6faeeb7261 1c709119a9
commit d24b1d17ee
1 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
store/localstore/compactor.go
View File

@ -91,18 +91,16 @@ func (gc *localstoreCompactor) deleteWorker() {
case <-gc.stopCh:
return
case key := <-gc.delCh:
{
cnt++
batch.Delete(key)
// Batch delete.
if cnt == gc.policy.BatchDeleteCnt {
err := gc.db.Commit(batch)
if err != nil {
log.Error(err)
}
batch = gc.db.NewBatch()
cnt = 0
cnt++
batch.Delete(key)
// Batch delete.
if cnt == gc.policy.BatchDeleteCnt {
err := gc.db.Commit(batch)
if err != nil {
log.Error(err)
}
batch = gc.db.NewBatch()
cnt = 0
}
}
}
@ -126,7 +124,6 @@ func (gc *localstoreCompactor) checkExpiredKeysWorker() {
gc.recentKeys = make(map[string]struct{})
gc.mu.Unlock()
log.Info("GC trigger")
// Do Compactor
for k := range m {
err := gc.Compact(nil, []byte(k))
if err != nil {