INNER CODE UNIT · Go

_

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

			for _ = range time.NewTicker(time.Duration(*StatsInterval) * time.Second).C {
				if xp.CheckIfXDPSocketClosed() {
					break
				}
				fmt.Println(stats.Minus(oldStats))
				oldStats, stats = stats, xp.GetStats()
			}
		}()
	}

	if *rx == 0 {
		go func() {
			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) {

View source record →