Run proxy run and serve client request
()
| 158 | |
| 159 | // Run proxy run and serve client request |
| 160 | func (s *Server) Run() error { |
| 161 | // start AdminServer first |
| 162 | go s.adminServer.Run() |
| 163 | |
| 164 | // start Server |
| 165 | s.closed.Set(false) |
| 166 | for s.closed.Get() != true { |
| 167 | conn, err := s.listener.Accept() |
| 168 | if err != nil { |
| 169 | log.Warn("[server] listener accept error: %s", err.Error()) |
| 170 | continue |
| 171 | } |
| 172 | |
| 173 | go s.onConn(conn) |
| 174 | } |
| 175 | |
| 176 | return nil |
| 177 | } |
| 178 | |
| 179 | // Close close proxy server |
| 180 | func (s *Server) Close() error { |