()
| 679 | } |
| 680 | |
| 681 | func (s *UdpServer) RefreshBlockAddr() { |
| 682 | s.blockAddrMapMutex.Lock() |
| 683 | defer s.blockAddrMapMutex.Unlock() |
| 684 | |
| 685 | now := time.Now() |
| 686 | for k, v := range s.blockAddrMap { |
| 687 | if v.expireTime.Before(now) { |
| 688 | delete(s.blockAddrMap, k) |
| 689 | } |
| 690 | } |
| 691 | } |
| 692 | |
| 693 | func (s *UdpServer) sendMessageRoutine() { |
| 694 | defer s.wg.Done() |
no outgoing calls
no test coverage detected