INNER CODE UNIT · Go

txFunc

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

		txFunc := func(s *XDPPacket, id int) {
			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)

View source record →