Method encodeLoopUDP

http2/client.go:449–486

encodeLoopUDP encodes data and sends it to the proxied UDP stream. |udp.transport| should be the TLS connection's reader from proxy. |src| should be the external data input.

(udp *Conn, src *io.PipeReader)

// |udp.transport| should be the TLS connection's reader from proxy.
// |src| should be the external data input.
func (c *Client) encodeLoopUDP(udp *Conn, src *io.PipeReader) {
	data := make([]byte, 1460)
loop:
	for {
		select {
		case <-udp.connCtx.Done():
			break loop
		default:
			{
				n, err := src.Read(data)
				if err != nil {
					if err == io.EOF {
						c.logger.Warn("EOF in udp.transport.Read")
						break loop
					}
					c.logger.Error("Error in encodeLoopUDP src.Read", "id", udp.Sid(), "err", err)
					break loop
				}

				if n > 0 {
					toSend := data[:n]
					chunk, n := StreamDataToDatagramChunk(toSend, n)
					if n > 0 {
						_, err := udp.transport.Write(chunk)
						if err != nil {
							c.logger.Error("Error in encodeLoopUDP udp.transport.Write", "id", udp.Sid(), "err", err)
							break loop
						}
					}
				}
			}
		}
	}

	if err := udp.doClose(); err != nil {
		c.logger.Error("Error from udp.doClose in encodeLoopUDP", "err", err)
	}
}

// decodeLoopUDP decodes data received from the proxied UDP stream.
// |udp.transport| should be the TLS connection's reader from proxy.