INNER CODE UNIT · Go

pkt

deepflowio/deepflow · server/libs/xdppacket/cmd/xdp/main.go:133

			pkt := GeneratePacket(*SrcMac, *DstMac, *SrcIp, *DstIp, 0)
			count := GetPktCount(*PktCount)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				err = xp.WritePacket(pkt)
				if err != nil {
					if isUnRecoverError(err) {
						break
					}
					log.Debugf("send packet failed as %v", err)
					continue
				}
			}
		}()
	} else if *rx == 2 {
		go func() {
			count := GetPktCount(*PktCount)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				_, _, err = xp.ZeroCopyReadMultiPackets()

View source record →