Method Serve

proxy/tcp/server.go:65–100

(l net.Listener)

}

func (s *Server) Serve(l net.Listener) error {
	defer l.Close()

	s.mu.Lock()
	s.listeners = append(s.listeners, l)
	s.mu.Unlock()

	for {
		c, err := l.Accept()
		if err != nil {
			return err
		}
		c = &conn{
			c:            c,
			ReadTimeout:  s.ReadTimeout,
			WriteTimeout: s.WriteTimeout,
		}
		s.mu.Lock()
		if s.conns == nil {
			s.conns = map[net.Conn]bool{}
		}
		s.conns[c] = true
		s.mu.Unlock()

		go func() {
			defer func() {
				c.Close()
				s.mu.Lock()
				delete(s.conns, c)
				s.mu.Unlock()
			}()

			s.Handler.ServeTCP(c)
		}()
	}
}

func (s *Server) closeListeners() {
	s.mu.Lock()