9792128433

Committed 04 Jul 2024 09:44AM UTC coverage: 83.372% (+0.2%) from 83.202%

Build # 9792128433

Build Type

Pull #1131

github

Committed by

web-flow

Commit Message

Merge 1a39300ac into 089f84846

Pull Request Pull Request #1131: Stability fixes

Run Details

889 of 1223 branches covered (72.69%)

Branch coverage included in aggregate %.

25 of 32 new or added lines in 7 files covered. (78.13%)

18 existing lines in 6 files now uncovered.

3373 of 3889 relevant lines covered (86.73%)

82.16 hits per line

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

90.91

/src/HassModel/NetDeamon.HassModel/Internal/BackgroundTaskTracker.cs

﻿using System.Collections.Concurrent;

namespace NetDaemon.HassModel.Internal;

internal class BackgroundTaskTracker : IBackgroundTaskTracker
{
    private readonly ILogger<BackgroundTaskTracker> _logger;
    internal readonly ConcurrentDictionary<Task, object?> BackgroundTasks = new();

    public BackgroundTaskTracker(ILogger<BackgroundTaskTracker> logger)
    {
        _logger = logger;
    }

    public void TrackBackgroundTask(Task? task, string? description = null)
    {
        ArgumentNullException.ThrowIfNull(task, nameof(task));

        BackgroundTasks.TryAdd(task, null);

        [SuppressMessage("", "CA1031")]
        async Task Wrap()
        {
            try
            {
                await task.ConfigureAwait(false);
            }
            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()
    {
        // Wait for the tasks to complete max 5 seconds
        if (!BackgroundTasks.IsEmpty)
        {
            await Task.WhenAny( Task.WhenAll(BackgroundTasks.Keys), Task.Delay(TimeSpan.FromSeconds(5))).ConfigureAwait(false);
        }
    }
}

1	using System.Collections.Concurrent;
2
3	namespace NetDaemon.HassModel.Internal;
4
5	internal class BackgroundTaskTracker : IBackgroundTaskTracker
6	{
7	private readonly ILogger<BackgroundTaskTracker> _logger;
8	internal readonly ConcurrentDictionary<Task, object?> BackgroundTasks = new();	30✔
9
10	public BackgroundTaskTracker(ILogger<BackgroundTaskTracker> logger)	30✔
11	{
12	_logger = logger;	30✔
13	}	30✔
14
15	public void TrackBackgroundTask(Task? task, string? description = null)
16	{
17	ArgumentNullException.ThrowIfNull(task, nameof(task));	17✔
18
19	BackgroundTasks.TryAdd(task, null);	17✔
20
21	[SuppressMessage("", "CA1031")]
22	async Task Wrap()
23	{
24	try
25	{
26	await task.ConfigureAwait(false);	17✔
27	}	16✔
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 _);	17✔
35	}
36	}	17✔
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();	17✔
42	}	17✔
43
44	public async ValueTask DisposeAsync()
45	{
46	// Wait for the tasks to complete max 5 seconds
47	if (!BackgroundTasks.IsEmpty)	72!
48	{
UNCOV 49	await Task.WhenAny( Task.WhenAll(BackgroundTasks.Keys), Task.Delay(TimeSpan.FromSeconds(5))).ConfigureAwait(false);	×
50	}
51	}	72✔
52	}

net-daemon / netdaemon / 9792128433

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