diff --git a/xos/api/tenant/monitoring/dashboard/ceilometerdashboard.py b/xos/api/tenant/monitoring/dashboard/ceilometerdashboard.py
index 2a3b1ba..bf8bef1 100644
--- a/xos/api/tenant/monitoring/dashboard/ceilometerdashboard.py
+++ b/xos/api/tenant/monitoring/dashboard/ceilometerdashboard.py
@@ -67,7 +67,7 @@
     if not slice:
         #TEMPORARY WORK AROUND: There are some resource in network like whitebox switches does not belong to a specific tenant.
         #They are all associated with "default_admin_tenant" tenant
-        tenantmap["default_admin_tenant"] = {"slice": "default_admin_tenant", "service": "Other"}
+        tenantmap["default_admin_tenant"] = {"slice": "default_admin_tenant", "service": "NetworkInfra"}
     return tenantmap
 
 def build_url(path, q, params=None):
diff --git a/xos/synchronizer/ceilometer/broadview_collector_plugin/README b/xos/synchronizer/ceilometer/broadview_collector_plugin/README
new file mode 100644
index 0000000..7630819
--- /dev/null
+++ b/xos/synchronizer/ceilometer/broadview_collector_plugin/README
@@ -0,0 +1,41 @@
+1. Install broadview-lib:
+
+$ git clone https://github.com/openstack/broadview-lib.git 
+$ cd broadview-lib 
+$ sudo python setup.py install
+
+2. Install broadview-collector
+
+$ git clone https://github.com/openstack/broadview-collector.git 
+$ cd broadview-collector 
+$ sudo python setup.py install
+
+3. Copy the file ~/xos_services/monitoring/xos/synchronizer/ceilometer/broadview_collector_plugin/broadviewcollector.conf to /etc
+
+$ sudo cp ~/xos_services/monitoring/xos/synchronizer/ceilometer/broadview_collector_plugin/broadviewcollector.conf /etc
+
+4. Edit /etc/broadviewcollector.conf as needed
+
+$ sudo vi /etc/broadviewcollector.conf
+— Change the ip_address
+— Change the publishers to ceilometerpublisher
+— Change rabbit_host, rabbit_user, rabbit_password
+
+5. Copy broadview collector application to /usr/local/bin:
+
+$ sudo cp broadview_collector/bin/bvcollect.py /usr/local/bin 
+$ sudo chmod 755 /usr/local/bin/bvcollect.py
+
+6. Copy the ~/xos_services/monitoring/xos/synchronizer/ceilometer/broadview_collector_plugin/plugins/ceilometerpublisher.py to /usr/local/lib/python2.7/dist-packages/broadview_collector/plugins/
+
+$ sudo cp ~/xos_services/monitoring/xos/synchronizer/ceilometer/broadview_collector_plugin/plugins/ceilometerpublisher.py /usr/local/lib/python2.7/dist-packages/broadview_collector/plugins/
+
+7. Copy the ~/xos_services/monitoring/xos/synchronizer/ceilometer/broadview_collector_plugin/serializers/bst_to_ceilometer.py to /usr/local/lib/python2.7/dist-packages/broadview_collector/serializers/
+
+$ sudo cp ~/xos_services/monitoring/xos/synchronizer/ceilometer/broadview_collector_plugin/serializers/bst_to_ceilometer.py /usr/local/lib/python2.7/dist-packages/broadview_collector/serializers/
+
+8. Start the collector (assuming /usr/local/bin is in your PATH):
+
+$ sudo mkdir -p /var/log/broadview-collector/
+$ sudo bvcollect.py &
+
diff --git a/xos/synchronizer/ceilometer/broadview_collector_plugin/broadviewcollector.conf b/xos/synchronizer/ceilometer/broadview_collector_plugin/broadviewcollector.conf
index 68fe151..35d8913 100644
--- a/xos/synchronizer/ceilometer/broadview_collector_plugin/broadviewcollector.conf
+++ b/xos/synchronizer/ceilometer/broadview_collector_plugin/broadviewcollector.conf
@@ -15,13 +15,13 @@
 # uncomment for monasca API
 
 #publishers: logpublisher, monascapublisher
-publishers: logpublisher
+publishers: ceilometerpublisher
 
 #searchpath: tmp
 
 # handlers map to broadview components, e.g., bst, packet trace
 
-handlers: bsthandler
+handlers: bsthandler, pthandler
 
 [logging]
 
