16890355172

Committed 11 Aug 2025 07:42PM UTC coverage: 84.193% (+0.1%) from 84.091%

Build # 16890355172

Build Type

Pull #1315

github

Committed by

web-flow

Commit Message

Merge 4f0812f19 into 25a52e371

Pull Request Pull Request #1315: Minimal NetDaemon

Run Details

862 of 1147 branches covered (75.15%)

Branch coverage included in aggregate %.

47 of 48 new or added lines in 10 files covered. (97.92%)

1 existing line in 1 file now uncovered.

3383 of 3895 relevant lines covered (86.85%)

1331.78 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

82.86

/src/HassModel/NetDaemon.HassModel/Internal/BackgroundTaskTracker.cs

﻿using System.Collections.Concurrent;

namespace NetDaemon.HassModel.Internal;

internal class BackgroundTaskTracker(ILogger<BackgroundTaskTracker> logger) : IBackgroundTaskTracker
{
    private volatile bool _isDisposed;

    internal readonly ConcurrentDictionary<Task, object?> BackgroundTasks = new();

    public void TrackBackgroundTask(Task? task, string? description = null)
    {
        if (task == null) return;

        BackgroundTasks.TryAdd(task, null);

        [SuppressMessage("", "CA1031")]
        async Task Wrap()
        {
            try
            {
                await task.ConfigureAwait(false);
            }
            catch (OperationCanceledException)
            {
                logger.LogTrace("Task was canceled processing Home Assistant event: {Description}", description ?? "");
            }
            catch (Exception e)
            {
                logger.LogError(e, "Exception processing Home Assistant event: {Description}", description ?? "");
            }
            finally
            {
                BackgroundTasks.TryRemove(task, out var _);
            }
        }

        // We do not handle task here cause exceptions
        // are handled in the Wrap local functions and
        // all tasks should be cancelable
        _ = Wrap();
    }

    public async ValueTask DisposeAsync()
    {
        if (_isDisposed) return;
        _isDisposed = true;

        var timeoutTask = Task.Delay(TimeSpan.FromSeconds(5));

        // Using a while look here incase new tasks are added while we are waiting
        while (!BackgroundTasks.IsEmpty)
        {
            var task = await Task.WhenAny( Task.WhenAll(BackgroundTasks.Keys), timeoutTask).ConfigureAwait(false);
            if (task == timeoutTask)
                break;
        }
    }
}

1	using System.Collections.Concurrent;
2
3	namespace NetDaemon.HassModel.Internal;
4
5	internal class BackgroundTaskTracker(ILogger<BackgroundTaskTracker> logger) : IBackgroundTaskTracker	35✔
6	{
7	private volatile bool _isDisposed;
8
9	internal readonly ConcurrentDictionary<Task, object?> BackgroundTasks = new();	35✔
10
11	public void TrackBackgroundTask(Task? task, string? description = null)
12	{
13	if (task == null) return;	31!
14
15	BackgroundTasks.TryAdd(task, null);	31✔
16
17	[SuppressMessage("", "CA1031")]
18	async Task Wrap()
19	{
20	try
21	{
22	await task.ConfigureAwait(false);	31✔
23	}	30✔
24	catch (OperationCanceledException)	×
25	{
NEW 26	logger.LogTrace("Task was canceled processing Home Assistant event: {Description}", description ?? "");	×
27	}	×
28	catch (Exception e)	1✔
29	{
30	logger.LogError(e, "Exception processing Home Assistant event: {Description}", description ?? "");	1✔
31	}	1✔
32	finally
33	{
34	BackgroundTasks.TryRemove(task, out var _);	31✔
35	}
36	}	31✔
37
38	// We do not handle task here cause exceptions
39	// are handled in the Wrap local functions and
40	// all tasks should be cancelable
41	_ = Wrap();	31✔
42	}	31✔
43
44	public async ValueTask DisposeAsync()
45	{
46	if (_isDisposed) return;	92✔
47	_isDisposed = true;	20✔
48
49	var timeoutTask = Task.Delay(TimeSpan.FromSeconds(5));	20✔
50
51	// Using a while look here incase new tasks are added while we are waiting
52	while (!BackgroundTasks.IsEmpty)	1,573,395✔
53	{
54	var task = await Task.WhenAny( Task.WhenAll(BackgroundTasks.Keys), timeoutTask).ConfigureAwait(false);	1,573,376✔
55	if (task == timeoutTask)	1,573,376✔
56	break;
57	}
58	}	56✔
59	}

net-daemon / netdaemon / 16890355172

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous