Утечка памяти при передачи данных по udp

func SendData(dataSendEnd chan struct{}) {
    conn, err := net.DialUDP("udp", nil, *&dest)
    defer func() {
        conn.Close()
        fmt.Println("Goroutine sending data finished")
        dataSendEnd <- struct{}{}
    }()
 
    if err != nil {
        fmt.Fprintf(os.Stderr, "error: %v\n", err)
        panic(1)
    }
 
    i := 0
    var wg sync.WaitGroup
    var mu sync.Mutex
 
    for currentData := range dataChan {
        if i == packetCount {
            time.Sleep(timeSync * time.Millisecond)
            i = 0
        }
 
        wg.Add(1)
        go func(data []byte) {
            defer wg.Done()
            mu.Lock()
            _, err := conn.Write(currentData)
            mu.Unlock()
            if err != nil {
                fmt.Fprintf(os.Stderr, "error: %v\n", err)
            }
        }(currentData)
        i++
    }
    wg.Wait()
 
}

type destFlag struct{ net.UDPAddr }
 
func (f *destFlag) String() string {
    return (*&f.UDPAddr).String()
}
 
func (f *destFlag) Set(s string) error {
    if UDPAddr, err := net.ResolveUDPAddr("udp", s); err == nil {
        f.UDPAddr = *UDPAddr
        return nil
    } else {
        return fmt.Errorf("Not valid destination %q", s)
    }
}
 
func DestFlag(name string, dest, usage string) *net.UDPAddr {
    ParseAddr, _ := net.ResolveUDPAddr("udp", dest)
    f := destFlag{*ParseAddr}
    flag.CommandLine.Var(&f, name, usage)
    return &f.UDPAddr
}
 
var dest                 = DestFlag("dest", "127.0.0.1:60000", "Dest address")

i := 0
    var wg sync.WaitGroup
    gorutinesLimiter := make(chan struct{}, 5000)
 
    for currentData := range dataChan {
        fmt.Println(string(currentData))
        for repeat := 0; repeat < *repetitions; repeat++ {
 
            if i == packetCount {
                time.Sleep(timeSync * time.Millisecond)
                i = 0
            }
 
            wg.Add(1)
            gorutinesLimiter <- struct{}{}
            go func(data []byte) {
                defer wg.Done()
                if _, err := conn.Write(data); err != nil {
                    fmt.Fprintf(os.Stderr, "error: %v\n", err)
                }
                <-gorutinesLimiter
            }(currentData)
            i++
 
        }
    }
    wg.Wait()