reduce buffer sizes

master
Oliver Tonnhofer 2013-06-07 15:39:08 +02:00
parent d6c9e1ee14
commit fd60373b58
1 changed files with 2 additions and 2 deletions

View File

@ -24,8 +24,8 @@ type InsertBuffer struct {
func NewInsertBuffer() *InsertBuffer {
ib := InsertBuffer{
In: make(chan InsertElement, 256),
Out: make(chan InsertBatch, 8),
In: make(chan InsertElement, 64),
Out: make(chan InsertBatch, 1),
wg: &sync.WaitGroup{},
}
ib.wg.Add(1)