INNER CODE UNIT · Go

POLL_TIMEOUT

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

	POLL_TIMEOUT           = 100 * time.Millisecond
	DIR_RX                 = 0
	DIR_TX                 = 1
)

var log = logging.MustGetLogger(os.Args[0])

var direction = flag.Int("r", 0, "Specify receive or send, "+
	"af_packet rx:0, af_packet tx:1")

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),

View source record →