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

Fix naming of IConnectionInformation.OutputReaderScheduler (#1608)

This commit is contained in:
Stephen Halter 2017-04-04 21:30:33 -07:00 committed by GitHub
parent 7ceea5323a
commit b40d8b4248
5 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/Microsoft.AspNetCore.Server.Kestrel.Core/Internal/ConnectionHandler.cs
View File

@ -25,7 +25,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal
public IConnectionContext OnConnection(IConnectionInformation connectionInfo) public IConnectionContext OnConnection(IConnectionInformation connectionInfo)
{ {
var inputPipe = connectionInfo.PipeFactory.Create(GetInputPipeOptions(connectionInfo.InputWriterScheduler)); var inputPipe = connectionInfo.PipeFactory.Create(GetInputPipeOptions(connectionInfo.InputWriterScheduler));
var outputPipe = connectionInfo.PipeFactory.Create(GetOutputPipeOptions(connectionInfo.OutputWriterScheduler)); var outputPipe = connectionInfo.PipeFactory.Create(GetOutputPipeOptions(connectionInfo.OutputReaderScheduler));
var connectionId = CorrelationIdGenerator.GetNextId(); var connectionId = CorrelationIdGenerator.GetNextId();

2
src/Microsoft.AspNetCore.Server.Kestrel.Transport.Abstractions/IConnectionInformation.cs
View File

@ -13,7 +13,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Transport.Abstractions
PipeFactory PipeFactory { get; } PipeFactory PipeFactory { get; }
IScheduler InputWriterScheduler { get; } IScheduler InputWriterScheduler { get; }
IScheduler OutputWriterScheduler { get; } IScheduler OutputReaderScheduler { get; }
// TODO: Remove timeout management from transport // TODO: Remove timeout management from transport
ITimeoutControl TimeoutControl { get; } ITimeoutControl TimeoutControl { get; }

2
src/Microsoft.AspNetCore.Server.Kestrel.Transport.Libuv/Internal/LibuvConnectionContext.cs
View File

@ -25,7 +25,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Transport.Libuv.Internal
public PipeFactory PipeFactory => ListenerContext.Thread.PipelineFactory; public PipeFactory PipeFactory => ListenerContext.Thread.PipelineFactory;
public IScheduler InputWriterScheduler => ListenerContext.Thread; public IScheduler InputWriterScheduler => ListenerContext.Thread;
public IScheduler OutputWriterScheduler => ListenerContext.Thread; public IScheduler OutputReaderScheduler => ListenerContext.Thread;
public ITimeoutControl TimeoutControl { get; set; } public ITimeoutControl TimeoutControl { get; set; }
} }

2
test/Microsoft.AspNetCore.Server.Kestrel.Performance/Mocks/MockConnectionInformation.cs
View File

@ -14,7 +14,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Performance
public PipeFactory PipeFactory { get; } public PipeFactory PipeFactory { get; }
public IScheduler InputWriterScheduler { get; } public IScheduler InputWriterScheduler { get; }
public IScheduler OutputWriterScheduler { get; } public IScheduler OutputReaderScheduler { get; }
public ITimeoutControl TimeoutControl { get; } = new MockTimeoutControl(); public ITimeoutControl TimeoutControl { get; } = new MockTimeoutControl();

2
test/Microsoft.AspNetCore.Server.KestrelTests/FrameTests.cs
View File

@ -716,7 +716,7 @@ namespace Microsoft.AspNetCore.Server.KestrelTests
public IPEndPoint LocalEndPoint { get; } public IPEndPoint LocalEndPoint { get; }
public PipeFactory PipeFactory { get; } public PipeFactory PipeFactory { get; }
public IScheduler InputWriterScheduler { get; } public IScheduler InputWriterScheduler { get; }
public IScheduler OutputWriterScheduler { get; } public IScheduler OutputReaderScheduler { get; }
public ITimeoutControl TimeoutControl { get; set; } = Mock.Of<ITimeoutControl>(); public ITimeoutControl TimeoutControl { get; set; } = Mock.Of<ITimeoutControl>();
} }
} }