INNER CODE UNIT · Go

pkt

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

			pkt := GeneratePacket(*SrcMac, *DstMac, *SrcIp, *DstIp, 0)
			count := GetPktCount(*PktCount)
			length := len(pkt)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				err = afPacket.WritePacketData(pkt)
				if err != nil {
					fmt.Printf("afpacket send packet failed as %v\n", err)
					time.Sleep(time.Second)
					continue
				}
				pkts += 1
				bytes += uint64(length)
			}
		}()
	}
}

func main() {

View source record →