Method replyDataToRemotAddress

socketproxy/udpproxy.go:380–390

()

}

func (p *UDPProxy) replyDataToRemotAddress() {
	for msg := range p.replyCh {
		_, err := p.listenConn.WriteToUDP(*(msg.data), msg.remoteAddr)
		pool.PutBuf(*msg.data)
		if err != nil {
			p.log.Errorf("[%s]转发目标端口数据到远程端口出错：%s", p.GetKey(), err.Error())
			continue
		}
		p.SendDataCallback(int64(msg.dataSize)) //发送流量记录
	}
}

func (p *UDPProxy) CheckReadTargetDataGoroutineLimit() error {
	if GetGlobalUDPPortForwardGroutineCount() >= GetGlobalUDPReadTargetDataMaxgoroutineCountLimit() {