Skip to content

Commit c9ca86b

Browse files
committed
Fixed resource cleanup
1 parent 77584c2 commit c9ca86b

File tree

1 file changed

+13
-5
lines changed

1 file changed

+13
-5
lines changed

src/cluster/DotNext.Net.Cluster/Net/Cluster/Consensus/Raft/StateMachine/WriteAheadLog.PageManagement.cs

Lines changed: 13 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -209,6 +209,19 @@ public sealed override MemoryManager<byte> GetOrAddPage(uint pageIndex)
209209

210210
public sealed override MemoryManager<byte>? TryGetPage(uint pageIndex)
211211
=> Pages.GetValueOrDefault(pageIndex);
212+
213+
protected override void Dispose(bool disposing)
214+
{
215+
if (disposing)
216+
{
217+
foreach (var page in Pages.Values)
218+
{
219+
page.As<IDisposable>().Dispose();
220+
}
221+
}
222+
223+
base.Dispose(disposing);
224+
}
212225
}
213226

214227
private class AnonymousPageManager : PageManager<AnonymousPage>
@@ -372,11 +385,6 @@ protected override void Dispose(bool disposing)
372385
{
373386
if (disposing)
374387
{
375-
foreach (var page in Pages.Values)
376-
{
377-
page.As<IDisposable>().Dispose();
378-
}
379-
380388
cache.Clear();
381389
}
382390

0 commit comments

Comments
 (0)