Fix the matter server shutdown flow and add DataModelShutdown

Author: jadhavrohit924

src/app/server/Server.cpp

@@ -651,6 +651,8 @@ void Server::Shutdown()
 #if CHIP_CONFIG_ENABLE_ICD_SERVER
     app::DnssdServer::Instance().SetICDManager(nullptr);
 #endif // CHIP_CONFIG_ENABLE_ICD_SERVER
+
+    app::InteractionModelEngine::GetInstance()->SetDataModelProvider(nullptr);
     app::DnssdServer::Instance().SetCommissioningModeProvider(nullptr);
     Dnssd::ServiceAdvertiser::Instance().Shutdown();
 
@@ -681,11 +683,13 @@ void Server::Shutdown()
     mCommissioningWindowManager.Shutdown();
     mMessageCounterManager.Shutdown();
     mExchangeMgr.Shutdown();
+    mFabrics.RemoveFabricDelegate(&mFabricDelegate);
     mSessions.Shutdown();
     mTransports.Close();
     mAccessControl.Finish();
     Access::ResetAccessControlToDefault();
     Credentials::SetGroupDataProvider(nullptr);
+    app::EventManagement::GetInstance().DestroyEventManagement();
 #if CHIP_CONFIG_ENABLE_ICD_SERVER
     // Remove Test Event Trigger Handler
     if (mTestEventTriggerDelegate != nullptr)
@@ -695,6 +699,7 @@ void Server::Shutdown()
     mICDManager.Shutdown();
 #endif // CHIP_CONFIG_ENABLE_ICD_SERVER
 
+    mFabrics.Shutdown();
     // TODO(16969): Remove chip::Platform::MemoryInit() call from Server class, it belongs to outer code
     chip::Platform::MemoryShutdown();
 }

src/app/util/DataModelHandler.cpp

@@ -28,3 +28,8 @@ void InitDataModelHandler()
     emberAfEndpointConfigure();
     emberAfInit();
 }
+
+void ShutdownDataModelHandler()
+{
+    emberAfShutdown();
+}

src/app/util/DataModelHandler.h

@@ -21,3 +21,8 @@
  * data model messages.
  */
 void InitDataModelHandler();
+
+/**
+ * Shutdown the data model.
+ */
+void ShutdownDataModelHandler();

src/app/util/attribute-storage-detail.h

@@ -32,6 +32,8 @@ extern uint8_t attributeData[]; // main storage bucket for all attributes
 
 void emAfCallInits();
 
+void emAfCallShutdowns();
+
 chip::Protocols::InteractionModel::Status emAfReadOrWriteAttribute(const EmberAfAttributeSearchRecord * attRecord,
                                                                    const EmberAfAttributeMetadata ** metadata, uint8_t * buffer,
                                                                    uint16_t readLength, bool write);

src/app/util/attribute-storage.cpp

@@ -458,6 +458,7 @@ static void shutdownEndpoint(EmberAfDefinedEndpoint * definedEndpoint)
     for (clusterIndex = 0; clusterIndex < epType->clusterCount; clusterIndex++)
     {
         const EmberAfCluster * cluster  = &(epType->cluster[clusterIndex]);
+        emberAfClusterShutdownCallback(definedEndpoint->endpoint, cluster->clusterId);
         EmberAfGenericClusterFunction f = emberAfFindClusterFunction(cluster, MATTER_CLUSTER_FLAG_SHUTDOWN_FUNCTION);
         if (f != nullptr)
         {
@@ -482,6 +483,19 @@ void emAfCallInits()
     }
 }
 
