INNER CODE UNIT · Go

len

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

				if n < len(pkts) {
					log.Debugf("only send %v packets, actual %v packets", n, len(pkts))
				}
			}
		}()
	}

	xp.ClearEbpfProg()
}

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

View source record →