use buffered channel (#4197)

envestcc · dustinxie · commit e85611fb327d · 2024-03-21T18:11:47.000-07:00
diff --git a/actpool/actpool.go b/actpool/actpool.go
@@ -436,7 +436,7 @@ func (ap *actPool) context(ctx context.Context) context.Context {
 }
 
 func (ap *actPool) enqueue(ctx context.Context, act *action.SealedEnvelope, replace bool) error {
-	var errChan = make(chan error) // unused errChan will be garbage-collected
+	var errChan = make(chan error, 1) // unused errChan will be garbage-collected
 	ap.jobQueue[ap.allocatedWorker(act.SenderAddress())] <- workerJob{
 		ctx,
 		act,

Original file line number	Diff line number	Diff line change
`@@ -436,7 +436,7 @@ func (ap *actPool) context(ctx context.Context) context.Context {`
`436`	`436`	`}`
`437`	`437`
`438`	`438`	`func (ap actPool) enqueue(ctx context.Context, act action.SealedEnvelope, replace bool) error {`
`439`		`- var errChan = make(chan error) // unused errChan will be garbage-collected`
	`439`	`+ var errChan = make(chan error, 1) // unused errChan will be garbage-collected`
`440`	`440`	`ap.jobQueue[ap.allocatedWorker(act.SenderAddress())] <- workerJob{`
`441`	`441`	`ctx,`
`442`	`442`	`act,`