diff --git a/xos/synchronizer/ceilometer/broadview_collector_plugin/plot.py b/xos/synchronizer/ceilometer/broadview_collector_plugin/plot.py
new file mode 100644
index 0000000..b496dba
--- /dev/null
+++ b/xos/synchronizer/ceilometer/broadview_collector_plugin/plot.py
@@ -0,0 +1,81 @@
+import plotly.plotly as py
+import plotly.graph_objs as go
+import time
+import requests
+#import ceilometerapi
+import ast
+
+PLOTLY_USERNAME = 'myusername'
+PLOTLY_API_KEY = 'myapikey'
+XOS_IP = '1.2.3.4'
+XOS_PORT = '9999'
+
+class LAGPlot():
+	def __init__(self):
+		# use my personal account, need an API key
+		py.sign_in(PLOTLY_USERNAME, PLOTLY_API_KEY)
+		self.data = {} # all the metrics we read
+                self.ceilometer_url = 'http://%s:%s/api/tenant/monitoring/dashboard/metersamples/' % (XOS_IP, XOS_PORT)
+
+	def getDataFromCeilometer(self):
+		''' 
+		keep track of how many times a lag member resolves
+		read new metrics from ceilometer (use timestamps to read
+                                                  a range so we get new
+                                                  data since last read)
+                '''
+                url = "%s?%s" % (self.ceilometer_url,"no_hyperlinks=1&meter=broadview.pt.packet-trace-lag-resolution")
+                try:
+                    response = requests.get(url, auth=('padmin@vicci.org','letmein'))
+                except requests.exceptions.RequestException as e:
+                    raise e
+                samples = response.json()
+                #print samples
+		for lagresolution in samples:
+		    for lagmember in ast.literal_eval(lagresolution['metadata']['lag-members']):
+			# here we add any new lagmembers to the hash
+			if not lagmember in self.data:
+			    self.data[lagmember] = 0
+		    lagresolve = lagresolution['metadata']['dst-lag-member']
+		    self.data[lagresolve] = self.data[lagresolve] + 1
+		
+		# now that we have added any new ceilometer data update the
+                # pie chart and write it out
+                print self.data
+	
+		data = []
+		tmp = {}
+		tmp["labels"] = []
+		tmp["values"] = []
+		tmp["type"] = "pie"
+		for  key, val in self.data.iteritems():
+                	tmp["labels"].append(key) # the lag member ID
+			tmp["values"].append(val) # count
+		data.append(tmp)
+		fig = {}
+		fig["data"] = data
+    		fig["layout"] = {}
+		# put whatever metadata that makes sense, if any
+		fig["layout"]["title"] = 'BroadView LAG Resolution'
+                print fig
+		return fig
+		
+	def plotPieToFile(self, data, filename="pie.png"):
+		# takes data in the following format and writes it to file
+		if not data:
+			data = {
+    				'data': [{'labels': ['LAG001', 'LAG002', 'LAG003'],
+              		         	'values': [19, 26, 55],
+              		         	'type': 'pie'}],
+    				'layout': {'title': 'BroadView LAG Resolution metadata...'}
+     			}
+
+		py.image.save_as(data, filename=filename)
+
+if __name__ == "__main__":
+	x = LAGPlot()
+	while True:
+           print "Plotting data"
+	   data = x.getDataFromCeilometer()
+	   x.plotPieToFile(data)
+	   time.sleep(30)	
diff --git a/xos/synchronizer/ceilometer/broadview_collector_plugin/plugins/ceilometerpublisher.py b/xos/synchronizer/ceilometer/broadview_collector_plugin/plugins/ceilometerpublisher.py
index 1ee346c..2690258 100644
--- a/xos/synchronizer/ceilometer/broadview_collector_plugin/plugins/ceilometerpublisher.py
+++ b/xos/synchronizer/ceilometer/broadview_collector_plugin/plugins/ceilometerpublisher.py
@@ -19,6 +19,7 @@
 import uuid
 import datetime
 from broadview_collector.serializers.bst_to_ceilometer import BSTToCeilometer
+from broadview_collector.serializers.pt_to_ceilometer import PTToCeilometer
 import json
 import ConfigParser
 import sys
@@ -75,9 +76,9 @@
             code = 200
         if self.isBST(data):
             success, sdata = BSTToCeilometer().serialize(host, data)
-        #elif self.isPT(data):
-        #    self._topic = "broadview-pt"
-        #    success, sdata = PTToMonasca().serialize(host, data)
+        elif self.isPT(data):
+            self._topic = "broadview-pt"
+            success, sdata = PTToCeilometer().serialize(host, data)
         else:
             success = False
         if success:
