huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'benaadams/async-write' into dev

This commit is contained in:
Cesar Blum Silveira 2016-04-27 11:25:45 -07:00
parent b0d5cfcf47 216aa9343e
commit 5a8cba878d
1 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/Microsoft.AspNetCore.Server.Kestrel/Filter/StreamSocketOutput.cs
View File

@ -73,9 +73,26 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Filter
public Task WriteAsync(ArraySegment<byte> buffer, bool chunk, CancellationToken cancellationToken) public Task WriteAsync(ArraySegment<byte> buffer, bool chunk, CancellationToken cancellationToken)
{ {
// TODO: Use _outputStream.WriteAsync #if NET451
Write(buffer, chunk); Write(buffer, chunk);
return TaskUtilities.CompletedTask; return TaskUtilities.CompletedTask;
#else
if (chunk && buffer.Array != null)
{
return WriteAsyncChunked(buffer, cancellationToken);
}
return _outputStream.WriteAsync(buffer.Array ?? _nullBuffer, buffer.Offset, buffer.Count, cancellationToken);
#endif
}
private async Task WriteAsyncChunked(ArraySegment<byte> buffer, CancellationToken cancellationToken)
{
var beginChunkBytes = ChunkWriter.BeginChunkBytes(buffer.Count);
await _outputStream.WriteAsync(beginChunkBytes.Array, beginChunkBytes.Offset, beginChunkBytes.Count, cancellationToken);
await _outputStream.WriteAsync(buffer.Array, buffer.Offset, buffer.Count, cancellationToken);
await _outputStream.WriteAsync(_endChunkBytes, 0, _endChunkBytes.Length, cancellationToken);
} }
public MemoryPoolIterator ProducingStart() public MemoryPoolIterator ProducingStart()