(l net.Listener)
| 441 | } |
| 442 | |
| 443 | func (s *Proxy) acceptConn(l net.Listener) (net.Conn, error) { |
| 444 | var delay = &DelayExp2{ |
| 445 | Min: 10, Max: 500, |
| 446 | Unit: time.Millisecond, |
| 447 | } |
| 448 | for { |
| 449 | c, err := l.Accept() |
| 450 | if err != nil { |
| 451 | if e, ok := err.(net.Error); ok && e.Temporary() { |
| 452 | log.WarnErrorf(err, "[%p] proxy accept new connection failed", s) |
| 453 | delay.Sleep() |
| 454 | continue |
| 455 | } |
| 456 | } |
| 457 | return c, err |
| 458 | } |
| 459 | } |
| 460 | |
| 461 | type Overview struct { |
| 462 | Version string `json:"version"` |
no test coverage detected