Trying to set up an Azure worker role with an asynchronous workflow for a polling service. The problem is that the role starts well and after some time becomes unresponsive. I don't know exactly what's the issue as in intellitrace there's no explicit exception. Do you see any problem here which may lead to this unstable situation ? After Mark an…

PollingService.fs

module PollingService
    
    open System.Diagnostics

    let poll interval work =
        let sw = Stopwatch()
        let rec loop() =
            async {
                sw.Restart()
                work()
                sw.Stop()
                let elapsed = int sw.ElapsedMilliseconds
                if elapsed < interval then
                    do! Async.Sleep(interval - elapsed)
                return! loop()
            }
        loop()

WorkerRole.fs

type WorkerRole() =
    inherit RoleEntryPoint() 

    let log message (kind : string) = Trace.TraceInformation(message, kind)
    let cts = new CancellationTokenSource()
    let interval = 2000
    let mutable onStopCalled = false
    let mutable returnedFromRunMethod = false;

    override wr.Run() =

        log "ExternalUserImport entry point called" "Information"

        try
            let polling = PollingService.poll interval (fun () ->
                    log "Doing asynchronous work" "Information"
                )

            Async.Start(polling, cts.Token)

        with
            | ex -> let mutable err = ex.Message
                    if (ex.InnerException <> null) then
                        err <- err + "Inner Exception : " + ex.InnerException.Message
                        
                    Trace.TraceError(err)
        
        while (true) do
            if (onStopCalled = true) then
                Trace.TraceInformation("onStopCalled WorkerRoleB")
                returnedFromRunMethod <- true
                ()

            Thread.Sleep(1000)


    override wr.OnStart() = 

        log "On start called" "Information"

        // Set the maximum number of concurrent connections 
        ServicePointManager.DefaultConnectionLimit <- Environment.ProcessorCount

        Diagnostics.configureDiagnostics()

        base.OnStart()

       
    override wr.OnStop() =
        
        log "On stop called" "Information"

        cts.Cancel()
        cts.Dispose()
        //cts <- new CancellationTokenSource()

        onStopCalled <- true
        while(returnedFromRunMethod = false) do
            Thread.Sleep(1000)
        
        base.OnStop()

In

while (true) do
            if (onStopCalled = true) then
                Trace.TraceInformation("onStopCalled WorkerRoleB")
                returnedFromRunMethod <- true
                ()

            Thread.Sleep(1000)

The () at the end of the if expression doesn't break the loop.