modify state db on tunnel decap field mod

Author: developfast

orchagent/tunneldecaporch.cpp

@@ -109,6 +109,8 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
 
         sai_object_id_t tunnel_id = SAI_NULL_OBJECT_ID;
 
+        // track whether any oper fields changed on this key
+        bool state_changed = false;
         // checking to see if the tunnel already exists
         bool exists = (tunnelTable.find(key) != tunnelTable.end());
         if (exists)
@@ -160,8 +162,10 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                     }
                     if (exists)
                     {
+                        // Apply to SAI; only touch cache/flag on success
                         setTunnelAttribute(fvField(i), dscp_mode, tunnel_id);
                         tunnelTable[key].dscp_mode = dscp_mode;
+                        state_changed = true;
                     }
                 }
                 else if (fvField(i) == "ecn_mode")
@@ -207,7 +211,9 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                     }
                     if (exists)
                     {
+                        // Apply to SAI; only touch cache/flag on success
                         setTunnelAttribute(fvField(i), ttl_mode, tunnel_id);
+                        state_changed = true;
                     }
                 }
                 else if (fvField(i) == decap_dscp_to_tc_field_name)
@@ -221,7 +227,9 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                     }
                     if (exists)
                     {
+                        // Apply to SAI; only touch cache/flag on success
                         setTunnelAttribute(fvField(i), dscp_to_tc_map_id, tunnel_id);
+                        state_changed = true;
                     }
                 }
                 else if (fvField(i) == decap_tc_to_pg_field_name)
@@ -235,7 +243,9 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                     }
                     if (exists)
                     {
+                        // Apply to SAI; only touch cache/flag on success
                         setTunnelAttribute(fvField(i), tc_to_pg_map_id, tunnel_id);
+                        state_changed = true;
                     }
                 }
                 else if (fvField(i) == encap_tc_to_dscp_field_name)
@@ -251,6 +261,7 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                     {
                         // Record only
                         tunnelTable[key].encap_tc_to_dscp_map_id = tc_to_dscp_map_id;
+                        state_changed = true;
                     }
                 }
                 else if (fvField(i) == encap_tc_to_queue_field_name)
@@ -266,6 +277,7 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                     {
                         // Record only
                         tunnelTable[key].encap_tc_to_queue_map_id = tc_to_queue_map_id;
+                        state_changed = true;
                     }
                 }
                 else
@@ -276,6 +288,11 @@ void TunnelDecapOrch::doDecapTunnelTask(Consumer &consumer)
                 }
             }
 
+            if (exists && state_changed) {
+                // Publish to STATE_DB if any mirrored field changed
+                setDecapTunnelStatus(key);
+            }
+
             if (task_status == task_process_status::task_need_retry)
             {
                 ++it;