Skip to content

Commit 35b8f1a

Browse files
committed
Removed call to BulkOperationCleanupAction.Init()
1 parent 5ffff67 commit 35b8f1a

File tree

3 files changed

+11
-7
lines changed

3 files changed

+11
-7
lines changed

src/NHibernate/Async/Engine/Query/NativeSQLQueryPlan.cs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,11 @@ private async Task CoordinateSharedCacheCleanupAsync(ISessionImplementor session
4343

4444
if (session.IsEventSource)
4545
{
46-
await (((IEventSource)session).ActionQueue.AddActionAsync(action, cancellationToken)).ConfigureAwait(false);
46+
await (((IEventSource) session).ActionQueue.AddActionAsync(action, cancellationToken)).ConfigureAwait(false);
47+
}
48+
else
49+
{
50+
action.AfterTransactionCompletionProcess(true);
4751
}
4852
}
4953

src/NHibernate/Engine/Query/NativeSQLQueryPlan.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,6 @@ private void CoordinateSharedCacheCleanup(ISessionImplementor session)
4848
{
4949
BulkOperationCleanupAction action = new BulkOperationCleanupAction(session, CustomQuery.QuerySpaces);
5050

51-
action.Init();
52-
5351
if (session.IsEventSource)
5452
{
5553
((IEventSource)session).ActionQueue.AddAction(action);

src/NHibernate/Hql/Ast/ANTLR/Exec/AbstractStatementExecutor.cs

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,11 +47,13 @@ protected virtual void CoordinateSharedCacheCleanup(ISessionImplementor session)
4747
{
4848
var action = new BulkOperationCleanupAction(session, AffectedQueryables);
4949

50-
action.Init();
51-
5250
if (session.IsEventSource)
5351
{
54-
((IEventSource)session).ActionQueue.AddAction(action);
52+
((IEventSource) session).ActionQueue.AddAction(action);
53+
}
54+
else
55+
{
56+
action.AfterTransactionCompletionProcess(true);
5557
}
5658
}
5759

@@ -311,4 +313,4 @@ public void DoWork(DbConnection connection, DbTransaction transaction)
311313
}
312314
}
313315
}
314-
}
316+
}

0 commit comments

Comments
 (0)