Skip to content

Commit 9cca877

Browse files
fredericDelaportefredericDelaporte
committed
Upgrade AsyncGenerator to 0.13.0
1 parent 9312c37 commit 9cca877

25 files changed

+253
-317
lines changed

‎Tools/packages.config

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
<package id="NUnit.Extension.NUnitV2ResultWriter" version="3.6.0" targetFramework="net461" />
88
<package id="NUnit.Extension.TeamCityEventListener" version="1.0.2" targetFramework="net461" />
99
<package id="NUnit.Extension.VSProjectLoader" version="3.6.0" targetFramework="net461" />
10-
<package id="CSharpAsyncGenerator.CommandLine" version="0.8.2.9" targetFramework="net461" />
10+
<package id="CSharpAsyncGenerator.CommandLine" version="0.13.0" targetFramework="net461" />
1111
<package id="vswhere" version="2.1.4" targetFramework="net461" />
1212
<package id="gitreleasemanager" version="0.7.0" targetFramework="net461" />
1313
</packages>

‎src/NHibernate.Test/Async/Linq/QueryTimeoutTests.cs

Lines changed: 4 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -114,15 +114,8 @@ public TimeoutCatchingNonBatchingBatcher(ConnectionManager connectionManager, II
114114

115115
public override Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
116116
{
117-
try
118-
{
119-
LastCommandTimeout = cmd.CommandTimeout;
120-
return base.ExecuteReaderAsync(cmd, cancellationToken);
121-
}
122-
catch (System.Exception ex)
123-
{
124-
return Task.FromException<DbDataReader>(ex);
125-
}
117+
LastCommandTimeout = cmd.CommandTimeout;
118+
return base.ExecuteReaderAsync(cmd, cancellationToken);
126119
}
127120

128121
public override DbDataReader ExecuteReader(DbCommand cmd)
@@ -150,15 +143,8 @@ public partial class TimeoutCatchingNonBatchingBatcher : NonBatchingBatcher
150143

151144
public override Task<DbDataReader> ExecuteReaderAsync(DbCommand cmd, CancellationToken cancellationToken)
152145
{
153-
try
154-
{
155-
LastCommandTimeout = cmd.CommandTimeout;
156-
return base.ExecuteReaderAsync(cmd, cancellationToken);
157-
}
158-
catch (System.Exception ex)
159-
{
160-
return Task.FromException<DbDataReader>(ex);
161-
}
146+
LastCommandTimeout = cmd.CommandTimeout;
147+
return base.ExecuteReaderAsync(cmd, cancellationToken);
162148
}
163149
}
164150
}

‎src/NHibernate.Test/Async/NHSpecificTest/GH1547/Fixture.cs

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -158,14 +158,7 @@ private partial class SubstituteDbCommand : DbCommand
158158

159159
protected override Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBehavior behavior, CancellationToken cancellationToken)
160160
{
161-
try
162-
{
163-
return Task.FromResult<DbDataReader>(_substituteReader);
164-
}
165-
catch (Exception ex)
166-
{
167-
return Task.FromException<DbDataReader>(ex);
168-
}
161+
return Task.FromResult<DbDataReader>(_substituteReader);
169162
}
170163

171164
public override Task<int> ExecuteNonQueryAsync(CancellationToken cancellationToken)

‎src/NHibernate.Test/Async/NHSpecificTest/NH3848/Fixture.cs

Lines changed: 6 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -573,20 +573,13 @@ protected void ClearSecondLevelCacheFor(System.Type entity)
573573

