Method activityFor

internal/exit/exit.go:902–911

activityFor returns owner's wake channel, lazily allocating it on first use. Channels are kept for the life of the server; with a small number of distinct clients per server this is fine.

(owner [frame.ClientIDLen]byte)

// use. Channels are kept for the life of the server; with a small number of
// distinct clients per server this is fine.
func (s *Server) activityFor(owner [frame.ClientIDLen]byte) chan struct{} {
	s.mu.Lock()
	defer s.mu.Unlock()
	ch, ok := s.activity[owner]
	if !ok {
		ch = make(chan struct{}, 1)
		s.activity[owner] = ch
	}
	return ch
}

func (s *Server) isDialSuppressed(target string) bool {
	now := time.Now()