diff options
author | ahothan <ahothan@cisco.com> | 2017-07-28 17:08:46 -0700 |
---|---|---|
committer | ahothan <ahothan@cisco.com> | 2017-07-31 12:34:00 -0700 |
commit | 04a7de082bd221eae3c7004f4e0b99dfa4f8be91 (patch) | |
tree | c9fb7beaedc80479772ba24c3b47c85d49c22f76 /nfvbench/packet_analyzer.py | |
parent | b8f02ed4e72399840a93aceb02b8c53831bbe68a (diff) |
Initial code drop from Cisco1.0.0
Change-Id: Ie2993886dc8e95c5f73ccdb871add8b96ffcc849
Signed-off-by: ahothan <ahothan@cisco.com>
Diffstat (limited to 'nfvbench/packet_analyzer.py')
-rw-r--r-- | nfvbench/packet_analyzer.py | 64 |
1 files changed, 64 insertions, 0 deletions
diff --git a/nfvbench/packet_analyzer.py b/nfvbench/packet_analyzer.py new file mode 100644 index 0000000..c01675b --- /dev/null +++ b/nfvbench/packet_analyzer.py @@ -0,0 +1,64 @@ +#!/usr/bin/env python +# Copyright 2016 Cisco Systems, Inc. All rights reserved. +# +# Licensed under the Apache License, Version 2.0 (the "License"); you may +# not use this file except in compliance with the License. You may obtain +# a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT +# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the +# License for the specific language governing permissions and limitations +# under the License. +# + +from collections import OrderedDict +from log import LOG + + +class PacketAnalyzer(object): + """Analyze packet drop counter in a chain""" + + def __init__(self): + self.last_packet_count = 0 + self.chain = [] + + def record(self, interface, traffic_type): + """Records the counter of the next interface with the corresponding traffic type""" + if interface.is_no_op(): + return + packet_count = interface.get_packet_count(traffic_type) + packet_drop_count = self.last_packet_count - packet_count + path_data = OrderedDict() + path_data['interface'] = interface.name + path_data['device'] = interface.device + path_data['packet_count'] = packet_count + + if self.chain: + path_data['packet_drop_count'] = packet_drop_count + + self.chain.append(path_data) + self.last_packet_count = packet_count + + def get_analysis(self): + """Gets the analysis of packet drops""" + transmitted_packets = self.chain[0]['packet_count'] + + for (index, path_data) in enumerate(self.chain): + LOG.info('[Packet Analyze] Interface: %s' % (path_data['interface'])) + LOG.info('[Packet Analyze] > Count: %d' % (path_data['packet_count'])) + + if index: + if transmitted_packets: + self.chain[index]['packet_drop_percentage'] = \ + 100.0 * path_data['packet_drop_count'] / transmitted_packets + else: + self.chain[index]['packet_drop_percentage'] = float('nan') + LOG.info('[Packet Analyze] > Packet Drops: %d' % + (path_data['packet_drop_count'])) + LOG.info('[Packet Analyze] > Percentage: %s' % + (path_data['packet_drop_percentage'])) + + return self.chain |