Method getOrCreate

interpreter/async.go:218–243

getOrCreate returns the existing call state for the (node id, args) tuple, or registers and returns a new one. A newly registered call is assigned a unique callID and counted as pending.

(id int64, function, overload string, argVals []ref.Val, impl functions.AsyncOp, gate *asyncGate)

// getOrCreate returns the existing call state for the (node id, args) tuple, or registers and
// returns a new one. A newly registered call is assigned a unique callID and counted as pending.
func (t *asyncCallStateTracker) getOrCreate(id int64, function, overload string, argVals []ref.Val, impl functions.AsyncOp, gate *asyncGate) *asyncCallState {
	key := hashCall(id, overload, argVals)

	t.mu.RLock()
	acs := findInBucket(t.calls[key], id, function, overload, argVals)
	t.mu.RUnlock()
	if acs != nil {
		return acs
	}

	t.mu.Lock()
	defer t.mu.Unlock()
	// Check again in case it was created while waiting for the lock.
	if acs := findInBucket(t.calls[key], id, function, overload, argVals); acs != nil {
		return acs
	}

	// Assign a new unique call ID for this async call.
	acs = newAsyncCallState(id, function, overload, argVals, impl)
	callID := t.nextCallID.Add(1)
	acs.callID = callID
	acs.gate = gate
	t.calls[key] = append(t.calls[key], acs)
	t.callsByID[callID] = acs
	return acs
}

func (t *asyncCallStateTracker) getByID(callID int64) *asyncCallState {
	t.mu.RLock()