Something went wrong. Try again.
Monorepo for Tangled
Something went wrong. Try again.
Go
1234567891011121314151617181920212223242526272829303132333435363738package executor
import ( "context" "fmt" "sync"
"tangled.org/core/spindle/engine" "tangled.org/core/spindle/models")
// wraps a real engine so StartWorkflows gets the slot ReserveSeat already// acquired, not a second one. everything else delegates, the execution// path runs exactly like standalonetype reservedEngine struct { models.Engine slot engine.WorkflowSlot once sync.Once}
func newReservedEngine(inner models.Engine, slot engine.WorkflowSlot) models.Engine { return &reservedEngine{Engine: inner, slot: slot}}
// hands back the pre-acquired slot exactly once, a second acquire would// double-count itfunc (e *reservedEngine) AcquireWorkflowSlot(ctx context.Context, wid models.WorkflowId, wf *models.Workflow, _ engine.AcquireMode) (engine.WorkflowSlot, error) { var slot engine.WorkflowSlot e.once.Do(func() { slot = e.slot e.slot = nil }) if slot == nil { return nil, fmt.Errorf("reserved slot already consumed") } return slot, nil}