INNER CODE UNIT · Go

pkt

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

			pkt := GeneratePacket(*SrcMac, *DstMac, *SrcIp, *DstIp, id)

			count := GetPktCount(*PktCount)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				err := s.WritePacket(pkt)
				if err != nil {
					if isUnRecoverError(err) {
						break
					}
					log.Debugf("queue %v send packet failed as %v", id, err)
					continue
				}
			}
		}

		for idx, s := range xsks {
			log.Debugf("queue %v xdp socket %v", idx, s)
			go txFunc(s, idx)

View source record →