INNER CODE UNIT · Go

AfPacketRxTx

deepflowio/deepflow · server/libs/xdppacket/cmd/afpacket/main.go:55

func AfPacketRxTx() {
	var pkts, bytes uint64

	afPacket, err := afpacket.NewTPacket(
		afpacket.OptPollTimeout(POLL_TIMEOUT),
		afpacket.OptBlockSize(DEFAULT_BLOCK_SIZE),
		afpacket.OptFrameSize(DEFAULT_FRAME_SIZE),
		afpacket.OptNumBlocks(DEFULT_AFPACKET_BLOCKS),
		afpacket.OptInterface(*Ifname),
	)
	if err != nil {
		log.Error("AF_PACKET init error", err)
		os.Exit(1)
	}

	if *StatsInterval > 0 {
		go func() {
			var oldPkts, oldBytes, nowPkts, nowBytes uint64

View source record →