INNER CODE UNIT · Go

count

deepflowio/deepflow · server/libs/xdppacket/cmd/afpacket/main.go:95

			count := GetPktCount(*PktCount)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				_, ci, err = afPacket.ZeroCopyReadPacketData()
				if err != nil {
					fmt.Println("========afPacket zero read failed as", err)
					time.Sleep(time.Second)
					continue
				}
				pkts += 1
				bytes += uint64(ci.Length)
			}
		}()
	} else if *direction == DIR_TX {
		go func() {
			pkt := GeneratePacket(*SrcMac, *DstMac, *SrcIp, *DstIp, 0)
			count := GetPktCount(*PktCount)
			length := len(pkt)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {

View source record →