mattburchett/NadekoBot
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Prebuffering time drastically decreased

Browse Source
This commit is contained in:
Master Kwoth 2017-07-03 12:46:51 +02:00
parent a609e17717
commit 99049a6ace
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/NadekoBot/DataStructures/PoopyRingBuffer.cs
View File

@ -38,6 +38,11 @@ namespace NadekoBot.DataStructures
} }
} }
public int LightLength =>
_readPos <= _writePos?
_writePos - _readPos :
Capacity - (_readPos - _writePos);
public int RemainingCapacity public int RemainingCapacity
{ {
get { lock (posLock) return Capacity - Length - 1; } get { lock (posLock) return Capacity - Length - 1; }

2
src/NadekoBot/Services/Music/SongBuffer.cs
View File

@ -54,7 +54,7 @@ namespace NadekoBot.Services.Music
bytesRead = await p.StandardOutput.BaseStream.ReadAsync(buffer, 0, readSize, cancelToken).ConfigureAwait(false); bytesRead = await p.StandardOutput.BaseStream.ReadAsync(buffer, 0, readSize, cancelToken).ConfigureAwait(false);
await _outStream.WriteAsync(buffer, 0, bytesRead, cancelToken); await _outStream.WriteAsync(buffer, 0, bytesRead, cancelToken);
if (_outStream.RemainingCapacity < _outStream.Capacity * 0.5f || bytesRead == 0) if (_outStream.LightLength > 200_000 || bytesRead == 0)
if (toReturn.TrySetResult(true)) if (toReturn.TrySetResult(true))
_log.Info("Prebuffering finished"); _log.Info("Prebuffering finished");
} }