Relocate payload in receiver function to avoid copying

Author: lspgn

cmd/goflow/goflow.go

@@ -12,6 +12,8 @@ import (
 	"github.com/cloudflare/goflow/v3/utils"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
 	log "github.com/sirupsen/logrus"
+
+	_ "net/http/pprof"
 )
 
 var (

utils/utils.go

@@ -189,17 +189,16 @@ func UDPRoutine(name string, decodeFunc decoder.DecoderFunc, workers int, addr s
 	}
 
 	routine := func(lane int, udpconn *net.UDPConn) {
-		payload := make([]byte, 9000)
 		localIP := addrUDP.IP.String()
 		if addrUDP.IP == nil {
 			localIP = ""
 		}
 
 		for {
-			size, pktAddr, _ := udpconn.ReadFromUDP(payload)
-			payloadCut := make([]byte, size)
-			copy(payloadCut, payload[0:size])
+			payload := make([]byte, 9000)
 
+			size, pktAddr, _ := udpconn.ReadFromUDP(payload)
+			payloadCut := payload[0:size]
 			baseMessage := BaseMessage{
 				Src:     pktAddr.IP,
 				Port:    pktAddr.Port,