1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
using System;
using System.Threading;
using System.Threading.Tasks;
using Jellyfin.Api.Controllers;
using MediaBrowser.Controller.MediaEncoding;
using Microsoft.Extensions.Logging.Abstractions;
using Xunit;
namespace Jellyfin.Api.Tests.Controllers
{
public class DynamicHlsControllerTests
{
[Theory]
[MemberData(nameof(GetSegmentLengths_Success_TestData))]
public void GetSegmentLengths_Success(long runtimeTicks, int segmentlength, double[] expected)
{
var res = DynamicHlsController.GetSegmentLengthsInternal(runtimeTicks, segmentlength);
Assert.Equal(expected.Length, res.Length);
for (int i = 0; i < expected.Length; i++)
{
Assert.Equal(expected[i], res[i]);
}
}
public static TheoryData<long, int, double[]> GetSegmentLengths_Success_TestData()
{
var data = new TheoryData<long, int, double[]>();
data.Add(0, 6, Array.Empty<double>());
data.Add(
TimeSpan.FromSeconds(3).Ticks,
6,
new double[] { 3 });
data.Add(
TimeSpan.FromSeconds(6).Ticks,
6,
new double[] { 6 });
data.Add(
TimeSpan.FromSeconds(3.3333333).Ticks,
6,
new double[] { 3.3333333 });
data.Add(
TimeSpan.FromSeconds(9.3333333).Ticks,
6,
new double[] { 6, 3.3333333 });
return data;
}
[Fact]
public async Task WaitForActiveTranscodingRequests_WaitsUntilRequestCompletes()
{
var job = new TranscodingJob(NullLogger<TranscodingJob>.Instance)
{
ActiveRequestCount = 1
};
var waitTask = DynamicHlsController.WaitForActiveTranscodingRequests(job, CancellationToken.None);
Assert.False(waitTask.IsCompleted);
job.DecrementActiveRequestCount();
await waitTask;
}
[Fact]
public async Task WaitForActiveTranscodingRequests_WaitsForEveryRequest()
{
var job = new TranscodingJob(NullLogger<TranscodingJob>.Instance)
{
ActiveRequestCount = 2
};
var waitTask = DynamicHlsController.WaitForActiveTranscodingRequests(job, CancellationToken.None);
job.DecrementActiveRequestCount();
await Task.Delay(150, TestContext.Current.CancellationToken);
Assert.False(waitTask.IsCompleted);
job.DecrementActiveRequestCount();
await waitTask;
}
[Fact]
public async Task WaitForActiveTranscodingRequests_ReturnsWithoutAnActiveRequest()
{
var job = new TranscodingJob(NullLogger<TranscodingJob>.Instance);
await DynamicHlsController.WaitForActiveTranscodingRequests(job, CancellationToken.None);
await DynamicHlsController.WaitForActiveTranscodingRequests(null, CancellationToken.None);
}
[Fact]
public async Task WaitForActiveTranscodingRequests_ObservesCancellation()
{
var job = new TranscodingJob(NullLogger<TranscodingJob>.Instance)
{
ActiveRequestCount = 1
};
using var cancellationTokenSource = new CancellationTokenSource();
var waitTask = DynamicHlsController.WaitForActiveTranscodingRequests(job, cancellationTokenSource.Token);
await cancellationTokenSource.CancelAsync();
await Assert.ThrowsAnyAsync<OperationCanceledException>(() => waitTask);
}
[Fact]
public async Task ActiveRequestCount_UpdatesAtomically()
{
const int RequestCount = 1000;
var job = new TranscodingJob(NullLogger<TranscodingJob>.Instance);
await Task.WhenAll(
Task.Run(() => Parallel.For(0, RequestCount, _ => job.IncrementActiveRequestCount())),
Task.Run(() => Parallel.For(0, RequestCount, _ => job.DecrementActiveRequestCount())));
Assert.Equal(0, job.ActiveRequestCount);
}
}
}
|