+// Calls the shutdown functions.
+void emAfCallShutdowns()
+{
+    uint16_t index;
+    for (index = 0; index < emberAfEndpointCount(); index++)
+    {
+        if (emberAfEndpointIndexIsEnabled(index))
+        {
+            shutdownEndpoint(&(emAfEndpoints[index]));
+        }
+    }
+}
+
 // Returns the pointer to metadata, or null if it is not found
 const EmberAfAttributeMetadata * emberAfLocateAttributeMetadata(EndpointId endpoint, ClusterId clusterId, AttributeId attributeId)
 {

src/app/util/generic-callbacks.h

@@ -35,6 +35,17 @@
  */
 void emberAfClusterInitCallback(chip::EndpointId endpoint, chip::ClusterId clusterId);
 
+/** @brief Cluster Shutdown
+ *
+ * This function is called when a specific cluster is shutdown. It gives the
+ * application an opportunity to take care of cluster shutdown procedures.
+ * It is called exactly once for each endpoint where cluster is present.
+ *
+ * @param endpoint   Ver.: always
+ * @param clusterId   Ver.: always
+ */
+void emberAfClusterShutdownCallback(chip::EndpointId endpoint, chip::ClusterId clusterId);
+
 /** @brief Attribute Read Access
  *
  * This function is called whenever the Application Framework needs to check

src/app/util/util.cpp

@@ -84,6 +84,15 @@ void emberAfInit()
     emAfCallInits();
 }
 
+// ****************************************
+// Shutdown Clusters
+// ****************************************
+void emberAfShutdown()
+{
+    emAfCallShutdowns();
+    MATTER_PLUGINS_SHUTDOWN
+}
+
 // Cluster init functions that don't have a cluster implementation to define
 // them in.
 void MatterBallastConfigurationPluginServerInitCallback() {}
@@ -142,6 +151,63 @@ void MatterWaterHeaterManagementPluginServerInitCallback() {}
 void MatterWaterHeaterModePluginServerInitCallback() {}
 void MatterCommodityPricePluginServerInitCallback() {}
 
+// Cluster shutdown functions that don't have a cluster implementation to define
+// them in.
+void MatterBallastConfigurationPluginServerShutdownCallback() {}
+void MatterBooleanStatePluginServerShutdownCallback() {}
+void MatterRelativeHumidityMeasurementPluginServerShutdownCallback() {}
+void MatterIlluminanceMeasurementPluginServerShutdownCallback() {}
+void MatterBinaryInputBasicPluginServerShutdownCallback() {}
+void MatterPressureMeasurementPluginServerShutdownCallback() {}
+void MatterTemperatureMeasurementPluginServerShutdownCallback() {}
+void MatterFlowMeasurementPluginServerShutdownCallback() {}
+void MatterThermostatUserInterfaceConfigurationPluginServerShutdownCallback() {}
+void MatterBridgedDeviceBasicInformationPluginServerShutdownCallback() {}
+void MatterPowerConfigurationPluginServerShutdownCallback() {}
+void MatterPowerProfilePluginServerShutdownCallback() {}
+void MatterPulseWidthModulationPluginServerShutdownCallback() {}
+void MatterAlarmsPluginServerShutdownCallback() {}
+void MatterTimePluginServerShutdownCallback() {}
+void MatterAclPluginServerShutdownCallback() {}
+void MatterPollControlPluginServerShutdownCallback() {}
+void MatterUnitLocalizationPluginServerShutdownCallback() {}
+void MatterProxyValidPluginServerShutdownCallback() {}
+void MatterProxyDiscoveryPluginServerShutdownCallback() {}
+void MatterProxyConfigurationPluginServerShutdownCallback() {}
+void MatterFanControlPluginServerShutdownCallback() {}
+void MatterActivatedCarbonFilterMonitoringPluginServerShutdownCallback() {}
+void MatterHepaFilterMonitoringPluginServerShutdownCallback() {}
+void MatterAirQualityPluginServerShutdownCallback() {}
+void MatterCarbonMonoxideConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterCarbonDioxideConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterFormaldehydeConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterNitrogenDioxideConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterOzoneConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterPm10ConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterPm1ConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterPm25ConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterRadonConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterTotalVolatileOrganicCompoundsConcentrationMeasurementPluginServerShutdownCallback() {}
+void MatterRvcRunModePluginServerShutdownCallback() {}
+void MatterRvcCleanModePluginServerShutdownCallback() {}
+void MatterDishwasherModePluginServerShutdownCallback() {}
+void MatterLaundryWasherModePluginServerShutdownCallback() {}
+void MatterRefrigeratorAndTemperatureControlledCabinetModePluginServerShutdownCallback() {}
+void MatterOperationalStatePluginServerShutdownCallback() {}
+void MatterRvcOperationalStatePluginServerShutdownCallback() {}
+void MatterOvenModePluginServerShutdownCallback() {}
+void MatterOvenCavityOperationalStatePluginServerShutdownCallback() {}
+void MatterDishwasherAlarmPluginServerShutdownCallback() {}
+void MatterMicrowaveOvenModePluginServerShutdownCallback() {}
+void MatterDeviceEnergyManagementModePluginServerShutdownCallback() {}
+void MatterEnergyEvseModePluginServerShutdownCallback() {}
+void MatterPowerTopologyPluginServerShutdownCallback() {}
+void MatterElectricalEnergyMeasurementPluginServerShutdownCallback() {}
+void MatterElectricalPowerMeasurementPluginServerShutdownCallback() {}
+void MatterServiceAreaPluginServerShutdownCallback() {}
+void MatterWaterHeaterManagementPluginServerShutdownCallback() {}
+void MatterWaterHeaterModePluginServerShutdownCallback() {}
+
 bool emberAfContainsAttribute(chip::EndpointId endpoint, chip::ClusterId clusterId, chip::AttributeId attributeId)
 {
     return (emberAfGetServerAttributeIndexByAttributeId(endpoint, clusterId, attributeId) != UINT16_MAX);

src/app/util/util.h

@@ -25,6 +25,7 @@
 
 void emberAfInit();
 
+void emberAfShutdown();
 /**
  * Retrieves the difference between the two passed values.
  * This function assumes that the two values have the same endianness.

src/credentials/FabricTable.cpp

@@ -1168,6 +1168,7 @@ void FabricTable::Shutdown()
         delegate->next               = nullptr;
         delegate                     = temp;
     }
+    mDelegateListRoot = nullptr;
 
     RevertPendingFabricData();
     for (FabricInfo & fabricInfo : mStates)

src/data-model-providers/codegen/CodegenDataModelProvider.cpp

@@ -133,6 +133,7 @@ DefaultAttributePersistenceProvider gDefaultAttributePersistence;
 CHIP_ERROR CodegenDataModelProvider::Shutdown()
 {
     Reset();
+    ShutdownDataModelForTesting();
     mRegistry.ClearContext();
     return CHIP_NO_ERROR;
 }
@@ -602,6 +603,12 @@ void CodegenDataModelProvider::InitDataModelForTesting()
     InitDataModelHandler();
 }
 
+void CodegenDataModelProvider::ShutdownDataModelForTesting()
+{
+    // Call the Ember-specific ShutdownDataModelHandler
+    ShutdownDataModelHandler();
+}
+
 CHIP_ERROR CodegenDataModelProvider::DeviceTypes(EndpointId endpointId, ReadOnlyBufferBuilder<DataModel::DeviceTypeEntry> & builder)
 {
     std::optional<unsigned> endpoint_index = TryFindEndpointIndex(endpointId);

src/data-model-providers/codegen/CodegenDataModelProvider.h

@@ -84,6 +84,7 @@ class CodegenDataModelProvider : public DataModel::Provider
     // This method serves as a placeholder and should NOT be used outside of specific tests.
     // It is expected to be removed or replaced with a proper implementation in the future.TODO:(#36837).
     virtual void InitDataModelForTesting();
+    virtual void ShutdownDataModelForTesting();
 
 private:
     // Iteration is often done in a tight loop going through all values.