From patchwork Mon Jan 25 08:43:59 2021 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: "Yufen.Mo" X-Patchwork-Id: 87188 X-Patchwork-Delegate: lijuan.tu@intel.com Return-Path: X-Original-To: patchwork@inbox.dpdk.org Delivered-To: patchwork@inbox.dpdk.org Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id C7DACA0A0B; Mon, 25 Jan 2021 09:51:44 +0100 (CET) Received: from [217.70.189.124] (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id C2F62140E01; Mon, 25 Jan 2021 09:51:44 +0100 (CET) Received: from mga06.intel.com (mga06.intel.com [134.134.136.31]) by mails.dpdk.org (Postfix) with ESMTP id 93E9D140DDD for ; Mon, 25 Jan 2021 09:51:43 +0100 (CET) IronPort-SDR: USJArDnAFoBUO8+OsL2hQPmBiSQ8x1kaxw8CquTMBBEpYHueupUBWskTKnlgF3gyjx2E/fiCeW YAw5uDwLV+sw== X-IronPort-AV: E=McAfee;i="6000,8403,9874"; a="241224430" X-IronPort-AV: E=Sophos;i="5.79,373,1602572400"; d="scan'208";a="241224430" Received: from fmsmga001.fm.intel.com ([10.253.24.23]) by orsmga104.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384; 25 Jan 2021 00:51:43 -0800 IronPort-SDR: xJ4/cDTdCtoDkh9CqeGOns/clEzr/XCBS6ibm65MoO65jVcraMl7xgbr+Y6ZNZvMY6XN4mpHpS GtQrPcqaA8fg== X-ExtLoop1: 1 X-IronPort-AV: E=Sophos;i="5.79,373,1602572400"; d="scan'208";a="471978459" Received: from dpdk-moyufen06.sh.intel.com ([10.67.116.208]) by fmsmga001.fm.intel.com with ESMTP; 25 Jan 2021 00:51:41 -0800 From: yufengmx To: dts@dpdk.org, lijuan.tu@intel.com Cc: yufengmx Date: Mon, 25 Jan 2021 16:43:59 +0800 Message-Id: <20210125084414.8503-13-yufengx.mo@intel.com> X-Mailer: git-send-email 2.21.0 In-Reply-To: <20210125084414.8503-1-yufengx.mo@intel.com> References: <20210125084414.8503-1-yufengx.mo@intel.com> MIME-Version: 1.0 Subject: [dts] [PATCH V1 12/27] framework/pktgen: enable ixNetwork X-BeenThere: dts@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: test suite reviews and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dts-bounces@dpdk.org Sender: "dts" parse pcap file/scapy Packet layers content. Signed-off-by: yufengmx --- framework/ixia_network/packet_parser.py | 93 +++++++++++++++++++++++++ 1 file changed, 93 insertions(+) create mode 100644 framework/ixia_network/packet_parser.py diff --git a/framework/ixia_network/packet_parser.py b/framework/ixia_network/packet_parser.py new file mode 100644 index 00000000..6bb0e2f3 --- /dev/null +++ b/framework/ixia_network/packet_parser.py @@ -0,0 +1,93 @@ +# BSD LICENSE +# +# Copyright(c) 2010-2021 Intel Corporation. All rights reserved. +# All rights reserved. +# +# Redistribution and use in source and binary forms, with or without +# modification, are permitted provided that the following conditions +# are met: +# +# * Redistributions of source code must retain the above copyright +# notice, this list of conditions and the following disclaimer. +# * Redistributions in binary form must reproduce the above copyright +# notice, this list of conditions and the following disclaimer in +# the documentation and/or other materials provided with the +# distribution. +# * Neither the name of Intel Corporation nor the names of its +# contributors may be used to endorse or promote products derived +# from this software without specific prior written permission. +# +# THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS +# "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT +# LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR +# A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT +# OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, +# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT +# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, +# DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY +# THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT +# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE +# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. +import os +from collections import OrderedDict + +from scapy.all import conf +from scapy.packet import NoPayload +from scapy.packet import Packet as scapyPacket +from scapy.fields import ConditionalField +from scapy.utils import rdpcap + + +class PacketParser(object): + ''' parse packet full layers information ''' + + def __init__(self): + self.packetLayers = OrderedDict() + self.framesize = 64 + + def _parse_packet_layer(self, pkt_object): + ''' parse one packet every layers' fields and value ''' + if pkt_object is None: + return + + self.packetLayers[pkt_object.name] = OrderedDict() + for curfield in pkt_object.fields_desc: + if isinstance(curfield, ConditionalField) and \ + not curfield._evalcond(pkt_object): + continue + field_value = pkt_object.getfieldval(curfield.name) + if isinstance(field_value, scapyPacket) or (curfield.islist and + curfield.holds_packets and type(field_value) is list): + continue + repr_value = curfield.i2repr(pkt_object, field_value) + if isinstance(repr_value, str): + repr_value = repr_value.replace(os.linesep, + os.linesep + " " * (len(curfield.name) + 4)) + self.packetLayers[pkt_object.name][curfield.name] = repr_value + + if isinstance(pkt_object.payload, NoPayload): + return + else: + self._parse_packet_layer(pkt_object.payload) + + def _parse_pcap(self, pcapFile, number=0): + ''' parse one packet content ''' + self.packetLayers = OrderedDict() + pcap_pkts = [] + if isinstance(pcapFile, str): + if os.path.exists(pcapFile) is False: + warning = "{0} is not exist !".format(pcapFile) + raise Exception(warning) + pcap_pkts = rdpcap(pcapFile) + else: + pcap_pkts = pcapFile + # parse packets' every layers and fields + if len(pcap_pkts) == 0: + warning = "{0} is empty".format(pcapFile) + raise Exception(warning) + elif number >= len(pcap_pkts): + warning = "{0} is missing No.{1} packet".format(pcapFile, number) + raise Exception(warning) + else: + self._parse_packet_layer(pcap_pkts[number]) + self.framesize = len(pcap_pkts[number]) + 4