mods := make([]*Ent, 0, len(modsNames)+len(rens))
if len(rens) > 0 {
sort.Sort(BySrc(rens))
- go reader(bufio.NewReaderSize(db, 1<<17), entsReader)
+ go reader(db, entsReader)
var ent Ent
var ok, met bool
for {
entsReader = make(chan Ent, 1<<10)
entsDirSizer := make(chan Ent, 1<<10)
entsWriter := make(chan Ent, 1<<10)
- go reader(bufio.NewReaderSize(db, 1<<17), entsReader)
+ go reader(db, entsReader)
dirSizerJob := make(chan struct{})
var dirSizes []int64
close(dirSizerJob)
}()
- bw := bufio.NewWriterSize(tmp0, 1<<17)
writerJob := make(chan struct{})
go func() {
- writer(bw, entsWriter)
+ writer(tmp0, entsWriter)
close(writerJob)
}()
<-dirSizerJob
close(entsWriter)
<-writerJob
- if err = bw.Flush(); err != nil {
- log.Fatalln(err)
- }
tmp1 := applyDirSizes(tmp0, dirSizes)
tmp0.Close()