aboutsummaryrefslogtreecommitdiff
path: root/Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs
diff options
context:
space:
mode:
Diffstat (limited to 'Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs')
-rw-r--r--Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs19
1 files changed, 0 insertions, 19 deletions
diff --git a/Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs b/Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs
index 2cfa1b9a5..90ff36441 100644
--- a/Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs
+++ b/Emby.Server.Implementations/LiveTv/TunerHosts/MulticastStream.cs
@@ -16,7 +16,6 @@ namespace Emby.Server.Implementations.LiveTv.TunerHosts
private const int BufferSize = 81920;
private CancellationToken _cancellationToken;
private readonly ILogger _logger;
- private readonly ConcurrentQueue<byte[]> _sharedBuffer = new ConcurrentQueue<byte[]>();
public MulticastStream(ILogger logger)
{
@@ -38,14 +37,6 @@ namespace Emby.Server.Implementations.LiveTv.TunerHosts
byte[] copy = new byte[bytesRead];
Buffer.BlockCopy(buffer, 0, copy, 0, bytesRead);
- _sharedBuffer.Enqueue(copy);
-
- while (_sharedBuffer.Count > 10000)
- {
- byte[] bytes;
- _sharedBuffer.TryDequeue(out bytes);
- }
-
var allStreams = _outputStreams.ToList();
foreach (var stream in allStreams)
{
@@ -74,16 +65,6 @@ namespace Emby.Server.Implementations.LiveTv.TunerHosts
OnFinished = OnFinished
};
- var list = new List<byte>();
- foreach (var bytes in _sharedBuffer)
- {
- list.AddRange(bytes);
- }
-
- _logger.Info("QueueStream started with {0} initial bytes", list.Count);
-
- result.Queue(list.ToArray());
-
_outputStreams.TryAdd(result.Id, result);
result.Start(_cancellationToken);