tweaked buffer sizes

master
Oliver Tonnhofer 2013-06-18 11:48:47 +02:00
parent 9601dbbfde
commit d39703aed9
2 changed files with 2 additions and 2 deletions

View File

@ -17,7 +17,7 @@ type InsertBuffer struct {
func NewInsertBuffer(pg *PostGIS) *InsertBuffer {
ib := InsertBuffer{
In: make(chan InsertElement, 64),
In: make(chan InsertElement),
Tables: make(map[string]*TableTx),
wg: &sync.WaitGroup{},
}

View File

@ -481,7 +481,7 @@ func (pg *PostGIS) NewTableTx(spec *TableSpec) *TableTx {
Table: spec.Name,
Spec: spec,
wg: &sync.WaitGroup{},
rows: make(chan []interface{}, 512),
rows: make(chan []interface{}, 64),
}
tt.wg.Add(1)
go tt.loop()