Add ConfigureAwait(false)

All.sln

@@ -15,7 +15,6 @@ EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "src", "src", "{CE6B50B2-34AE-44C9-940A-4E48C3E1B3BC}"
 	ProjectSection(SolutionItems) = preProject
 		src\Directory.Build.props = src\Directory.Build.props
-		src\EFCore.ruleset = src\EFCore.ruleset
 	EndProjectSection
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "dotnet-ef", "src\dotnet-ef\dotnet-ef.csproj", "{2D66A1DA-D102-4DD9-960B-7D863BBB53DE}"

eng/Versions.props

@@ -28,6 +28,7 @@
     <SQLitePCLRawBundleWinsqlite3Version>2.0.3</SQLitePCLRawBundleWinsqlite3Version>
     <SQLitePCLRawCoreVersion>2.0.3</SQLitePCLRawCoreVersion>
     <IdentityServer4EntityFrameworkVersion>3.0.0</IdentityServer4EntityFrameworkVersion>
+    <FxCopAnalyzersVersion>3.0.0</FxCopAnalyzersVersion>
     <StyleCopAnalyzersVersion>1.1.118</StyleCopAnalyzersVersion>
     <BenchmarkDotNetVersion>0.12.0</BenchmarkDotNetVersion>
     <MicrosoftDataSqlClientVersion>2.0.0-preview3.20122.2</MicrosoftDataSqlClientVersion>

rulesets/EFCore.ruleset

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="utf-8"?>
+<RuleSet Name="EFCore" ToolsVersion="15.0">
+  <Include Path="StyleCop.ruleset" Action="Default" />
+  <Include Path="FxCop.ruleset" Action="Default" />
+</RuleSet>

EFCore.ruleset → rulesets/StyleCop.ruleset

@@ -1,5 +1,5 @@
-<?xml version="1.0" encoding="utf-8"?>
-<RuleSet Name="EFCore" ToolsVersion="15.0">
+<?xml version="1.0"?>
+<RuleSet Name="StyleCop" Description="StyleCop." ToolsVersion="15.0">
   <Rules AnalyzerId="StyleCop.Analyzers" RuleNamespace="StyleCop.Analyzers">
     <Rule Id="SA1000" Action="None" />
     <Rule Id="SA1001" Action="None" />
@@ -154,15 +154,4 @@
     <Rule Id="SA1649" Action="None" />
     <Rule Id="SA1650" Action="Warning" />
   </Rules>
-  <Rules AnalyzerId="Roslynator.CSharp.Analyzers" RuleNamespace="Roslynator.CSharp.Analyzers">
-    <Rule Id="RCS1079" Action="None" />
-    <Rule Id="RCS1090" Action="None" />
-    <Rule Id="RCS1118" Action="None" />
-    <Rule Id="RCS1141" Action="None" />
-    <Rule Id="RCS1142" Action="None" />
-    <Rule Id="RCS1165" Action="None" />
-    <Rule Id="RCS1168" Action="None" />
-    <Rule Id="RCS1194" Action="None" />
-    <Rule Id="RCS1206" Action="None" />
-  </Rules>
 </RuleSet>

src/Directory.Build.props

@@ -1,8 +1,14 @@
 <Project>
   <Import Project="..\Directory.Build.props" />
-  
+
   <PropertyGroup>
     <IsPackable>True</IsPackable>
     <IncludeSymbols>True</IncludeSymbols>
+    <CodeAnalysisRuleSet>..\..\rulesets\EFCore.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.CodeAnalysis.FxCopAnalyzers" Version="$(FxCopAnalyzersVersion)" PrivateAssets="All" />
+  </ItemGroup>
+
 </Project>

src/EFCore.Abstractions/EFCore.Abstractions.csproj

@@ -7,7 +7,6 @@
     <AssemblyName>Microsoft.EntityFrameworkCore.Abstractions</AssemblyName>
     <RootNamespace>Microsoft.EntityFrameworkCore</RootNamespace>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
-    <CodeAnalysisRuleSet>..\..\EFCore.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
 
   <ItemGroup>

src/EFCore.Analyzers/EFCore.Analyzers.csproj

@@ -6,7 +6,6 @@
     <AssemblyName>Microsoft.EntityFrameworkCore.Analyzers</AssemblyName>
     <RootNamespace>Microsoft.EntityFrameworkCore</RootNamespace>
     <IncludeBuildOutput>false</IncludeBuildOutput>
-    <CodeAnalysisRuleSet>..\..\EFCore.ruleset</CodeAnalysisRuleSet>
     <NuspecFile>$(MSBuildProjectName).nuspec</NuspecFile>
   </PropertyGroup>
 

