Start and initialize ReplicaWatchdog on FunctionRegistry creation

Author: stidsborg

Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/FunctionTests/PostponedTests.cs

@@ -264,7 +264,6 @@ protected async Task PostponedActionIsCompletedByWatchDogAfterCrash(Task<IFuncti
             (
                 crashableStore,
                 new Settings(
-                    unhandledExceptionHandler.Catch,
                     leaseLength: TimeSpan.Zero,
                     enableWatchdogs: false
                 )

Core/Cleipnir.ResilientFunctions/CoreRuntime/Watchdogs/CrashedOrPostponedWatchdog.cs

@@ -3,6 +3,7 @@
 using System.Threading;
 using System.Threading.Tasks;
 using Cleipnir.ResilientFunctions.CoreRuntime.Invocation;
+using Cleipnir.ResilientFunctions.Domain;
 using Cleipnir.ResilientFunctions.Domain.Exceptions;
 using Cleipnir.ResilientFunctions.Helpers;
 using Cleipnir.ResilientFunctions.Storage;
@@ -17,7 +18,8 @@ internal class CrashedOrPostponedWatchdog
 
     private readonly TimeSpan _checkFrequency;
     private readonly TimeSpan _delayStartUp;
-    
+    private readonly ClusterInfo _clusterInfo;
+
     private readonly LeasesUpdater _leasesUpdater;
 
     private volatile ImmutableDictionary<StoredType, Tuple<RestartFunction, ScheduleRestartFromWatchdog, AsyncSemaphore>> _flowsDictionary
@@ -31,6 +33,7 @@ public CrashedOrPostponedWatchdog(
         IFunctionStore functionStore,
         ShutdownCoordinator shutdownCoordinator, UnhandledExceptionHandler unhandledExceptionHandler, 
         TimeSpan checkFrequency, TimeSpan delayStartUp,
+        ClusterInfo clusterInfo,
         LeasesUpdater leasesUpdater, 
         UtcNow utcNow)
     {
@@ -39,6 +42,7 @@ public CrashedOrPostponedWatchdog(
         _unhandledExceptionHandler = unhandledExceptionHandler;
         _checkFrequency = checkFrequency;
         _delayStartUp = delayStartUp;
+        _clusterInfo = clusterInfo;
         _leasesUpdater = leasesUpdater;
         _utcNow = utcNow;
     }

Core/Cleipnir.ResilientFunctions/FunctionsRegistry.cs

@@ -44,6 +44,8 @@ public FunctionsRegistry(IFunctionStore functionStore, Settings? settings = null
         _leasesUpdater = new LeasesUpdater(_settings.LeaseLength, _functionStore, _settings.UnhandledExceptionHandler, utcNow);
         _ = _leasesUpdater.Start();
 
+        ClusterInfo = new ClusterInfo(ReplicaId.NewId());
+        
         _timeoutWatchdog = new TimeoutWatchdog(
             functionStore.TimeoutStore,
             _settings.WatchdogCheckFrequency,
@@ -58,13 +60,14 @@ public FunctionsRegistry(IFunctionStore functionStore, Settings? settings = null
             _settings.UnhandledExceptionHandler,
             _settings.WatchdogCheckFrequency,
             _settings.DelayStartup,
+            ClusterInfo,
             _leasesUpdater, 
             utcNow
         );
-
-        ClusterInfo = new ClusterInfo(ReplicaId.NewId());
-        _replicaWatchdog = new ReplicaWatchdog(ClusterInfo, functionStore, checkFrequency: TimeSpan.FromSeconds(1), _settings.UnhandledExceptionHandler);
 
+        _replicaWatchdog = new ReplicaWatchdog(ClusterInfo, functionStore, checkFrequency: TimeSpan.FromSeconds(1), _settings.UnhandledExceptionHandler);
+        _replicaWatchdog.Initialize().GetAwaiter().GetResult();
+        _ = _replicaWatchdog.Start();
     }
 
     #region Func overloads