commit d6cf5aa1a14035c506490800b1dc03e2986a22e2
author Nicolas Palpacuer <np202g@att.com> Mon Jul 16 15:14:39 2018 -0400
committer Nicolas Palpacuer <np202g@att.com> Mon Jul 16 15:52:04 2018 -0400
tree 6f5b5b3d5fd2d21665ece840f9a19210bc552fbb
parent 73222e0db37e7e6381169243540eb8f10f4b1792

VOL-1100 Flow priority, fix EAP after OLT reboot

Change-Id: I74878313e11aa26bf4e3909aa13f55116acfe797

src/core.cc

diff --git a/src/core.cc b/src/core.cc
index e5f4949..6a605e4 100644
--- a/src/core.cc
+++ b/src/core.cc
@@ -241,7 +241,7 @@
 Status FlowAdd_(uint32_t onu_id,
                 uint32_t flow_id, const std::string flow_type,
                 uint32_t access_intf_id, uint32_t network_intf_id,
-                uint32_t gemport_id,
+                uint32_t gemport_id, uint32_t priority_value,
                 const ::openolt::Classifier& classifier,
                 const ::openolt::Action& action) {
     bcmos_errno err;
@@ -274,6 +274,8 @@
     BCMBAL_CFG_PROP_SET(&cfg, flow, network_int_id, network_intf_id);
     BCMBAL_CFG_PROP_SET(&cfg, flow, sub_term_id, onu_id);
     BCMBAL_CFG_PROP_SET(&cfg, flow, svc_port_id, gemport_id);
+    BCMBAL_CFG_PROP_SET(&cfg, flow, priority, priority_value);
+
 
     {
         bcmbal_classifier val = { };

src/core.h

diff --git a/src/core.h b/src/core.h
index 38e02ba..eae6e79 100644
--- a/src/core.h
+++ b/src/core.h
@@ -33,7 +33,7 @@
 Status FlowAdd_(uint32_t onu_id,
                 uint32_t flow_id, const std::string flow_type,
                 uint32_t access_intf_id, uint32_t network_intf_id,
-                uint32_t gemport_id,
+                uint32_t gemport_id, uint32_t priority,
                 const ::openolt::Classifier& classifier,
                 const ::openolt::Action& action);
 

src/server.cc

diff --git a/src/server.cc b/src/server.cc
index 606e9cb..6b1609c 100644
--- a/src/server.cc
+++ b/src/server.cc
@@ -96,6 +96,7 @@
             request->access_intf_id(),
             request->network_intf_id(),
             request->gemport_id(),
+            request->priority(),
             request->classifier(),
             request->action());
     }