force wait for join (#2051)

* force wait for join

Author: rogeralsing

src/Proto.Cluster/DefaultClusterContext.cs

@@ -19,21 +19,25 @@ namespace Proto.Cluster;
 
 public class DefaultClusterContext : IClusterContext
 {
+#pragma warning disable CS0618 // Type or member is obsolete
+    private static readonly ILogger Logger = Log.CreateLogger<DefaultClusterContext>();
+#pragma warning restore CS0618 // Type or member is obsolete
+    
     private readonly IIdentityLookup _identityLookup;
-
     private readonly PidCache _pidCache;
     private readonly ShouldThrottle _requestLogThrottle;
     private readonly ActorSystem _system;
-    private static readonly ILogger Logger = Log.CreateLogger<DefaultClusterContext>();
     private readonly int _requestTimeoutSeconds;
     private readonly bool _legacyTimeouts;
+    private readonly Cluster _cluster;
 
     public DefaultClusterContext(Cluster cluster)
     {
         _identityLookup = cluster.IdentityLookup;
         _pidCache = cluster.PidCache;
         var config = cluster.Config;
         _system = cluster.System;
+        _cluster = cluster;
 
         _requestLogThrottle = Throttle.Create(
             config.MaxNumberOfEventsInRequestLogThrottlePeriod,
@@ -48,6 +52,11 @@ public DefaultClusterContext(Cluster cluster)
     public async Task<T?> RequestAsync<T>(ClusterIdentity clusterIdentity, object message, ISenderContext context,
         CancellationToken ct)
     {
+        if (!_cluster.JoinedCluster.IsCompletedSuccessfully)
+        {
+            await _cluster.JoinedCluster;
+        }
+        
         var i = 0;
 
         var future = context.GetFuture();

src/Proto.Cluster/Gossip/Gossiper.cs

@@ -203,6 +203,8 @@ internal Task StartAsync()
 
     private async Task GossipLoop()
     {
+        Logger.LogInformation("Gossip is waiting for cluster to join");
+        await _cluster.JoinedCluster;
         Logger.LogInformation("Starting gossip loop");
         await Task.Yield();