Adds support to Orleans.Analyzers for generic attributes

src/Orleans.Analyzers/SyntaxHelpers.cs

@@ -13,6 +13,7 @@ internal static class SyntaxHelpers
         {
             IdentifierNameSyntax id => id.Identifier.Text,
             QualifiedNameSyntax qualified => qualified.Right.Identifier.Text,
+			GenericNameSyntax generic => generic.Identifier.Text,
             _ => throw new NotSupportedException()
         };
 

test/Grains/TestGrains/StuckGrain.cs

@@ -20,6 +20,9 @@ public class StuckGrain : Grain, IStuckGrain
         private readonly ILogger<StuckGrain> _log;
         private bool isDeactivatingBlocking = false;
 
+        private static ConcurrentDictionary<GrainId, ManualResetEventSlim> blockingMREMap =
+            new ConcurrentDictionary<GrainId, ManualResetEventSlim>();
+
         public StuckGrain(ILogger<StuckGrain> log)
         {
             _log = log;
@@ -38,6 +41,33 @@ public static bool Release(Guid key)
             }
         }
 
+        public static Task WaitForDeactivationStart(GrainId key)
+        {
+            if (!blockingMREMap.TryGetValue(key, out var mre) || mre == null)
+                throw new InvalidOperationException();
+
+
+            return Task.Run(() => mre.Wait(1000));
+        }
+
+        public static void SetDeactivationStarted(GrainId key)
+        {
+            if (!blockingMREMap.TryGetValue(key, out var mre) || mre == null)
+                return;
+
+            mre.Set();
+        }
+
+        public static void BlockCallingTestUntilDeactivation(GrainId key)
+        {
+            if (!blockingMREMap.TryGetValue(key, out var mre) || mre == null)
+                mre = new ManualResetEventSlim(false);
+            else if (mre != null)
+                mre.Reset();
+
+            blockingMREMap[key] = mre;
+        }
+
         public static bool IsActivated(Guid key)
         {
             return grains.Contains(key);
@@ -77,6 +107,7 @@ public Task<bool> DidActivationTryToStart(GrainId id)
         public Task BlockingDeactivation()
         {
             isDeactivatingBlocking = true;
+            BlockCallingTestUntilDeactivation(this.GetGrainId());
             DeactivateOnIdle();
             return Task.CompletedTask;
         }
@@ -116,6 +147,7 @@ public override Task OnDeactivateAsync(DeactivationReason reason, CancellationTo
         {
             _log.LogInformation(reason.Exception, "Deactivating ReasonCode: {ReasonCode} Description: {ReasonText}", reason.ReasonCode, reason.Description);
 
+            SetDeactivationStarted(this.GetGrainId());
             if (isDeactivatingBlocking) return RunForever();
 
             var key = this.GetPrimaryKey();

test/TesterInternal/OrleansRuntime/StuckGrainTests.cs

@@ -10,6 +10,7 @@
 using Xunit;
 using System.Diagnostics;
 using Orleans.Runtime;
+using UnitTests.Grains;
 
 namespace UnitTests.StuckGrainTests
 {
@@ -109,6 +110,8 @@ public async Task StuckGrainTest_StuckDetectionOnDeactivation()
             var stuckGrain = this.fixture.GrainFactory.GetGrain<IStuckGrain>(id);
             await stuckGrain.BlockingDeactivation();
 
+            await StuckGrain.WaitForDeactivationStart(stuckGrain.GetGrainId());
+
             for (var i = 0; i < 3; i++)
             {
                 await Assert.ThrowsAsync<TimeoutException>(