Skip to content

Commit c7f2968

Browse files
Async regen.
1 parent 223412c commit c7f2968

File tree

1 file changed

+40
-0
lines changed

1 file changed

+40
-0
lines changed

src/NHibernate/Async/Action/BulkOperationCleanupAction.cs

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,46 @@ public Task ExecuteAsync(CancellationToken cancellationToken)
5959
}
6060
}
6161

62+
private Task EvictCollectionRegionsAsync(CancellationToken cancellationToken)
63+
{
64+
if (cancellationToken.IsCancellationRequested)
65+
{
66+
return Task.FromCanceled<object>(cancellationToken);
67+
}
68+
try
69+
{
70+
if (affectedCollectionRoles != null && affectedCollectionRoles.Any())
71+
{
72+
return session.Factory.EvictCollectionAsync(affectedCollectionRoles, cancellationToken);
73+
}
74+
return Task.CompletedTask;
75+
}
76+
catch (Exception ex)
77+
{
78+
return Task.FromException<object>(ex);
79+
}
80+
}
81+
82+
private Task EvictEntityRegionsAsync(CancellationToken cancellationToken)
83+
{
84+
if (cancellationToken.IsCancellationRequested)
85+
{
86+
return Task.FromCanceled<object>(cancellationToken);
87+
}
88+
try
89+
{
90+
if (affectedEntityNames != null && affectedEntityNames.Any())
91+
{
92+
return session.Factory.EvictEntityAsync(affectedEntityNames, cancellationToken);
93+
}
94+
return Task.CompletedTask;
95+
}
96+
catch (Exception ex)
97+
{
98+
return Task.FromException<object>(ex);
99+
}
100+
}
101+
62102
#endregion
63103
}
64104
}

0 commit comments

Comments
 (0)