Check for open atomic write before resetting

hasty · hasty · commit 2a84acbfbe9a · 2024-08-06T11:27:18.000-07:00
diff --git a/src/app/clusters/thermostat-server/thermostat-server.cpp b/src/app/clusters/thermostat-server/thermostat-server.cpp
@@ -974,7 +974,7 @@ void ThermostatAttrAccess::OnFabricRemoved(const FabricTable & fabricTable, Fabr
     for (size_t i = 0; i < ArraySize(mAtomicWriteStates); ++i)
     {
         auto atomicWriteState = mAtomicWriteStates[i];
-        if (atomicWriteState.nodeId.GetFabricIndex() == fabricIndex)
+        if (atomicWriteState.inProgress && atomicWriteState.nodeId.GetFabricIndex() == fabricIndex)
         {
             auto delegate = GetDelegate(atomicWriteState.endpointId);
             if (delegate == nullptr)

Original file line number	Diff line number	Diff line change
`@@ -974,7 +974,7 @@ void ThermostatAttrAccess::OnFabricRemoved(const FabricTable & fabricTable, Fabr`
`974`	`974`	`for (size_t i = 0; i < ArraySize(mAtomicWriteStates); ++i)`
`975`	`975`	`{`
`976`	`976`	`auto atomicWriteState = mAtomicWriteStates[i];`
`977`		`- if (atomicWriteState.nodeId.GetFabricIndex() == fabricIndex)`
	`977`	`+ if (atomicWriteState.inProgress && atomicWriteState.nodeId.GetFabricIndex() == fabricIndex)`
`978`	`978`	`{`
`979`	`979`	`auto delegate = GetDelegate(atomicWriteState.endpointId);`
`980`	`980`	`if (delegate == nullptr)`