src/EFCore.Cosmos/EFCore.Cosmos.csproj

@@ -8,7 +8,6 @@
     <RootNamespace>Microsoft.EntityFrameworkCore.Cosmos</RootNamespace>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <PackageTags>$(PackageTags);CosmosDb;SQL API</PackageTags>
-    <CodeAnalysisRuleSet>..\..\EFCore.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
 
   <ItemGroup>

src/EFCore.Cosmos/Query/Internal/CosmosShapedQueryCompilingExpressionVisitor.QueryingEnumerable.cs

@@ -222,7 +222,7 @@ public async ValueTask<bool> MoveNextAsync()
                                 _cosmosQueryContext.InitializeStateManager(_performIdentityResolution);
                             }
 
-                            var hasNext = await _enumerator.MoveNextAsync();
+                            var hasNext = await _enumerator.MoveNextAsync().ConfigureAwait(false);
 
                             Current
                                 = hasNext

src/EFCore.Cosmos/Query/Internal/CosmosShapedQueryCompilingExpressionVisitor.ReadItemQueryingEnumerable.cs

@@ -152,7 +152,8 @@ public async ValueTask<bool> MoveNextAsync()
                                     _readItemExpression.Container,
                                     partitionKey,
                                     resourceId,
-                                    _cancellationToken);
+                                    _cancellationToken)
+                                    .ConfigureAwait(false);
 
                                 return ShapeResult();
                             }

src/EFCore.Cosmos/Storage/Internal/CosmosClientWrapper.cs

@@ -287,14 +287,15 @@ private async Task<bool> CreateItemOnceAsync(
             await using var writer = new StreamWriter(stream, new UTF8Encoding(), bufferSize: 1024, leaveOpen: false);
             using var jsonWriter = new JsonTextWriter(writer);
             JsonSerializer.Create().Serialize(jsonWriter, parameters.Document);
-            await jsonWriter.FlushAsync(cancellationToken);
+            await jsonWriter.FlushAsync(cancellationToken).ConfigureAwait(false);
 
             var entry = parameters.Entry;
             var container = Client.GetDatabase(_databaseId).GetContainer(parameters.ContainerId);
             var itemRequestOptions = CreateItemRequestOptions(entry);
             var partitionKey = CreatePartitionKey(entry);
 
-            using var response = await container.CreateItemStreamAsync(stream, partitionKey, itemRequestOptions, cancellationToken);
+            using var response = await container.CreateItemStreamAsync(stream, partitionKey, itemRequestOptions, cancellationToken)
+                .ConfigureAwait(false);
             ProcessResponse(response, entry);
 
             return response.StatusCode == HttpStatusCode.Created;
@@ -348,15 +349,16 @@ private async Task<bool> ReplaceItemOnceAsync(
             using var writer = new StreamWriter(stream, new UTF8Encoding(), bufferSize: 1024, leaveOpen: false);
             using var jsonWriter = new JsonTextWriter(writer);
             JsonSerializer.Create().Serialize(jsonWriter, parameters.Document);
-            await jsonWriter.FlushAsync(cancellationToken);
+            await jsonWriter.FlushAsync(cancellationToken).ConfigureAwait(false);
 
             var entry = parameters.Entry;
             var container = Client.GetDatabase(_databaseId).GetContainer(parameters.ContainerId);
             var itemRequestOptions = CreateItemRequestOptions(entry);
             var partitionKey = CreatePartitionKey(entry);
 
             using var response = await container.ReplaceItemStreamAsync(
-                stream, parameters.ItemId, partitionKey, itemRequestOptions, cancellationToken);
+                    stream, parameters.ItemId, partitionKey, itemRequestOptions, cancellationToken)
+                .ConfigureAwait(false);
             ProcessResponse(response, entry);
 
             return response.StatusCode == HttpStatusCode.OK;
@@ -417,7 +419,8 @@ public virtual async Task<bool> DeleteItemOnceAsync(
             var partitionKey = CreatePartitionKey(entry);
 
             using var response = await items.DeleteItemStreamAsync(
-                parameters.DocumentId, partitionKey, itemRequestOptions, cancellationToken: cancellationToken);
+                    parameters.DocumentId, partitionKey, itemRequestOptions, cancellationToken: cancellationToken)
+                .ConfigureAwait(false);
             ProcessResponse(response, entry);
 
             return response.StatusCode == HttpStatusCode.NoContent;
@@ -550,7 +553,8 @@ internal virtual async Task<JObject> ExecuteReadItemAsync(
             _commandLogger.ExecutingReadItem(partitionKey, resourceId);
 
             var responseMessage = await CreateSingleItemQuery(
-                containerId, partitionKey, resourceId, cancellationToken);
+                    containerId, partitionKey, resourceId, cancellationToken)
+                .ConfigureAwait(false);
 
             return JObjectFromReadItemResponseMessage(responseMessage);
         }
