Ошибка во время выполнения, когда я использую goroutines для захвата пакетов от устройства с несколькими интерфейсами, используя "github.com/google/gopacket/pcap"

Я хочу перехватывать пакеты на 4 интерфейсных устройствах eth0, eth1, eth2 и eth3, используя "github.com/google/gopacket/pcap" . У машины, которую я использую, большое количество трафика. Допустим, это нехватка в минуту. Я использовал goroutines для параллельного захвата пакетов на каждом устройстве.

Через некоторое время (через 1 час или более) я получаю одну из следующих ошибок, когда запускаю свой двоичный код на машине с CentOS 7.

1) время выполнения: указатель 0xc441198b80 на нераспределенный диапазон idx=0x108cc span.base()=0xc441196000 span.limit=0xc441197ff0 span.state=3 фатальная ошибка: обнаружен неверный указатель в куче Go (неправильное использование unsafe или cgo?)

2) Ошибка сегментации

3) фатальная ошибка: системный стек вызван из-за непредвиденной ошибки сегментации

Как я использую горутины?

func main(){
             done = make(chan bool)
             var status bool = true
             for _, interface_device := range util.ConfigDetails.InterfaceDeviceList{
                   go func(device string) {           
                       status = CapturePackets(device)
                       fmt.Println("status is", status)
                       done <- true
                }(interface_device)
              }
             // wait for all goroutines to complete before exiting
               for _ = range util.ConfigDetails.InterfaceDeviceList {
                 <-done
               }

    }

    func CapturePackets(device string) bool {

       handle, err = pcap.OpenLive(device, snapshot_len, promiscuous, pcap.BlockForever)
        if err != nil {
            util.Log.Errorf("%v",err)
        }

        defer handle.Close()

        packetSource := gopacket.NewPacketSource(handle, handle.LinkType())
        parser := gopacket.NewDecodingLayerParser(
                layers.LayerTypeEthernet,
                &ethLayer,
                &ipLayer,
                &ip6Layer,
                &tcpLayer,
                &udpLayer,
                &payload,
            )
    for packet := range packetSource.Packets() {
     foundLayerTypes := []gopacket.LayerType{}
     var ip_source,ip_dest net.IP

            for _, layerType := range foundLayerTypes {

                if layerType == layers.LayerTypeIPv4 {
                    ip_source = ipLayer.SrcIP
                    ip_dest = ipLayer.DstIP
                }

                if layerType == layers.LayerTypeIPv6 {
                    ip_source = ip6Layer.SrcIP
                    ip_dest = ip6Layer.DstIP
                }
          fmt.Println(ip_source)
          fmt.Println(ip_dest)
      }
    }
 return true
    }

Пожалуйста, помогите мне.

0 ответов

Другие вопросы по тегам