574574
protected Task ClearCollectionCacheAsync<T>(Expression<Func<T, IEnumerable>> pathToCollection, CancellationToken cancellationToken = default(CancellationToken))
575575
{
576-
try
577-
{
578-
var rootEntityTypeFullPath = typeof(T).FullName;
579-
var memberExpression = pathToCollection.Body as MemberExpression;
580-
if (memberExpression == null)
581-
return Task.FromException<object>(new ArgumentException("pathToCollection should be member expression"));
576+
var rootEntityTypeFullPath = typeof(T).FullName;
577+
var memberExpression = pathToCollection.Body as MemberExpression;
578+
if (memberExpression == null)
579+
return Task.FromException<object>(new ArgumentException("pathToCollection should be member expression"));
582580

583-
var role = $"{rootEntityTypeFullPath}.{memberExpression.Member.Name}";
584-
return Sfi.EvictCollectionAsync(role, cancellationToken);
585-
}
586-
catch (Exception ex)
587-
{
588-
return Task.FromException<object>(ex);
589-
}
581+
var role = $"{rootEntityTypeFullPath}.{memberExpression.Member.Name}";
582+
return Sfi.EvictCollectionAsync(role, cancellationToken);
590583
}
591584

592585
protected void ClearCollectionCache<T>(Expression<Func<T, IEnumerable>> pathToCollection)

‎src/NHibernate.Test/Async/SystemTransactions/DistributedSystemTransactionFixture.cs

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -690,16 +690,9 @@ public async Task EnforceConnectionUsageRulesOnTransactionCompletionAsync()
690690

691691
private Task DodgeTransactionCompletionDelayIfRequiredAsync(CancellationToken cancellationToken = default(CancellationToken))
692692
{
693-
try
694-
{
695-
if (Sfi.ConnectionProvider.Driver.HasDelayedDistributedTransactionCompletion)
696-
return Task.Delay(500, cancellationToken);
697-
return Task.CompletedTask;
698-
}
699-
catch (Exception ex)
700-
{
701-
return Task.FromException<object>(ex);
702-
}
693+
if (Sfi.ConnectionProvider.Driver.HasDelayedDistributedTransactionCompletion)
694+
return Task.Delay(500, cancellationToken);
695+
return Task.CompletedTask;
703696
}
704697

705698
private void DodgeTransactionCompletionDelayIfRequired()

‎src/NHibernate.Test/Async/TransactionTest/TransactionNotificationFixture.cs

Lines changed: 4 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -132,28 +132,14 @@ public partial class Synchronization : ITransactionCompletionSynchronization
132132

133133
public Task ExecuteBeforeTransactionCompletionAsync(CancellationToken cancellationToken)
134134
{
135-
try
136-
{
137-
BeforeExecutions += 1;
138-
return Task.CompletedTask;
139-
}
140-
catch (Exception ex)
141-
{
142-
return Task.FromException<object>(ex);
143-
}
135+
BeforeExecutions += 1;
136+
return Task.CompletedTask;
144137
}
145138

146139
public Task ExecuteAfterTransactionCompletionAsync(bool success, CancellationToken cancellationToken)
147140
{
148-
try
149-
{
150-
AfterExecutions += 1;
151-
return Task.CompletedTask;
152-
}
153-
catch (Exception ex)
154-
{
155-
return Task.FromException<object>(ex);
156-
}
141+
AfterExecutions += 1;
142+
return Task.CompletedTask;
157143
}
158144
}
159145

