1

我想使用“github.com/google/gopacket/pcap”在 4 个接口设备 eth0、eth1、eth2 和 eth3 上捕获数据包。我使用的机器流量很大。可以说它每分钟缺乏。我使用 goroutines 在每个设备上并行捕获数据包。

当我在 centOS 7 机器上运行我的二进制代码时，一段时间后（在 1 小时或更短时间后）出现以下错误之一。

1) 运行时：指针 0xc441198b80 指向未分配的 span idx=0x108cc span.base()=0xc441196000 span.limit=0xc441197ff0 span.state=3 致命错误：在 Go 堆中发现错误的指针（不正确使用 unsafe 或 cgo？）

2) 分段错误

3) 致命错误：systemstack 从意外的 goroutine Segmentation fault 调用

我如何使用 goroutines-

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
    }

请帮帮我。

4

0 回答 0