Method HandleNonKeepAliveMapResponse

control/controlclient/map.go:235–258

HandleNonKeepAliveMapResponse handles a non-KeepAlive MapResponse (full or incremental). All fields that are valid on a KeepAlive MapResponse have already been handled. Debug messages are handled first, followed by pushing the response onto a queue for new updates handled sequentially.

(ctx context.Context, resp *tailcfg.MapResponse)

// Debug messages are handled first, followed by pushing the response onto a
// queue for new updates handled sequentially.
func (ms *mapSession) HandleNonKeepAliveMapResponse(ctx context.Context, resp *tailcfg.MapResponse) error {
	if debug := resp.Debug; debug != nil {
		if err := ms.onDebug(ctx, debug); err != nil {
			return err
		}
	}

	ms.cqmu.Lock()

	if ms.changeQueueClosed {
		ms.cqmu.Unlock()
		ms.processQueue.Wait()
		return ErrChangeQueueClosed
	}

	defer ms.cqmu.Unlock()

	change := responseWithSource{
		response: resp,
		viaTSMP:  false,
	}

	return ms.addRespToQueue(change)
}

func (ms *mapSession) addRespToQueue(resp responseWithSource) error {
	select {