()
| 658 | } |
| 659 | |
| 660 | func (s *server) UnpauseAccept() { |
| 661 | s.pauseAcceptMu.Lock() |
| 662 | select { |
| 663 | case <-s.pauseAcceptc: // already unpaused |
| 664 | case <-s.donec: |
| 665 | s.pauseAcceptMu.Unlock() |
| 666 | return |
| 667 | default: |
| 668 | close(s.pauseAcceptc) |
| 669 | } |
| 670 | s.pauseAcceptMu.Unlock() |
| 671 | |
| 672 | s.lg.Info( |
| 673 | "unpaused accept", |
| 674 | zap.String("from", s.From()), |
| 675 | zap.String("to", s.To()), |
| 676 | ) |
| 677 | } |
| 678 | |
| 679 | func (s *server) DelayAccept(latency, rv time.Duration) { |
| 680 | if latency <= 0 { |