diff --git a/src/Kestrel/ServerRequest.cs b/src/Kestrel/ServerRequest.cs index eb65c5281f..47d9905afb 100644 --- a/src/Kestrel/ServerRequest.cs +++ b/src/Kestrel/ServerRequest.cs @@ -194,14 +194,14 @@ namespace Kestrel } } - bool IHttpResponseFeature.HeadersSent + bool IHttpResponseFeature.HasStarted { - get { return _frame.HeadersSent; } + get { return _frame.HasResponseStarted; } } - void IHttpResponseFeature.OnSendingHeaders(Action callback, object state) + void IHttpResponseFeature.OnResponseStarting(Action callback, object state) { - _frame.OnSendingHeaders(callback, state); + _frame.OnResponseStarting(callback, state); } void IHttpResponseFeature.OnResponseCompleted(Action callback, object state) diff --git a/src/Microsoft.AspNet.Server.Kestrel/Http/Frame.cs b/src/Microsoft.AspNet.Server.Kestrel/Http/Frame.cs index 8761f0c64f..3a9277f85c 100644 --- a/src/Microsoft.AspNet.Server.Kestrel/Http/Frame.cs +++ b/src/Microsoft.AspNet.Server.Kestrel/Http/Frame.cs @@ -54,7 +54,7 @@ namespace Microsoft.AspNet.Server.Kestrel.Http Mode _mode; private bool _resultStarted; - private bool _headersSent; + private bool _responseStarted; private bool _keepAlive; /* @@ -63,9 +63,9 @@ namespace Microsoft.AspNet.Server.Kestrel.Http CancellationTokenSource _cts = new CancellationTokenSource(); */ - List, object>> _onSendingHeaders; + List, object>> _onResponseStarting; List, object>> _onResponseCompleted; - object _onSendingHeadersSync = new Object(); + object _onResponseStartingSync = new Object(); object _onResponseCompletedSync = new Object(); public Frame(ConnectionContext context) : base(context) @@ -92,9 +92,9 @@ namespace Microsoft.AspNet.Server.Kestrel.Http public Stream DuplexStream { get; set; } - public bool HeadersSent + public bool HasResponseStarted { - get { return _headersSent; } + get { return _responseStarted; } } @@ -190,15 +190,15 @@ namespace Microsoft.AspNet.Server.Kestrel.Http Task.Run(ExecuteAsync); } - public void OnSendingHeaders(Action callback, object state) + public void OnResponseStarting(Action callback, object state) { - lock (_onSendingHeadersSync) + lock (_onResponseStartingSync) { - if (_onSendingHeaders == null) + if (_onResponseStarting == null) { - _onSendingHeaders = new List, object>>(); + _onResponseStarting = new List, object>>(); } - _onSendingHeaders.Add(new KeyValuePair, object>(callback, state)); + _onResponseStarting.Add(new KeyValuePair, object>(callback, state)); } } @@ -214,17 +214,17 @@ namespace Microsoft.AspNet.Server.Kestrel.Http } } - private void FireOnSendingHeaders() + private void FireOnResponseStarting() { - List, object>> onSendingHeaders = null; - lock (_onSendingHeadersSync) + List, object>> onResponseStarting = null; + lock (_onResponseStartingSync) { - onSendingHeaders = _onSendingHeaders; - _onSendingHeaders = null; + onResponseStarting = _onResponseStarting; + _onResponseStarting = null; } - if (onSendingHeaders != null) + if (onResponseStarting != null) { - foreach (var entry in onSendingHeaders) + foreach (var entry in onResponseStarting) { entry.Key.Invoke(entry.Value); } @@ -318,9 +318,9 @@ namespace Microsoft.AspNet.Server.Kestrel.Http if (_resultStarted) return; _resultStarted = true; - FireOnSendingHeaders(); + FireOnResponseStarting(); - _headersSent = true; + _responseStarted = true; var status = ReasonPhrases.ToStatus(StatusCode, ReasonPhrase);