Method maybeDrain

agent/tools_executor.go:309–336

()

	defer e.mu.Unlock()
	return e.slots[tcID]
}

func (e *StreamingToolExecutor) GetSlotInfo(toolUseID string) SlotInfo {
	return e.GetSlot(toolUseID)
}

func (e *StreamingToolExecutor) Cancelled() bool {
	select {
	case <-e.cancelCtx.Done():
		return true
	default:
		return false
	}
}

func (e *StreamingToolExecutor) maybeDrain() {
	var toLaunch []string
	e.mu.Lock()
	if e.Cancelled() {
		e.mu.Unlock()
		return
	}
	for _, tid := range e.toolOrder {
		slot := e.slots[tid]
		if slot != nil && slot.State == ToolStateQueued && e.isSafeLocked(slot.TC) && e.canStartImmediatelyLocked(slot.TC, false) {
			toLaunch = append(toLaunch, tid)
		}
	}
	for _, tid := range e.toolOrder {
		slot := e.slots[tid]
		if slot == nil || slot.State != ToolStateQueued || e.isSafeLocked(slot.TC) || !slot.PermissionGranted {