‎src/NHibernate.Test/Async/TransformTests/AliasToBeanResultTransformerFixture.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -304,7 +304,7 @@ public async Task SerializationAsync()
304304
var transformer = Transformers.AliasToBean<T>();
305305
var bytes = SerializationHelper.Serialize(transformer);
306306
transformer = (IResultTransformer)SerializationHelper.Deserialize(bytes);
307-
return AssertCardinalityNameAndIdAsync<T>(transformer: transformer, cancellationToken: cancellationToken);
307+
return AssertCardinalityNameAndIdAsync<T>(transformer: transformer, cancellationToken:cancellationToken);
308308
}
309309
catch (System.Exception ex)
310310
{

‎src/NHibernate.sln.DotSettings

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,9 @@
77
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/EXPLICIT_INTERNAL_MODIFIER/@EntryValue">True</s:Boolean>
88
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/EXPLICIT_PRIVATE_MODIFIER/@EntryValue">True</s:Boolean>
99
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/LINE_FEED_AT_FILE_END/@EntryValue">True</s:Boolean>
10+
<s:String x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/PLACE_ACCESSOR_ATTRIBUTE_ON_SAME_LINE_EX/@EntryValue">NEVER</s:String>
1011
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/PLACE_FIELD_ATTRIBUTE_ON_SAME_LINE/@EntryValue">False</s:Boolean>
12+
<s:String x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/PLACE_FIELD_ATTRIBUTE_ON_SAME_LINE_EX/@EntryValue">NEVER</s:String>
1113
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/PLACE_SIMPLE_ACCESSOR_ATTRIBUTE_ON_SAME_LINE/@EntryValue">False</s:Boolean>
1214
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/WRAP_AFTER_DECLARATION_LPAR/@EntryValue">True</s:Boolean>
1315
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/WRAP_AFTER_INVOCATION_LPAR/@EntryValue">True</s:Boolean>
@@ -20,9 +22,13 @@
2022
<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/PredefinedNamingRules/=PrivateInstanceFields/@EntryIndexedValue">&lt;Policy Inspect="True" Prefix="_" Suffix="" Style="aaBb" /&gt;</s:String>
2123
<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/PredefinedNamingRules/=PrivateStaticReadonly/@EntryIndexedValue">&lt;Policy Inspect="True" Prefix="" Suffix="" Style="AaBb" /&gt;</s:String>
2224
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ECSharpAttributeForSingleLineMethodUpgrade/@EntryIndexedValue">True</s:Boolean>
25+
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ECSharpKeepExistingMigration/@EntryIndexedValue">True</s:Boolean>
26+
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ECSharpPlaceEmbeddedOnSameLineMigration/@EntryIndexedValue">True</s:Boolean>
2327
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ESettingsUpgrade_002EAddAccessorOwnerDeclarationBracesMigration/@EntryIndexedValue">True</s:Boolean>
28+
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ESettingsUpgrade_002ECSharpPlaceAttributeOnSameLineMigration/@EntryIndexedValue">True</s:Boolean>
2429
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ESettingsUpgrade_002EMigrateBlankLinesAroundFieldToBlankLinesAroundProperty/@EntryIndexedValue">True</s:Boolean>
2530
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ESettingsUpgrade_002EMigrateThisQualifierSettings/@EntryIndexedValue">True</s:Boolean>
31+
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002EFormat_002ESettingsUpgrade_002EAlignmentTabFillStyleMigration/@EntryIndexedValue">True</s:Boolean>
2632
<s:Boolean x:Key="/Default/Environment/UnitTesting/SeparateAppDomainPerAssembly/@EntryValue">True</s:Boolean>
2733
<s:Boolean x:Key="/Default/PatternsAndTemplates/StructuralSearch/Pattern/=0BE95D01E0F2244E97F5FEFAD1EB1A63/@KeyIndexDefined">True</s:Boolean>
2834
<s:String x:Key="/Default/PatternsAndTemplates/StructuralSearch/Pattern/=0BE95D01E0F2244E97F5FEFAD1EB1A63/Comment/@EntryValue">NUnit Assert.NotNull</s:String>

‎src/NHibernate/Async/Action/CollectionAction.cs

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -55,15 +55,8 @@ public virtual Task ExecuteAfterTransactionCompletionAsync(bool success, Cancell
5555
{
5656
return Task.FromCanceled<object>(cancellationToken);
5757
}
58-
try
59-
{
60-
var ck = new CacheKey(key, persister.KeyType, persister.Role, Session.Factory);
61-
return persister.Cache.ReleaseAsync(ck, softLock, cancellationToken);
62-
}
63-
catch (Exception ex)
64-
{
65-
return Task.FromException<object>(ex);
66-
}
58+
var ck = new CacheKey(key, persister.KeyType, persister.Role, Session.Factory);
59+
return persister.Cache.ReleaseAsync(ck, softLock, cancellationToken);
6760
}
6861

6962
#endregion

‎src/NHibernate/Async/Action/EntityIdentityInsertAction.cs

Lines changed: 6 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -121,24 +121,17 @@ protected override Task AfterTransactionCompletionProcessImplAsync(bool success,
121121
{
122122
return Task.FromCanceled<object>(cancellationToken);
123123
}
124-
try
125-
{
126-
//TODO Make 100% certain that this is called before any subsequent ScheduledUpdate.afterTransactionCompletion()!!
127-
//TODO from H3.2: reenable if we also fix the above todo
128-
/*EntityPersister persister = getEntityPersister();
124+
//TODO Make 100% certain that this is called before any subsequent ScheduledUpdate.afterTransactionCompletion()!!
125+
//TODO from H3.2: reenable if we also fix the above todo
126+
/*EntityPersister persister = getEntityPersister();
129127
if ( success && persister.hasCache() && !persister.isCacheInvalidationRequired() ) {
130128
persister.getCache().afterInsert( getGeneratedId(), cacheEntry );
131129
}*/
132-
if (success)
133-
{
134-
return PostCommitInsertAsync(cancellationToken);
135-
}
136-
return Task.CompletedTask;
137-
}
138-
catch (Exception ex)
130+
if (success)
139131
{
140-
return Task.FromException<object>(ex);
132+
return PostCommitInsertAsync(cancellationToken);
141133
}
134+
return Task.CompletedTask;
142135
}
143136
}
144137
}

