INNER CODE UNIT · Go

pkt

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

			pkt := GeneratePacket(*SrcMac, *DstMac, *SrcIp, *DstIp, i)
			pkts = append(pkts, pkt)
		}
		go func() {
			count := GetPktCount(*PktCount)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				n, err := xp.WritePacket(pkts)
				if err != nil {
					if isUnRecoverError(err) {
						break
					}
					log.Debugf("multi queue send packet failed as %v", err)
					continue
				}
				if n < len(pkts) {
					log.Debugf("multi queue only send %v packets", n)
				}
			}

View source record →