diff --git a/xos/synchronizer/ceilometer/broadview_collector_plugin/serializers/pt_to_ceilometer.py b/xos/synchronizer/ceilometer/broadview_collector_plugin/serializers/pt_to_ceilometer.py
new file mode 100644
index 0000000..0539a7c
--- /dev/null
+++ b/xos/synchronizer/ceilometer/broadview_collector_plugin/serializers/pt_to_ceilometer.py
@@ -0,0 +1,1055 @@
+# (C) Copyright Broadcom Corporation 2016
+#
+# 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 broadviewserializerbase import BroadViewSerializerBase
+from broadview_lib.pt.pt_parser import PTParser, ReportTypes
+import json
+import six
+import uuid
+import unittest
+import datetime
+import time
+
+
+class PTToCeilometer(BroadViewSerializerBase):
+    '''
+    Class that converts Packet Trace object model to OpenStack Ceilometer metrics.
+    See broadview-collector/doc/pt_to_monasca_serializer.md for documentation
+    '''
+
+    def __init__(self):
+        pass
+
+    def __serializeToJSON(self, host, data):
+        ret = []
+        #try:
+        #    timestamp = time.mktime(data.getTimestamp()) * 1000
+        #except:
+        #    timestamp = int(time.mktime(datetime.datetime.utcnow().timetuple())) \
+        #                * 1000 * 1000
+        timestamp=time.strftime('%Y-%m-%dT%H:%M:%SZ',data.getTimestamp())
+        asic = data.getASICId()
+
+        '''
+        Note that monasca requires a value field. Where required, but not
+        obvious value is present in the data, we use 0 and notate that the
+        value is to be ignored in the metadata
+        '''
+
+        d = data.getPacketTraceProfile()
+        for x in d:
+            for y in x:
+                m = {}
+                m["event_type"] = "broadview.pt." + repr(x)
+                m["timestamp"] = timestamp
+                m['message_id'] = six.text_type(uuid.uuid4())
+                m['priority'] = 'INFO'
+                m["payload"] = {}
+                m["payload"]["value"] = 0
+                m["payload"]["asic-id"] = asic
+                m["payload"]["bv-agent"] = host
+                m["payload"]["realm"] = y.getRealm()
+                m["payload"]["port"] = y.getPort()
+                r = y.getLAGLinkResolution()
+                if r:
+                    m["payload"]["lag-id"] = r.getLAGID()
+                    m["payload"]["dst-lag-member"] = r.getDstLAGMember()
+                    m["payload"]["lag-members"] = r.getLAGMembers()
+                    m["payload"]["fabric-trunk-members"] = r.getFabricTrunkMembers()
+                    m["payload"]["fabric-trunk-id"] = r.getFabricTrunkID()
+                    m["payload"]["ignore-value"] = 1
+                    ret.append(m)
+                else:
+                    r = y.getECMPLinkResolution()
+                    for l in r:
+                        m = {}
+                        m["event_type"] = "broadview.pt." + repr(x)
+                        m["timestamp"] = timestamp
+                        m['message_id'] = six.text_type(uuid.uuid4())
+                        m['priority'] = 'INFO'
+                        m["payload"] = {}
+                        m["payload"]["value"] = 0
+                        m["payload"]["ignore-value"] = 1
+                        m["payload"]["asic-id"] = asic
+                        m["payload"]["bv-agent"] = host
+                        m["payload"]["realm"] = y.getRealm()
+                        m["payload"]["port"] = y.getPort()
+                        m["payload"]["ecmp-group-id"] = l.getECMPGroupID()
+                        m["payload"]["ecmp-dst-member"] = l.getECMPDstMember()
+                        m["payload"]["ecmp-dst-port"] = l.getECMPDstPort()
+                        m["payload"]["ecmp-next-hop-ip"] = l.getECMPNextHopIP()
+                        m["payload"]["ecmp-members"] = []
+                        for mem in l.getECMPMembers():
+                            member = {}
+                            member["id"] = mem.getId()
+                            member["ip"] = mem.getIP()
+                            member["port"] = mem.getPort()
+                            m["payload"]["ecmp-members"].append(member)
+                        ret.append(m)
+
+        d = data.getPacketTraceECMPResolution()
+        for x in d:
+            r = x.getECMPLinkResolution()
+            for l in r:
+                m = {}
+                m["event_type"] = "broadview.pt." + repr(x)
+                m["timestamp"] = timestamp
+                m['message_id'] = six.text_type(uuid.uuid4())
+                m['priority'] = 'INFO'
+                m["payload"] = {}
+                m["payload"]["value"] = 0
+                m["payload"]["ignore-value"] = 1
+                m["payload"]["asic-id"] = asic
+                m["payload"]["bv-agent"] = host
+                m["payload"]["port"] = x.getPort()
+                m["payload"]["ecmp-group-id"] = l.getECMPGroupID()
+                m["payload"]["ecmp-dst-member"] = l.getECMPDstMember()
+                m["payload"]["ecmp-dst-port"] = l.getECMPDstPort()
+                m["payload"]["ecmp-next-hop-ip"] = l.getECMPNextHopIP()
+                m["payload"]["ecmp-members"] = []
+                for mem in l.getECMPMembers():
+                    member = {}
+                    member["id"] = mem.getId()
+                    member["ip"] = mem.getIP()
+                    member["port"] = mem.getPort()
+                    m["payload"]["ecmp-members"].append(member)
+                ret.append(m)
+            
+        d = data.getPacketTraceLAGResolution()
+        for x in d:
+            ll = x.getLAGLinkResolution()
+            m = {}
+            m["event_type"] = "broadview.pt." + repr(x)
+            m["timestamp"] = timestamp
+            m['message_id'] = six.text_type(uuid.uuid4())
+            m['priority'] = 'INFO'
+            m["payload"] = {}
+            m["payload"]["asic-id"] = asic
+            m["payload"]["bv-agent"] = host
+            m["payload"]["port"] = x.getPort()
+            m["payload"]["lag-id"] = ll.getLAGID()
+            m["payload"]["dst-lag-member"] = ll.getDstLAGMember()
+            m["payload"]["lag-members"] = ll.getLAGMembers()
+            m["payload"]["fabric-trunk-members"] = ll.getFabricTrunkMembers()
+            m["payload"]["fabric-trunk-id"] = ll.getFabricTrunkID()
+            m["payload"]["ignore-value"] = 1
+            m["payload"]["value"] = 0
+            ret.append(m)
+            
+        d = data.getPacketTraceDropReason()
+        for x in d:
+            m = {}
+            m["event_type"] = "broadview.pt." + repr(x)
+            m["timestamp"] = timestamp
+            m['message_id'] = six.text_type(uuid.uuid4())
+            m['priority'] = 'INFO'
+            m["payload"] = {}
+            m["payload"]["asic-id"] = asic
+            m["payload"]["bv-agent"] = host
+            m["payload"]["reason"] = x.getReason()
+            m["payload"]["port-list"] = x.getPortList()
+            m["payload"]["send-dropped-packet"] = x.getSendDroppedPacket()
+            m["payload"]["trace-profile"] = x.getTraceProfile()
+            m["payload"]["packet-threshold"] = x.getPacketThreshold()
+            m["payload"]["ignore-value"] = 0
+            m["payload"]["value"] = x.getPacketCount()
+            ret.append(m)
+            
+        d = data.getPacketTraceDropCounterReport()
+        for x in d:
+            for y in x:
+                m = {}
+                m["event_type"] = "broadview.pt." + repr(x)
+                m["timestamp"] = timestamp
+                m['message_id'] = six.text_type(uuid.uuid4())
+                m['priority'] = 'INFO'
+                m["payload"] = {}
+                m["payload"]["asic-id"] = asic
+                m["payload"]["bv-agent"] = host
+                m["payload"]["realm"] = y.getRealm()
+                m["payload"]["port"] = y.getPort()
+                m["payload"]["value"] = y.getCount()
+                m["payload"]["ignore-value"] = 0
+                ret.append(m)
+
+        d = data.getPacketTraceSupportedDropReasons()
+        if d:
+            m = {}
+            m["event_type"] = "broadview.pt." + repr(x)
+            m["timestamp"] = timestamp
+            m['message_id'] = six.text_type(uuid.uuid4())
+            m['priority'] = 'INFO'
+            m["payload"] = {}
+            m["payload"]["asic-id"] = asic
+            m["payload"]["bv-agent"] = host
+            m["payload"]["reasons"] = d.getReasons()
+            m["payload"]["ignore-value"] = 1
+            m["payload"]["value"] = 0
+            ret.append(m)
+
+        return json.dumps(ret)
+
+    def serialize(self, host, data):
+        # serialize a parsed BST report to Monasca metrics
+        ret = (False, None)
+
+        s = self.__serializeToJSON(host, data)
+
+        if s:
+            ret = (True, s)
+
+        return ret
+
+    def __repr__(self):
+        return "Packet Trace To Monasca Serializer" 
+
+class TestSerializer(unittest.TestCase):
+
+    def setUp(self):
+        self._host = "127.0.0.1"
+        self.packet_trace_profile_1 = {
+            "jsonrpc": "2.0",
+            "method": "get-packet-trace-profile",
+            "asic-id": "1",
+            "version": "1",
+            "time-stamp": "2014-11-18 - 00:15:04 ",
+            "report": [
+                {
+                    "port": "1",
+                    "trace-profile": [
+                        {
+                            "realm": "lag-link-resolution",
+                            "data": {
+                                "lag-id": "2",
+                                "lag-members": ["1", "2", "3", "4"],
+                                "dst-lag-member": "4",
+                                "fabric-trunk-id": "6",
+                                "fabric-trunk-members": ["27", "28", "29"],
+                            }
+                        },
+                        {
+                            "realm": "ecmp-link-resolution",
+                            "data": 
+                            [
+                                {
+                                    "ecmp-group-id": "100256",
+                                    "ecmp-members": [["100004", "1.2.2.2", "18"],["100005", "1.6.6.1", "11"]],
+                                    "ecmp-dst-member": "100005",
+                                    "ecmp-dst-port": "11",
+                                    "ecmp-next-hop-ip": "1.6.6.2"
+                                },
+                                {
+                                    "ecmp-group-id": "200100",
+                                    "ecmp-members": [["200001", "2.3.3.1", "21"], ["200002", "2.7.7.2", "21"]],
+                                    "ecmp-dst-member": "200001",
+                                    "ecmp-dst-port": "21",
+                                    "ecmp-next-hop-ip": "2.3.3.2"
+                                }
+                            ]
+                        }
+                    ]
+                },
+                {
+                    "port": "2",
+                    "trace-profile": [
+                        {
+                            "realm": "lag-link-resolution",
+                            "data": {
+                                "lag-id": "2",
+                                "lag-members": ["5", "6", "7", "8"],
+                                "dst-lag-member": "5",
+                                "fabric-trunk-id": "7",
+                                "fabric-trunk-members": ["37", "38", "39"],
+                            }
+                        },
+                        {
+                            "realm": "ecmp-link-resolution",
+                            "data": 
+                            [
+                                {
+                                    "ecmp-group-id": "300256",
+                                    "ecmp-members": [["300004", "3.2.2.2", "38"],["300005", "3.6.6.1", "31"]],
+                                    "ecmp-dst-member": "300005",
+                                    "ecmp-dst-port": "31",
+                                    "ecmp-next-hop-ip": "3.6.6.2"
+                                },
+                                {
+                                    "ecmp-group-id": "400100",
+                                    "ecmp-members": [["400001", "4.3.3.1", "48"], ["400002", "4.7.7.2", "41"]],
+                                    "ecmp-dst-member": "400001",
+                                    "ecmp-dst-port": "41",
+                                    "ecmp-next-hop-ip": "4.3.3.2"
+                                }
+                            ]
+                        }
+                    ]
+                } 
+            ],
+            "id": 1
+        }
+        self.packet_trace_lag_resolution_1 = {
+            "jsonrpc": "2.0",
+            "method": " get-packet-trace-lag-resolution",
+            "asic-id": "1",
+            "version": "1",
+            "time-stamp": "2014-11-18 - 00:15:04 ",
+            "report": [
+                {
+                    "port": "1",
+                    "lag-link-resolution": {
+                        "lag-id": "1",
+                        "lag-members": [
+                            "1",
+                            "2",
+                            "3",
+                            "4"
+                        ],
+                        "dst-lag-member": "4",
+                        "fabric-trunk-id": "8",
+                        "fabric-trunk-members": ["47", "48", "49"],
+                    }
+                },
+                {
+                    "port": "2",
+                    "lag-link-resolution": {
+                        "lag-id": "2",
+                        "lag-members": [
+                            "5",
+                            "6",
+                            "7",
+                            "8"
+                        ],
+                        "dst-lag-member": "7",
+                        "fabric-trunk-id": "9",
+                        "fabric-trunk-members": ["57", "58", "59"],
+                    }
+                }
+            ],
+            "id": 1
+        }
+
+        self.packet_trace_ecmp_resolution_1 = {
+            "jsonrpc": "2.0",
+            "method": " get-packet-trace-ecmp-resolution",
+            "asic-id": "1",
+            "version": "1",
+            "time-stamp": "2014-11-18 - 00:15:04 ",
+            "report": [
+                {
+                    "port": "1",
+                    "ecmp-link-resolution": [
+                        {
+                            "ecmp-group-id": "100256",
+                            "ecmp-members": [["100004", "1.2.2.2", "18"],["100005", "1.6.6.1", "11"]],
+                            "ecmp-dst-member": "100005",
+                            "ecmp-dst-port": "11",
+                            "ecmp-next-hop-ip": "1.6.6.2"
+                        },
+                        {
+                            "ecmp-group-id": "200100",
+                            "ecmp-members": [["200001", "2.3.3.1", "21"], ["200002", "2.7.7.2", "21"]],
+                            "ecmp-dst-member": "200001",
+                            "ecmp-dst-port": "21",
+                            "ecmp-next-hop-ip": "2.3.3.2"
+                        }
+                    ]
+                },
+                {
+                    "port": "2",
+                    "ecmp-link-resolution": [
+                        {
+                            "ecmp-group-id": "300100",
+                            "ecmp-members": [["300001", "3.3.3.1", "38"],["300002", "3.7.7.2", "31"]],
+                            "ecmp-dst-member": "300005",
+                            "ecmp-dst-port": "31",
+                            "ecmp-next-hop-ip": "3.6.6.2"
+                        },
+                        {
+                            "ecmp-group-id": "400100",
+                            "ecmp-members": [["400001", "4.3.3.1", "48"], ["400002", "4.7.7.2", "41"]],
+                            "ecmp-dst-member": "400001",
+                            "ecmp-dst-port": "41",
+                            "ecmp-next-hop-ip": "4.3.3.2"
+                        }
+                    ]
+                }
+            ],
+            "id": 1
+        }
+
+        self.packet_trace_drop_reason_1 = {
+            "jsonrpc": "2.0",
+            "method": "get-packet-trace-drop-reason",
+            "asic-id": "1",
+            "version": "1",
+            "result": [
+                {
+                    "reason": "l2-lookup-failure",
+                    "port-list": [
+                        "1",
+                        "5",
+                        "6",
+                        "10-15"
+                    ],
+                    "send-dropped-packet": 0,
+                    "trace-profile": 0,
+                    "packet-count": 4,
+                    "packet-threshold": 0
+                },
+                {
+                    "reason": "vlan-mismatch",
+                    "port-list": [
+                        "11",
+                        "15",
+                        "16",
+                        "20-25"
+                    ],
+                    "send-dropped-packet": 1,
+                    "trace-profile": 1,
+                    "packet-count": 3,
+                    "packet-threshold": 10
+                }
+            ],
+            "id": 1
+        }
+
+        self.packet_trace_drop_counter_report_1 = {
+            "jsonrpc": "2.0",
+            "method": " get-packet-trace-drop-counter-report",
+            "asic-id": "1",
+            "version": "1",
+            "report": [
+                {
+                    "realm": "vlan-xlate-miss-drop",
+                    "data": [
+                        {
+                            "port": "1",
+                            "count": 10
+                        },
+                        {
+                            "port": "5",
+                            "count": 20
+                        },
+                        {
+                            "port": "6",
+                            "count": 30
+                        },
+                        {
+                            "port": "10",
+                            "count": 40
+                        },
+                        {
+                            "port": "11",
+                            "count": 50
+                        },
+                        {
+                            "port": "12",
+                            "count": 60
+                        }
+                    ]
+                },
+                {
+                    "realm": "bpdu-drop",
+                    "data": [
+                        {
+                            "port": "1",
+                            "count": 70
+                        },
+                        {
+                            "port": "5",
+                            "count": 20
+                        },
+                        {
+                            "port": "6",
+                            "count": 30
+                        },
+                        {
+                            "port": "10",
+                            "count": 40
+                        },
+                        {
+                            "port": "11",
+                            "count": 80
+                        },
+                        {
+                            "port": "12",
+                            "count": 90
+                        }
+                    ]
+                },
+                {
+                    "realm": "trill-slowpath-drop",
+                    "data": [
+                        {
+                            "port": "1",
+                            "count": 10
+                        },
+                        {
+                            "port": "5",
+                            "count": 20
+                        },
+                        {
+                            "port": "6",
+                            "count": 30
+                        },
+                        {
+                            "port": "10",
+                            "count": 40
+                        },
+                        {
+                            "port": "11",
+                            "count": 50
+                        },
+                        {
+                            "port": "12",
+                            "count": 60
+                        }
+                    ]
+                }
+            ]
+        }
+
+        self.packet_trace_supported_drop_reasons_1 = {
+            "jsonrpc": "2.0",
+            "method": "get-packet-trace-supported-drop-reasons",
+            "asic-id": "1",
+            "version": "1",
+            "result": [
+                "l2-lookup-failure",
+                "vlan-mismatch"
+            ],
+            "id": 1
+        }
+
+    def test_packet_trace_profile_1(self):
+        rep = PTParser()
+        rep.process(self.packet_trace_profile_1)
+        serializer = PTToMonasca()
+        ret = serializer.serialize(self._host, rep)
+        self.assertEqual(ret[0], True)
+        data = json.loads(ret[1])
+        self.assertTrue(len(data) == 6)
+
+        self.assertTrue("timestamp" in data[0])
+        timestamp = int(data[0]["timestamp"]) / 1000
+        self.assertTrue("name" in data[0])
+        self.assertTrue("payload" in data[0])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_profile_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        self.assertEqual(data[0]["name"], "broadview.pt.packet-trace-profile")
+        dim = data[0]["payload"]
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("realm" in dim)
+        self.assertEqual(dim["realm"], "lag-link-resolution")
+        self.assertTrue("lag-id" in dim)
+        self.assertEqual(dim["lag-id"], "2")
+        self.assertTrue("lag-members" in dim)
+        self.assertEqual(len(dim["lag-members"]), 4)
+        self.assertTrue("1" in dim["lag-members"])
+        self.assertTrue("2" in dim["lag-members"])
+        self.assertTrue("3" in dim["lag-members"])
+        self.assertTrue("4" in dim["lag-members"])
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "1")
+        self.assertTrue("dst-lag-member" in dim)
+        self.assertEqual(dim["dst-lag-member"], "4")
+        self.assertTrue("fabric-trunk-id" in dim)
+        self.assertEqual(dim["fabric-trunk-id"], "6")
+        self.assertTrue("fabric-trunk-members" in dim)
+        self.assertEqual(len(dim["fabric-trunk-members"]), 3)
+        self.assertTrue("27" in dim["fabric-trunk-members"])
+        self.assertTrue("28" in dim["fabric-trunk-members"])
+        self.assertTrue("29" in dim["fabric-trunk-members"])
+
+        self.assertTrue("timestamp" in data[1])
+        timestamp = int(data[1]["timestamp"]) / 1000
+        self.assertTrue("name" in data[1])
+        self.assertTrue("payload" in data[1])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_profile_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        self.assertEqual(data[1]["name"], "broadview.pt.packet-trace-profile")
+        dim = data[1]["payload"]
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("realm" in dim)
+        self.assertEqual(dim["realm"], "ecmp-link-resolution")
+        self.assertTrue("ecmp-dst-member" in dim)
+        self.assertEqual(dim["ecmp-dst-member"], "100005")
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("ecmp-next-hop-ip" in dim)
+        self.assertEqual(dim["ecmp-next-hop-ip"], "1.6.6.2")
+        self.assertTrue("ecmp-dst-port" in dim)
+        self.assertEqual(dim["ecmp-dst-port"], "11")
+        self.assertTrue("ecmp-members" in dim)
+        self.assertEqual(len(dim["ecmp-members"]), 2)
+        mem = dim["ecmp-members"][0]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "1.2.2.2")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "100004")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "18")
+        mem = dim["ecmp-members"][1]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "1.6.6.1")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "100005")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "11")
+        self.assertTrue("ecmp-group-id" in dim)
+        self.assertEqual(dim["ecmp-group-id"], "100256")
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "1")
+
+        self.assertTrue("timestamp" in data[2])
+        timestamp = int(data[1]["timestamp"]) / 1000
+        self.assertTrue("name" in data[2])
+        self.assertTrue("payload" in data[2])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_profile_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        self.assertEqual(data[2]["name"], "broadview.pt.packet-trace-profile")
+        dim = data[2]["payload"]
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("realm" in dim)
+        self.assertEqual(dim["realm"], "ecmp-link-resolution")
+        self.assertTrue("ecmp-dst-member" in dim)
+        self.assertEqual(dim["ecmp-dst-member"], "200001")
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("ecmp-next-hop-ip" in dim)
+        self.assertEqual(dim["ecmp-next-hop-ip"], "2.3.3.2")
+        self.assertTrue("ecmp-dst-port" in dim)
+        self.assertEqual(dim["ecmp-dst-port"], "21")
+        self.assertTrue("ecmp-members" in dim)
+        self.assertEqual(len(dim["ecmp-members"]), 2)
+        mem = dim["ecmp-members"][0]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "2.3.3.1")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "200001")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "21")
+        mem = dim["ecmp-members"][1]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "2.7.7.2")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "200002")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "21")
+        self.assertTrue("ecmp-group-id" in dim)
+        self.assertEqual(dim["ecmp-group-id"], "200100")
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "1")
+
+    def test_packet_trace_lag_resolution_1(self):
+        rep = PTParser()
+        rep.process(self.packet_trace_lag_resolution_1)
+        serializer = PTToMonasca()
+        ret = serializer.serialize(self._host, rep)
+        self.assertEqual(ret[0], True)
+        data = json.loads(ret[1])
+        self.assertTrue(len(data) == 2)
+
+        self.assertTrue("timestamp" in data[0])
+        timestamp = int(data[0]["timestamp"]) / 1000
+        self.assertTrue("name" in data[0])
+        self.assertTrue("payload" in data[0])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_lag_resolution_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        self.assertEqual(data[0]["name"], "broadview.pt.packet-trace-lag-resolution")
+        dim = data[0]["payload"]
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("lag-id" in dim)
+        self.assertEqual(dim["lag-id"], "1")
+        self.assertTrue("lag-members" in dim)
+        self.assertEqual(len(dim["lag-members"]), 4)
+        self.assertTrue("1" in dim["lag-members"])
+        self.assertTrue("2" in dim["lag-members"])
+        self.assertTrue("3" in dim["lag-members"])
+        self.assertTrue("4" in dim["lag-members"])
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "1")
+        self.assertTrue("dst-lag-member" in dim)
+        self.assertEqual(dim["dst-lag-member"], "4")
+        self.assertTrue("fabric-trunk-id" in dim)
+        self.assertEqual(dim["fabric-trunk-id"], "8")
+        self.assertTrue("fabric-trunk-members" in dim)
+        self.assertEqual(len(dim["fabric-trunk-members"]), 3)
+        self.assertTrue("47" in dim["fabric-trunk-members"])
+        self.assertTrue("48" in dim["fabric-trunk-members"])
+        self.assertTrue("49" in dim["fabric-trunk-members"])
+
+        self.assertTrue("timestamp" in data[1])
+        timestamp = int(data[0]["timestamp"]) / 1000
+        self.assertTrue("name" in data[1])
+        self.assertTrue("payload" in data[1])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_lag_resolution_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        self.assertEqual(data[1]["name"], "broadview.pt.packet-trace-lag-resolution")
+        dim = data[1]["payload"]
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("lag-id" in dim)
+        self.assertEqual(dim["lag-id"], "2")
+        self.assertTrue("lag-members" in dim)
+        self.assertEqual(len(dim["lag-members"]), 4)
+        self.assertTrue("5" in dim["lag-members"])
+        self.assertTrue("6" in dim["lag-members"])
+        self.assertTrue("7" in dim["lag-members"])
+        self.assertTrue("8" in dim["lag-members"])
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "2")
+        self.assertTrue("dst-lag-member" in dim)
+        self.assertEqual(dim["dst-lag-member"], "7")
+        self.assertTrue("fabric-trunk-id" in dim)
+        self.assertEqual(dim["fabric-trunk-id"], "9")
+        self.assertTrue("fabric-trunk-members" in dim)
+        self.assertEqual(len(dim["fabric-trunk-members"]), 3)
+        self.assertTrue("57" in dim["fabric-trunk-members"])
+        self.assertTrue("58" in dim["fabric-trunk-members"])
+        self.assertTrue("59" in dim["fabric-trunk-members"])
+
+    def test_packet_trace_ecmp_resolution_1(self):
+        rep = PTParser()
+        rep.process(self.packet_trace_ecmp_resolution_1)
+        serializer = PTToMonasca()
+        ret = serializer.serialize(self._host, rep)
+        self.assertEqual(ret[0], True)
+        data = json.loads(ret[1])
+        self.assertTrue(len(data) == 4)
+
+        self.assertTrue("timestamp" in data[0])
+        timestamp = int(data[0]["timestamp"]) / 1000
+        self.assertTrue("name" in data[0])
+        self.assertTrue("payload" in data[0])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_ecmp_resolution_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        self.assertEqual(data[0]["name"], "broadview.pt.packet-trace-ecmp-resolution")
+        dim = data[0]["payload"]
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("ecmp-dst-member" in dim)
+        self.assertEqual(dim["ecmp-dst-member"], "100005")
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("ecmp-next-hop-ip" in dim)
+        self.assertEqual(dim["ecmp-next-hop-ip"], "1.6.6.2")
+        self.assertTrue("ecmp-dst-port" in dim)
+        self.assertEqual(dim["ecmp-dst-port"], "11")
+        self.assertTrue("ecmp-members" in dim)
+        self.assertEqual(len(dim["ecmp-members"]), 2)
+        mem = dim["ecmp-members"][0]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "1.2.2.2")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "100004")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "18")
+        mem = dim["ecmp-members"][1]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "1.6.6.1")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "100005")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "11")
+        self.assertTrue("ecmp-group-id" in dim)
+        self.assertEqual(dim["ecmp-group-id"], "100256")
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "1")
+
+        self.assertTrue("timestamp" in data[1])
+        timestamp = int(data[1]["timestamp"]) / 1000
+        self.assertTrue("name" in data[1])
+        self.assertTrue("payload" in data[1])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_ecmp_resolution_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        dim = data[1]["payload"]
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("ecmp-dst-member" in dim)
+        self.assertEqual(dim["ecmp-dst-member"], "200001")
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("ecmp-next-hop-ip" in dim)
+        self.assertEqual(dim["ecmp-next-hop-ip"], "2.3.3.2")
+        self.assertTrue("ecmp-dst-port" in dim)
+        self.assertEqual(dim["ecmp-dst-port"], "21")
+        self.assertTrue("ecmp-members" in dim)
+        self.assertEqual(len(dim["ecmp-members"]), 2)
+        mem = dim["ecmp-members"][0]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "2.3.3.1")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "200001")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "21")
+        mem = dim["ecmp-members"][1]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "2.7.7.2")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "200002")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "21")
+        self.assertTrue("ecmp-group-id" in dim)
+        self.assertEqual(dim["ecmp-group-id"], "200100")
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "1")
+
+        self.assertTrue("timestamp" in data[2])
+        timestamp = int(data[2]["timestamp"]) / 1000
+        self.assertTrue("name" in data[2])
+        self.assertTrue("payload" in data[2])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_ecmp_resolution_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        dim = data[2]["payload"]
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("ecmp-dst-member" in dim)
+        self.assertEqual(dim["ecmp-dst-member"], "300005")
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("ecmp-next-hop-ip" in dim)
+        self.assertEqual(dim["ecmp-next-hop-ip"], "3.6.6.2")
+        self.assertTrue("ecmp-dst-port" in dim)
+        self.assertEqual(dim["ecmp-dst-port"], "31")
+        self.assertTrue("ecmp-members" in dim)
+        self.assertEqual(len(dim["ecmp-members"]), 2)
+        mem = dim["ecmp-members"][0]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "3.3.3.1")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "300001")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "38")
+        mem = dim["ecmp-members"][1]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "3.7.7.2")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "300002")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "31")
+        self.assertTrue("ecmp-group-id" in dim)
+        self.assertEqual(dim["ecmp-group-id"], "300100")
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "2")
+
+        self.assertTrue("timestamp" in data[3])
+        timestamp = int(data[3]["timestamp"]) / 1000
+        self.assertTrue("name" in data[3])
+        self.assertTrue("payload" in data[3])
+        t1 = datetime.datetime.fromtimestamp(timestamp)
+        t1 = t1.strftime("%Y-%m-%d - %H:%M:%S")
+        t2 = self.packet_trace_ecmp_resolution_1["time-stamp"].strip()
+        self.assertEqual(t1, t2)
+        dim = data[3]["payload"]
+        self.assertTrue("asic-id" in dim)
+        self.assertEqual(dim["asic-id"], self.packet_trace_profile_1["asic-id"])
+        self.assertTrue("ecmp-dst-member" in dim)
+        self.assertEqual(dim["ecmp-dst-member"], "400001")
+        self.assertTrue("bv-agent" in dim)
+        self.assertTrue("ecmp-next-hop-ip" in dim)
+        self.assertEqual(dim["ecmp-next-hop-ip"], "4.3.3.2")
+        self.assertTrue("ecmp-dst-port" in dim)
+        self.assertEqual(dim["ecmp-dst-port"], "41")
+        self.assertTrue("ecmp-members" in dim)
+        self.assertEqual(len(dim["ecmp-members"]), 2)
+        mem = dim["ecmp-members"][0]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "4.3.3.1")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "400001")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "48")
+        mem = dim["ecmp-members"][1]
+        self.assertTrue("ip" in mem)
+        self.assertEqual(mem["ip"], "4.7.7.2")
+        self.assertTrue("id" in mem)
+        self.assertEqual(mem["id"], "400002")
+        self.assertTrue("port" in mem)
+        self.assertEqual(mem["port"], "41")
+        self.assertTrue("ecmp-group-id" in dim)
+        self.assertEqual(dim["ecmp-group-id"], "400100")
+        self.assertTrue("port" in dim)
+        self.assertEqual(dim["port"], "2")
+
+    def test_packet_trace_drop_reason(self):
+        rep = PTParser()
+        rep.process(self.packet_trace_drop_reason_1)
+        serializer = PTToMonasca()
+        ret = serializer.serialize(self._host, rep)
+        self.assertEqual(ret[0], True)
+        data = json.loads(ret[1])
+        self.assertTrue(len(data) == 2)
+        i = 0
+        for x in data:
+            self.assertTrue("timestamp" in x)
+            self.assertTrue("name" in x)
+            self.assertTrue("payload" in x)
+            self.assertEqual(x["name"], "broadview.pt.packet-trace-drop-reason")
+            dim = x["payload"]
+            if i == 0:
+                self.assertEqual(dim["reason"], "l2-lookup-failure")
+                l = dim["port-list"]
+                self.assertEqual(len(l), 4)
+                self.assertEqual(l[0], "1")
+                self.assertEqual(l[1], "5")
+                self.assertEqual(l[2], "6")
+                self.assertEqual(l[3], "10-15")
+                self.assertEqual(dim["send-dropped-packet"], 0)
+                self.assertEqual(dim["trace-profile"], 0)
+                self.assertEqual(dim["packet-threshold"], 0)
+                self.assertEqual(x["value"], 4)
+            else:
+                self.assertEqual(dim["reason"], "vlan-mismatch")
+                l = dim["port-list"]
+                self.assertEqual(len(l), 4)
+                self.assertEqual(l[0], "11")
+                self.assertEqual(l[1], "15")
+                self.assertEqual(l[2], "16")
+                self.assertEqual(l[3], "20-25")
+                self.assertEqual(dim["send-dropped-packet"], 1)
+                self.assertEqual(dim["trace-profile"], 1)
+                self.assertEqual(dim["packet-threshold"], 10)
+                self.assertEqual(x["value"], 3)
+            i = i + 1
+
+    def test_packet_trace_drop_counter_report(self):
+        rep = PTParser()
+        rep.process(self.packet_trace_drop_counter_report_1)
+        serializer = PTToMonasca()
+        ret = serializer.serialize(self._host, rep)
+        self.assertEqual(ret[0], True)
+        data = json.loads(ret[1])
+        self.assertTrue(len(data) == 18)
+        i = 0
+        for x in data:
+            self.assertTrue("timestamp" in x)
+            self.assertTrue("name" in x)
+            self.assertTrue("payload" in x)
+            self.assertEqual(x["name"], "broadview.pt.packet-trace-drop-counter-report")
+            dim = x["payload"]
+            if i == 0:
+                self.assertEqual(dim["realm"], "vlan-xlate-miss-drop")
+                self.assertEqual(dim["port"], "1")
+                self.assertEqual(x["value"], 10) 
+            elif i == 1:
+                self.assertEqual(dim["realm"], "vlan-xlate-miss-drop")
+                self.assertEqual(dim["port"], "5")
+                self.assertEqual(x["value"], 20) 
+            elif i == 2:
+                self.assertEqual(dim["realm"], "vlan-xlate-miss-drop")
+                self.assertEqual(dim["port"], "6")
+                self.assertEqual(x["value"], 30) 
+            elif i == 3:
+                self.assertEqual(dim["realm"], "vlan-xlate-miss-drop")
+                self.assertEqual(dim["port"], "10")
+                self.assertEqual(x["value"], 40) 
+            elif i == 4:
+                self.assertEqual(dim["realm"], "vlan-xlate-miss-drop")
+                self.assertEqual(dim["port"], "11")
+                self.assertEqual(x["value"], 50) 
+            elif i == 5:
+                self.assertEqual(dim["realm"], "vlan-xlate-miss-drop")
+                self.assertEqual(dim["port"], "12")
+                self.assertEqual(x["value"], 60) 
+            elif i == 6:
+                self.assertEqual(dim["realm"], "bpdu-drop")
+                self.assertEqual(dim["port"], "1")
+                self.assertEqual(x["value"], 70) 
+            elif i == 7:
+                self.assertEqual(dim["realm"], "bpdu-drop")
+                self.assertEqual(dim["port"], "5")
+                self.assertEqual(x["value"], 20) 
+            elif i == 8:
+                self.assertEqual(dim["realm"], "bpdu-drop")
+                self.assertEqual(dim["port"], "6")
+                self.assertEqual(x["value"], 30) 
+            elif i == 9:
+                self.assertEqual(dim["realm"], "bpdu-drop")
+                self.assertEqual(dim["port"], "10")
+                self.assertEqual(x["value"], 40) 
+            elif i == 10:
+                self.assertEqual(dim["realm"], "bpdu-drop")
+                self.assertEqual(dim["port"], "11")
+                self.assertEqual(x["value"], 80) 
+            elif i == 11:
+                self.assertEqual(dim["realm"], "bpdu-drop")
+                self.assertEqual(dim["port"], "12")
+                self.assertEqual(x["value"], 90) 
+            elif i == 12:
+                self.assertEqual(dim["realm"], "trill-slowpath-drop")
+                self.assertEqual(dim["port"], "1")
+                self.assertEqual(x["value"], 10) 
+            elif i == 13:
+                self.assertEqual(dim["realm"], "trill-slowpath-drop")
+                self.assertEqual(dim["port"], "5")
+                self.assertEqual(x["value"], 20) 
+            elif i == 14:
+                self.assertEqual(dim["realm"], "trill-slowpath-drop")
+                self.assertEqual(dim["port"], "6")
+                self.assertEqual(x["value"], 30) 
+            elif i == 15:
+                self.assertEqual(dim["realm"], "trill-slowpath-drop")
+                self.assertEqual(dim["port"], "10")
+                self.assertEqual(x["value"], 40) 
+            elif i == 16:
+                self.assertEqual(dim["realm"], "trill-slowpath-drop")
+                self.assertEqual(dim["port"], "11")
+                self.assertEqual(x["value"], 50) 
+            elif i == 17:
+                self.assertEqual(dim["realm"], "trill-slowpath-drop")
+                self.assertEqual(dim["port"], "12")
+                self.assertEqual(x["value"], 60) 
+            i = i + 1
+
+    def test_packet_trace_supported_drop_reasons(self):
+        rep = PTParser()
+        rep.process(self.packet_trace_supported_drop_reasons_1)
+        serializer = PTToMonasca()
+        ret = serializer.serialize(self._host, rep)
+        self.assertEqual(ret[0], True)
+        data = json.loads(ret[1])
+        self.assertTrue(len(data) == 1)
+        d = data[0]
+        self.assertTrue("timestamp" in d)
+        self.assertTrue("name" in d)
+        self.assertTrue("payload" in d)
+        self.assertEqual(d["name"], "broadview.pt.packet-trace-supported-drop-reasons")
+        dim = d["payload"]
+        self.assertTrue("reasons" in dim)
+        self.assertEqual(len(dim["reasons"]), 2)
+        self.assertEqual(dim["reasons"][0], "l2-lookup-failure")
+        self.assertEqual(dim["reasons"][1], "vlan-mismatch")
+
+if __name__ == "__main__":
+    unittest.main()
+
diff --git a/xos/synchronizer/ceilometer/ceilometer-plugins/network/ext_services/broadview/notifications.py b/xos/synchronizer/ceilometer/ceilometer-plugins/network/ext_services/broadview/notifications.py
index 0189e6c..694cf88 100644
--- a/xos/synchronizer/ceilometer/ceilometer-plugins/network/ext_services/broadview/notifications.py
+++ b/xos/synchronizer/ceilometer/ceilometer-plugins/network/ext_services/broadview/notifications.py
@@ -38,7 +38,7 @@
 class BroadViewNotificationBase(plugin_base.NotificationBase):
 
     resource_name = None
-    event_types = ['broadview.bst.*']
+    event_types = ['broadview.bst.*','broadview.pt.*']
 
     def get_targets(self,conf):
         """Return a sequence of oslo.messaging.Target
@@ -54,12 +54,16 @@
     def process_notification(self, message):
         if message['payload']:
             resource_id = 'broadview_' + message["payload"]["asic-id"] 
+            volume = 1
+            if 'value' in message["payload"]:
+                if (not 'ignore-value' in message["payload"]) or (message["payload"]['ignore-value'] != 1):
+                    volume = message["payload"]["value"]
             LOG.info('SRIKANTH: Received BroadView %(event_type)s notification: resource_id=%(resource_id)s' % {'event_type': message['event_type'], 'resource_id': resource_id})
             yield sample.Sample.from_notification(
                 name=message['event_type'],
                 type=sample.TYPE_GAUGE,
                 unit='bv-agent',
-                volume=message['payload']['value'],
+                volume=volume,
                 user_id=None,
                 project_id='default_admin_tenant',
                 resource_id=resource_id,