Function findInBucket

interpreter/async.go:207–214

findInBucket returns the call state in the bucket matching the same node id and call identity, or nil if no match is present.

(bucket []*asyncCallState, id int64, function, overload string, args []ref.Val)

// findInBucket returns the call state in the bucket matching the same node id and call identity,
// or nil if no match is present.
func findInBucket(bucket []*asyncCallState, id int64, function, overload string, args []ref.Val) *asyncCallState {
	for _, acs := range bucket {
		if acs.matches(id, function, overload, args) {
			return acs
		}
	}
	return nil
}

// 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.