INNER CODE UNIT · Go

count

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

			count := GetPktCount(*PktCount)
			for i := 0; count == PKT_CNT_INFINITE || i < count; i++ {
				_, _, err := xp.ZeroCopyReadPacket()
				// pkt, ci, err := xp.ZeroCopyReadPacket()
				if err != nil {
					if isUnRecoverError(err) {
						break
					}
					log.Debug("zero read failed as", err)
					continue
				}
				// 测试准确性时方可打开，因其影响性能
				// log.Debugf("ci:%#vpacket:%v", ci, DumpPacket(pkt))
			}
		}()
	} else if *rx == 1 {
		go func() {
			pkt := GeneratePacket(*SrcMac, *DstMac, *SrcIp, *DstIp, 0)

View source record →