Merge pull request #300 from Consensys/299-tweak-buffered-channels

Tweak channel buffers sizes
Consensys · Sep 5, 2024 · 4058fb1 · 4058fb1
2 parents 519fbb2 + 07e4bc0
commit 4058fb1
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/cmd/check.go b/pkg/cmd/check.go
@@ -210,7 +210,7 @@ func validationCheck(tr trace.Trace, schema sc.Schema) error {
 
 	schemaCols := schema.Columns()
 	// Construct a communication channel for errors.
-	c := make(chan error, 10)
+	c := make(chan error, tr.Width())
 	// Check each column in turn
 	for i := uint(0); i < tr.Width(); i++ {
 		// Extract ith column

diff --git a/pkg/schema/schemas.go b/pkg/schema/schemas.go
@@ -68,7 +68,7 @@ func processConstraintBatch(batch uint, batchsize uint, iter util.Iterator[Const
 	var err error
 
 	n := uint(0)
-	c := make(chan error, 10)
+	c := make(chan error, 128)
 	stats := util.NewPerfStats()
 	// Launch at most 100 go-routines.
 	for ; n < batchsize && iter.HasNext(); n++ {

diff --git a/pkg/trace/lt/reader.go b/pkg/trace/lt/reader.go
@@ -36,7 +36,7 @@ func FromBytes(data []byte) ([]trace.RawColumn, error) {
 	}
 	// Determine byte slices
 	offset := uint(len(data) - buf.Len())
-	c := make(chan util.Pair[uint, util.Array[fr.Element]], 100)
+	c := make(chan util.Pair[uint, util.Array[fr.Element]], ncols)
 	// Dispatch go-routines
 	for i := uint(0); i < uint(ncols); i++ {
 		ith := headers[i]