Skip to content

Commit 0bcb6c0

Browse files
committed
Regenerate code
1 parent 757f08d commit 0bcb6c0

File tree

4 files changed

+12
-3
lines changed

4 files changed

+12
-3
lines changed

src/NHibernate/Async/Action/EntityInsertAction.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ public override async Task ExecuteAsync()
5353
ISessionFactoryImplementor factory = Session.Factory;
5454
if (IsCachePutEnabled(persister))
5555
{
56-
CacheEntry ce = CacheEntry.Create(state, persister, persister.HasUninitializedLazyProperties(instance), version, session, instance);
56+
CacheEntry ce = await (CacheEntry.CreateAsync(state, persister, persister.HasUninitializedLazyProperties(instance), version, session, instance));
5757
cacheEntry = persister.CacheEntryStructure.Structure(ce);
5858
CacheKey ck = Session.GenerateCacheKey(id, persister.IdentifierType, persister.RootEntityName);
5959
bool put = persister.Cache.Insert(ck, cacheEntry, version);

src/NHibernate/Async/Action/EntityUpdateAction.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public override async Task ExecuteAsync()
8585
}
8686
else
8787
{
88-
CacheEntry ce = CacheEntry.Create(state, persister, persister.HasUninitializedLazyProperties(instance), nextVersion, Session, instance);
88+
CacheEntry ce = await (CacheEntry.CreateAsync(state, persister, persister.HasUninitializedLazyProperties(instance), nextVersion, Session, instance));
8989
cacheEntry = persister.CacheEntryStructure.Structure(ce);
9090
bool put = persister.Cache.Update(ck, cacheEntry, nextVersion, previousVersion);
9191
if (put && factory.Statistics.IsStatisticsEnabled)

src/NHibernate/Async/Cache/Entry/CacheEntry.cs

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,15 @@ namespace NHibernate.Cache.Entry
1010
[System.CodeDom.Compiler.GeneratedCode("AsyncGenerator", "1.0.0")]
1111
public sealed partial class CacheEntry
1212
{
13+
public static async Task<CacheEntry> CreateAsync(object[] state, IEntityPersister persister, bool unfetched, object version, ISessionImplementor session, object owner)
14+
{
15+
//disassembled state gets put in a new array (we write to cache by value!)
16+
var disassembledState = await (TypeHelper.DisassembleAsync(state, persister.PropertyTypes, null, session, owner));
17+
var subclass = persister.EntityName;
18+
var lazyPropertiesAreUnfetched = unfetched || !persister.IsLazyPropertiesCacheable;
19+
return new CacheEntry(disassembledState, subclass, lazyPropertiesAreUnfetched, version);
20+
}
21+
1322
public async Task<object[]> AssembleAsync(object instance, object id, IEntityPersister persister, IInterceptor interceptor, ISessionImplementor session)
1423
{
1524
if (!persister.EntityName.Equals(subclass))

src/NHibernate/Async/Engine/TwoPhaseLoad.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,7 @@ public static async Task InitializeEntityAsync(object entity, bool readOnly, ISe
7474
if (log.IsDebugEnabled)
7575
log.Debug("adding entity to second-level cache: " + MessageHelper.InfoString(persister, id, session.Factory));
7676
object version = Versioning.GetVersion(hydratedState, persister);
77-
CacheEntry entry = CacheEntry.Create(hydratedState, persister, entityEntry.LoadedWithLazyPropertiesUnfetched, version, session, entity);
77+
CacheEntry entry = await (CacheEntry.CreateAsync(hydratedState, persister, entityEntry.LoadedWithLazyPropertiesUnfetched, version, session, entity));
7878
CacheKey cacheKey = session.GenerateCacheKey(id, persister.IdentifierType, persister.RootEntityName);
7979
bool put = persister.Cache.Put(cacheKey, persister.CacheEntryStructure.Structure(entry), session.Timestamp, version, persister.IsVersioned ? persister.VersionType.Comparator : null, UseMinimalPuts(session, entityEntry));
8080
if (put && factory.Statistics.IsStatisticsEnabled)

0 commit comments

Comments
 (0)