‎src/NHibernate/Async/Collection/AbstractPersistentCollection.cs

Lines changed: 13 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -73,30 +73,23 @@ public virtual Task ForceInitializationAsync(CancellationToken cancellationToken
7373
{
7474
return Task.FromCanceled<object>(cancellationToken);
7575
}
76-
try
76+
if (!initialized)
7777
{
78-
if (!initialized)
78+
if (initializing)
7979
{
80-
if (initializing)
81-
{
82-
return Task.FromException<object>(new AssertionFailure("force initialize loading collection"));
83-
}
84-
if (session == null)
85-
{
86-
return Task.FromException<object>(new HibernateException("collection is not associated with any session"));
87-
}
88-
if (!session.IsConnected)
89-
{
90-
return Task.FromException<object>(new HibernateException("disconnected session"));
91-
}
92-
return session.InitializeCollectionAsync(this, false, cancellationToken);
80+
return Task.FromException<object>(new AssertionFailure("force initialize loading collection"));
9381
}
94-
return Task.CompletedTask;
95-
}
96-
catch (Exception ex)
97-
{
98-
return Task.FromException<object>(ex);
82+
if (session == null)
83+
{
84+
return Task.FromException<object>(new HibernateException("collection is not associated with any session"));
85+
}
86+
if (!session.IsConnected)
87+
{
88+
return Task.FromException<object>(new HibernateException("disconnected session"));
89+
}
90+
return session.InitializeCollectionAsync(this, false, cancellationToken);
9991
}
92+
return Task.CompletedTask;
10093
}
10194

10295
public Task<ICollection> GetQueuedOrphansAsync(string entityName, CancellationToken cancellationToken)

‎src/NHibernate/Async/Engine/ActionQueue.cs

Lines changed: 3 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -46,18 +46,11 @@ private Task PreInvalidateCachesAsync(CancellationToken cancellationToken)
4646
{
4747
return Task.FromCanceled<object>(cancellationToken);
4848
}
49-
try
50-
{
51-
if (session.Factory.Settings.IsQueryCacheEnabled)
52-
{
53-
return session.Factory.UpdateTimestampsCache.PreInvalidateAsync(executedSpaces, cancellationToken);
54-
}
55-
return Task.CompletedTask;
56-
}
57-
catch (Exception ex)
49+
if (session.Factory.Settings.IsQueryCacheEnabled)
5850
{
59-
return Task.FromException<object>(ex);
51+
return session.Factory.UpdateTimestampsCache.PreInvalidateAsync(executedSpaces, cancellationToken);
6052
}
53+
return Task.CompletedTask;
6154
}
6255

6356
public async Task ExecuteAsync(IExecutable executable, CancellationToken cancellationToken)

0 commit comments

Comments
 (0)