Skip to content

Commit 77c7ea4

Browse files
committed
Better async key processing
1 parent aa4e0ae commit 77c7ea4

File tree

2 files changed

+2
-12
lines changed

2 files changed

+2
-12
lines changed

src/NHibernate/Async/Engine/BatchFetchQueue.cs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ internal async Task<object[]> GetCollectionBatchAsync(ICollectionPersister colle
7474
foreach (KeyValuePair<CollectionEntry, IPersistentCollection> me in map)
7575
{
7676
cancellationToken.ThrowIfCancellationRequested();
77-
if (await (ProcessKeyAndCheckCacheAsync(me)).ConfigureAwait(false))
77+
if (ProcessKey(me) ?? await (CheckCacheAndProcessResultAsync()).ConfigureAwait(false))
7878
{
7979
return keys;
8080
}
@@ -132,11 +132,6 @@ async Task<bool> CheckCacheAndProcessResultAsync()
132132
return false;
133133
}
134134

135-
async Task<bool> ProcessKeyAndCheckCacheAsync(KeyValuePair<CollectionEntry, IPersistentCollection> me)
136-
{
137-
return ProcessKey(me) ?? await (CheckCacheAndProcessResultAsync()).ConfigureAwait(false);
138-
}
139-
140135
bool? ProcessKey(KeyValuePair<CollectionEntry, IPersistentCollection> me, bool ignoreCache = false)
141136
{
142137
var ce = me.Key;

src/NHibernate/Engine/BatchFetchQueue.cs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -244,7 +244,7 @@ internal object[] GetCollectionBatch(ICollectionPersister collectionPersister, o
244244

245245
foreach (KeyValuePair<CollectionEntry, IPersistentCollection> me in map)
246246
{
247-
if (ProcessKeyAndCheckCache(me))
247+
if (ProcessKey(me) ?? CheckCacheAndProcessResult())
248248
{
249249
return keys;
250250
}
@@ -301,11 +301,6 @@ bool CheckCacheAndProcessResult()
301301
return false;
302302
}
303303

304-
bool ProcessKeyAndCheckCache(KeyValuePair<CollectionEntry, IPersistentCollection> me)
305-
{
306-
return ProcessKey(me) ?? CheckCacheAndProcessResult();
307-
}
308-
309304
bool? ProcessKey(KeyValuePair<CollectionEntry, IPersistentCollection> me, bool ignoreCache = false)
310305
{
311306
var ce = me.Key;

0 commit comments

Comments
 (0)