Method notifyTCP

mux.go:129–141

notifyTCP is called when a new stream is created. It finds the first listener that will accept the given stream. It never blocks.

(req TCPRequest)

// notifyTCP is called when a new stream is created. It finds the first listener
// that will accept the given stream. It never blocks.
func (s *mux) notifyTCP(req TCPRequest) {
	s.mu.Lock()
	defer s.mu.Unlock()

	for _, entry := range s.tcpHandlers {
		if patternMatches(entry.pattern, req.LocalAddr()) {
			go entry.handler(req)
			return
		}
	}

	verbosef("nobody listening for tcp to %v, dropping", req.LocalAddr())
}

// notifyUDP is called when a new packet arrives. It finds the first handler
// with a pattern that matches the packet and delivers the packet to it