@@ -597,11 +601,12 @@ private async Task<ResponseMessage> CreateSingleItemQuery(
             CancellationToken cancellationToken = default)
         {
             var container = Client.GetDatabase(_databaseId).GetContainer(containerId);
-            
+
             return await container.ReadItemStreamAsync(
-                resourceId,
-                string.IsNullOrEmpty(partitionKey) ? PartitionKey.None : new PartitionKey(partitionKey),
-                cancellationToken: cancellationToken);
+                    resourceId,
+                    string.IsNullOrEmpty(partitionKey) ? PartitionKey.None : new PartitionKey(partitionKey),
+                    cancellationToken: cancellationToken)
+                .ConfigureAwait(false);
         }
 
 
@@ -781,7 +786,7 @@ private sealed class AsyncEnumerator : IAsyncEnumerator<JObject>
                 private JsonTextReader _jsonReader;
 
                 private FeedIterator _query;
-                
+
                 public JObject Current { get; private set; }
 
                 public AsyncEnumerator(DocumentAsyncEnumerable documentEnumerable, CancellationToken cancellationToken)
@@ -808,7 +813,7 @@ public async ValueTask<bool> MoveNextAsync()
                             return false;
                         }
 
-                        _responseMessage = await _query.ReadNextAsync(_cancellationToken);
+                        _responseMessage = await _query.ReadNextAsync(_cancellationToken).ConfigureAwait(false);
                         _responseMessage.EnsureSuccessStatusCode();
 
                         _responseStream = _responseMessage.Content;
@@ -822,26 +827,26 @@ public async ValueTask<bool> MoveNextAsync()
                         return true;
                     }
 
-                    await ResetReadAsync();
+                    await ResetReadAsync().ConfigureAwait(false);
 
-                    return await MoveNextAsync();
+                    return await MoveNextAsync().ConfigureAwait(false);
                 }
 
                 private async Task ResetReadAsync()
                 {
                     _jsonReader?.Close();
                     _jsonReader = null;
-                    await _reader.DisposeAsyncIfAvailable();
+                    await _reader.DisposeAsyncIfAvailable().ConfigureAwait(false);
                     _reader = null;
-                    await _responseStream.DisposeAsyncIfAvailable();
+                    await _responseStream.DisposeAsyncIfAvailable().ConfigureAwait(false);
                     _responseStream = null;
                 }
 
                 public async ValueTask DisposeAsync()
                 {
-                    await ResetReadAsync();
+                    await ResetReadAsync().ConfigureAwait(false);
 
-                    await _responseMessage.DisposeAsyncIfAvailable();
+                    await _responseMessage.DisposeAsyncIfAvailable().ConfigureAwait(false);
                     _responseMessage = null;
                 }
             }

src/EFCore.Cosmos/Storage/Internal/CosmosDatabaseCreator.cs

@@ -78,22 +78,24 @@ public virtual bool EnsureCreated()
         /// </summary>
         public virtual async Task<bool> EnsureCreatedAsync(CancellationToken cancellationToken = default)
         {
-            var created = await _cosmosClient.CreateDatabaseIfNotExistsAsync(cancellationToken);
+            var created = await _cosmosClient.CreateDatabaseIfNotExistsAsync(cancellationToken)
+                .ConfigureAwait(false);
             foreach (var entityType in _model.GetEntityTypes())
             {
                 var containerName = entityType.GetContainer();
                 if (containerName != null)
                 {
                     created |= await _cosmosClient.CreateContainerIfNotExistsAsync(
-                        containerName,
-                        GetPartitionKeyStoreName(entityType),
-                        cancellationToken);
+                            containerName,
+                            GetPartitionKeyStoreName(entityType),
+                            cancellationToken)
+                        .ConfigureAwait(false);
                 }
             }
 
             if (created)
             {
-                await SeedAsync(cancellationToken);
+                await SeedAsync(cancellationToken).ConfigureAwait(false);
             }
 
             return created;

src/EFCore.Cosmos/Storage/Internal/CosmosDatabaseWrapper.cs

