INNER CODE UNIT · Go

isUnRecoverError

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

func isUnRecoverError(err error) bool {
	if err == ErrSocketClosed || err == ErrReadFunctionNil {
		log.Debugf("err is %v", err)
		return true
	}
	return false
}

func OneQueueRxTx(queueID int) {
	xp, err := NewXDPPacket(*Ifname, OptQueueCount(*queueCount), OptQueueID(queueID),
		actualXdpMode, actualIOMode, actualPollTimeOut, OptNumFrames(*FrameNum))
	if err != nil {
		log.Errorf("new xdp socket failed as %v", err)
		return
	}
	defer xp.Close()

	if *StatsInterval > 0 {

View source record →