Fixes end of stream at handling websockets

vnext
Paul Schneider 4 years ago
parent 2cd531c242
commit 4fe417bd4f
2 changed files with 3 additions and 3 deletions

@ -165,6 +165,7 @@ namespace Yavsc.Services
received = await liveHandler.Socket.ReceiveAsync(sBuffer, liveHandler.TokenSource.Token); received = await liveHandler.Socket.ReceiveAsync(sBuffer, liveHandler.TokenSource.Token);
_logger.LogInformation($"Received bytes : {received.Count}"); _logger.LogInformation($"Received bytes : {received.Count}");
_logger.LogInformation($"segment : offset: {sBuffer.Offset} count: {sBuffer.Count}");
_logger.LogInformation($"Is the end : {received.EndOfMessage}"); _logger.LogInformation($"Is the end : {received.EndOfMessage}");
fsInputQueue.Enqueue(sBuffer); fsInputQueue.Enqueue(sBuffer);
if (received.CloseStatus.HasValue) if (received.CloseStatus.HasValue)

@ -64,10 +64,9 @@ namespace Yavsc.ViewModels.Streaming
logger.LogInformation($"writing {buffer.Array.Length} bytes..."); logger.LogInformation($"writing {buffer.Array.Length} bytes...");
await dest.WriteAsync(buffer.Array, 0, buffer.Array.Length); await dest.WriteAsync(buffer.Array, buffer.Offset, buffer.Count);
logger.LogInformation($"done."); logger.LogInformation($"done.");
usage += buffer.Array.Length; usage += buffer.Count;
} }
if (usage >= user.DiskQuota) break; if (usage >= user.DiskQuota) break;
if (queue.Count==0 && !isEndOfInput()) { if (queue.Count==0 && !isEndOfInput()) {

Loading…