vm/dispatcher: simplify runInstance()

Move boot error reporting to a separate function.

1 files changed, 16 insertions, 12 deletions

diff --git a/vm/dispatcher/pool.go b/vm/dispatcher/pool.go
index d3f937b13..08bc1ebfa 100644
--- a/vm/dispatcher/pool.go
+++ b/vm/dispatcher/pool.go
@@ -127,18 +127,7 @@ func (p *Pool[T]) runInstance(ctx context.Context, inst *poolInstance[T]) {
 
 	obj, err := p.creator(inst.idx)
 	if err != nil {
-		select {
-		case p.BootErrors <- err:
-			return
-		default:
-			// Print some log message to make it visible.
-			log.Logf(0, "WARNING: boot error channel is full!")
-		}
-		select {
-		case p.BootErrors <- err:
-		case <-ctx.Done():
-			// On context cancellation, no one might be listening on the channel.
-		}
+		p.reportBootError(ctx, err)
 		return
 	}
 	defer obj.Close()
@@ -166,6 +155,21 @@ func (p *Pool[T]) runInstance(ctx context.Context, inst *poolInstance[T]) {
 	job(ctx, obj, inst.updateInfo)
 }
 
+func (p *Pool[T]) reportBootError(ctx context.Context, err error) {
+	select {
+	case p.BootErrors <- err:
+		return
+	default:
+		// Print some log message to make it visible.
+		log.Logf(0, "WARNING: boot error channel is full!")
+	}
+	select {
+	case p.BootErrors <- err:
+	case <-ctx.Done():
+		// On context cancellation, no one might be listening on the channel.
+	}
+}
+
 // ReserveForRun specifies the size of the sub-pool for the execution of custom runners.
 // The reserved instances will be booted, but the pool will not start the default runner.
 // To unreserve all instances, execute ReserveForRun(0).