aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMartin Czygan <martin.czygan@gmail.com>2021-07-10 12:49:44 +0200
committerMartin Czygan <martin.czygan@gmail.com>2021-07-10 12:49:44 +0200
commit7db9f87f5ab9539cae6ee5c6fe3d18d94c0ae5d8 (patch)
treed22483c20f6069dc14b819c1c21c6d42400950dc
parentad8a18332a0bd32a3bf7dd1e045c31dcd99ba237 (diff)
downloadrefcat-7db9f87f5ab9539cae6ee5c6fe3d18d94c0ae5d8.tar.gz
refcat-7db9f87f5ab9539cae6ee5c6fe3d18d94c0ae5d8.zip
batch: log batch size
-rw-r--r--skate/zipkey/batch.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/skate/zipkey/batch.go b/skate/zipkey/batch.go
index ac7d462..f1e21fe 100644
--- a/skate/zipkey/batch.go
+++ b/skate/zipkey/batch.go
@@ -68,7 +68,7 @@ func (b *Batcher) GroupFunc(g *Group) error {
oversized := len(g.G0) > maxGroupSize || len(g.G1) > maxGroupSize
if len(b.batch) == b.Size || oversized {
if oversized {
- log.Printf("short circuiting large group (%d/%d)", len(g.G0), len(g.G1))
+ log.Printf("short circuiting large group (g0=%d, g1=%d, b=%d)", len(g.G0), len(g.G1), len(b.batch))
}
g := make([]*Group, len(b.batch))
copy(g, b.batch)