Encode fat flow config in vrouter ksync.

Also, add introspect for fat flow config. (cherry picked from commit c9821d4) Conflicts: src/vnsw/agent/oper/agent.sandesh Change-Id: I9261c39a034b884b273619ee3b9bd55a2d5001b3 closes-bug: 1518234
Juniper · Feb 3, 2016 · caa89c1 · caa89c1
1 parent 60ea648
commit caa89c1
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 2 deletions.
diff --git a/src/vnsw/agent/oper/agent.sandesh b/src/vnsw/agent/oper/agent.sandesh
@@ -104,8 +104,9 @@ struct ItfSandeshData {
    49: optional string ipv4_active;
    50: list<string> fixed_ip4_list;
    51: list<string> fixed_ip6_list;
-   52: optional string health_check_active;
-   53: optional string metadata_ip_active;
+   52: list<string> fat_flow_list;
+   53: optional string health_check_active;
+   54: optional string metadata_ip_active;
 }
 
 struct VnIpamData {

diff --git a/src/vnsw/agent/oper/interface.cc b/src/vnsw/agent/oper/interface.cc
@@ -951,6 +951,17 @@ void Interface::SetItfSandeshData(ItfSandeshData &data) const {
         }
         data.set_fixed_ip6_list(fixed_ip6_list);
 
+        std::vector<std::string> fat_flow_list;
+        VmInterface::FatFlowEntrySet::iterator fat_flow_it =
+            vintf->fat_flow_list().list_.begin();
+        while (fat_flow_it != vintf->fat_flow_list().list_.end()) {
+            ostringstream str;
+            str << (int)fat_flow_it->protocol << ":" << (int)fat_flow_it->port<<"";
+            fat_flow_list.push_back(str.str());
+            fat_flow_it++;
+        }
+        data.set_fat_flow_list(fat_flow_list);
+
         if (vintf->fabric_port()) {
             data.set_fabric_port("FabricPort");
         } else {

diff --git a/src/vnsw/agent/vrouter/ksync/interface_ksync.cc b/src/vnsw/agent/vrouter/ksync/interface_ksync.cc
@@ -540,6 +540,16 @@ int InterfaceKSyncEntry::Encode(sandesh_op::type op, char *buf, int buf_len) {
                                      ((const int8_t *)smac(),
                                       (const int8_t *)smac() + smac().size()));
         }
+
+        if (fat_flow_list_.list_.size() != 0) {
+            std::vector<int32_t> fat_flow_list;
+            for (VmInterface::FatFlowEntrySet::const_iterator it =
+                 fat_flow_list_.list_.begin(); it != fat_flow_list_.list_.end();
+                 it++) {
+                fat_flow_list.push_back(it->protocol << 16 | it->port);
+            }
+            encoder.set_vifr_fat_flow_protocol_port(fat_flow_list);
+        }
         break;
     }