@@ -172,7 +172,7 @@ public override async Task<int> SaveChangesAsync(
                 entriesSaved.Add(entry);
                 try
                 {
-                    if (await SaveAsync(entry, cancellationToken))
+                    if (await SaveAsync(entry, cancellationToken).ConfigureAwait(false))
                     {
                         rowsAffected++;
                     }
@@ -186,7 +186,7 @@ public override async Task<int> SaveChangesAsync(
             foreach (var rootEntry in rootEntriesToSave)
             {
                 if (!entriesSaved.Contains(rootEntry)
-                    && await SaveAsync(rootEntry, cancellationToken))
+                    && await SaveAsync(rootEntry, cancellationToken).ConfigureAwait(false))
                 {
                     rowsAffected++;
                 }

src/EFCore.Design/EFCore.Design.csproj

@@ -6,7 +6,6 @@
     <AssemblyName>Microsoft.EntityFrameworkCore.Design</AssemblyName>
     <RootNamespace>Microsoft.EntityFrameworkCore</RootNamespace>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
-    <CodeAnalysisRuleSet>..\..\EFCore.ruleset</CodeAnalysisRuleSet>
     <DevelopmentDependency>True</DevelopmentDependency>
   </PropertyGroup>
 

src/EFCore.InMemory/EFCore.InMemory.csproj

@@ -8,7 +8,6 @@
     <RootNamespace>Microsoft.EntityFrameworkCore.InMemory</RootNamespace>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <PackageTags>$(PackageTags);In-Memory</PackageTags>
-    <CodeAnalysisRuleSet>..\..\EFCore.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
 
   <ItemGroup>

src/EFCore.Proxies/EFCore.Proxies.csproj

@@ -8,7 +8,6 @@
     <RootNamespace>Microsoft.EntityFrameworkCore</RootNamespace>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <PackageTags>$(PackageTags);Lazy-loading</PackageTags>
-    <CodeAnalysisRuleSet>..\..\EFCore.ruleset</CodeAnalysisRuleSet>
   </PropertyGroup>
 
   <ItemGroup>

src/EFCore.Relational/Diagnostics/Internal/DbCommandInterceptorAggregator.cs

@@ -107,7 +107,8 @@ public async Task<InterceptionResult<DbDataReader>> ReaderExecutingAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    result = await _interceptors[i].ReaderExecutingAsync(command, eventData, result, cancellationToken);
+                    result = await _interceptors[i].ReaderExecutingAsync(command, eventData, result, cancellationToken)
+                        .ConfigureAwait(false);
                 }
 
                 return result;
@@ -121,7 +122,8 @@ public async Task<InterceptionResult<object>> ScalarExecutingAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    result = await _interceptors[i].ScalarExecutingAsync(command, eventData, result, cancellationToken);
+                    result = await _interceptors[i].ScalarExecutingAsync(command, eventData, result, cancellationToken)
+                        .ConfigureAwait(false);
                 }
 
                 return result;
@@ -135,7 +137,8 @@ public async Task<InterceptionResult<int>> NonQueryExecutingAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    result = await _interceptors[i].NonQueryExecutingAsync(command, eventData, result, cancellationToken);
+                    result = await _interceptors[i].NonQueryExecutingAsync(command, eventData, result, cancellationToken)
+                        .ConfigureAwait(false);
                 }
 
                 return result;
@@ -188,7 +191,8 @@ public async Task<DbDataReader> ReaderExecutedAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    result = await _interceptors[i].ReaderExecutedAsync(command, eventData, result, cancellationToken);
+                    result = await _interceptors[i].ReaderExecutedAsync(command, eventData, result, cancellationToken)
+                        .ConfigureAwait(false);
                 }
 
                 return result;
@@ -202,7 +206,8 @@ public async Task<object> ScalarExecutedAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    result = await _interceptors[i].ScalarExecutedAsync(command, eventData, result, cancellationToken);
+                    result = await _interceptors[i].ScalarExecutedAsync(command, eventData, result, cancellationToken)
+                        .ConfigureAwait(false);
                 }
 
                 return result;
@@ -216,7 +221,8 @@ public async Task<int> NonQueryExecutedAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    result = await _interceptors[i].NonQueryExecutedAsync(command, eventData, result, cancellationToken);
+                    result = await _interceptors[i].NonQueryExecutedAsync(command, eventData, result, cancellationToken)
+                        .ConfigureAwait(false);
                 }
 
                 return result;
@@ -235,7 +241,8 @@ public async Task CommandFailedAsync(
             {
                 for (var i = 0; i < _interceptors.Length; i++)
                 {
-                    await _interceptors[i].CommandFailedAsync(command, eventData, cancellationToken);
+                    await _interceptors[i].CommandFailedAsync(command, eventData, cancellationToken)
+                        .ConfigureAwait(false);
                 }
             }