1 write to Response
Microsoft.AspNetCore.Server.HttpSys (1)
RequestProcessing\RequestContext.FeatureCollection.cs (1)
123
Response
= new Response(this);
126 references to Response
Microsoft.AspNetCore.Server.HttpSys (66)
AuthenticationHandler.cs (2)
26
_requestContext!.
Response
.StatusCode = 401;
32
_requestContext!.
Response
.StatusCode = 403;
AuthenticationManager.cs (3)
181
IList<string> challenges = GenerateChallenges(context.
Response
.AuthenticationChallenges);
185
context.
Response
.Headers[HeaderNames.WWWAuthenticate]
186
= StringValues.Concat(context.
Response
.Headers[HeaderNames.WWWAuthenticate], challenges.ToArray());
RequestProcessing\Request.cs (1)
396
public bool CanDelegate => !(HasRequestBodyStarted || RequestContext.
Response
.HasStarted);
RequestProcessing\RequestContext.cs (14)
48
if (_disposed ||
Response
.BodyIsFinished)
98
if (
Response
.HasStarted)
104
Response
.StatusCode = StatusCodes.Status101SwitchingProtocols;
105
Response
.ReasonPhrase = ReasonPhrases.GetReasonPhrase(StatusCodes.Status101SwitchingProtocols);
107
Response
.SendOpaqueUpgrade(); // TODO: Async
109
Response
.SwitchToOpaqueMode();
110
var opaqueStream = new OpaqueStream(Request.Body,
Response
.Body);
132
Response
.Dispose();
179
Response
?.Abort();
213
Response
?.CancelLastWrite();
338
Response
.StatusCode = status;
339
Response
.ContentLength = 0;
349
if (
Response
.HasStarted)
383
Response
.MarkDelegated();
RequestProcessing\RequestContext.FeatureCollection.cs (14)
142
_responseStream = new ResponseStream(
Response
.Body, OnResponseStart);
143
_responseHeaders =
Response
.Headers;
478
get { return
Response
.ReasonPhrase; }
479
set {
Response
.ReasonPhrase = value; }
484
get { return
Response
.StatusCode; }
485
set {
Response
.StatusCode = value; }
491
await
Response
.SendFileAsync(path, offset, length, cancellation);
524
Response
.Dispose();
614
get => _responseTrailers ??=
Response
.Trailers;
632
Response
.Headers.IsReadOnly = true; // Prohibit further modifications.
659
Response
.CacheTtl = GetCacheTtl();
665
var response =
Response
;
752
if (!
Response
.HasStarted)
754
Response
.Headers[HeaderNames.Connection] = "close";
RequestProcessing\RequestContextOfT.cs (5)
71
if (
Response
.HasStarted)
89
Response
.Headers.IsReadOnly = false;
90
Response
.Trailers.IsReadOnly = false;
91
Response
.Headers.Clear();
92
Response
.Trailers.Clear();
RequestProcessing\Response.cs (1)
401
var statusCanHaveBody = CanSendResponseBody(RequestContext.
Response
.StatusCode);
RequestProcessing\ResponseBody.cs (26)
121
var started = _requestContext.
Response
.HasStarted;
150
statusCode = _requestContext.
Response
.SendHeaders(ref allocator, dataChunks, null, flags, false);
193
var chunked = _requestContext.
Response
.BoundaryType == BoundaryType.Chunked;
194
var addTrailers = endOfRequest && _requestContext.
Response
.HasTrailers;
265
_requestContext.
Response
.SerializeTrailers(ref allocator, out dataChunks[currentChunk++]);
269
_requestContext.
Response
.MakeTrailersReadOnly();
327
var started = _requestContext.
Response
.HasStarted;
343
var chunked = _requestContext.
Response
.BoundaryType == BoundaryType.Chunked;
352
statusCode = _requestContext.
Response
.SendHeaders(ref allocator, null, asyncResult, flags, false);
465
if (!_requestContext.
Response
.HasComputedHeaders)
467
flags = _requestContext.
Response
.ComputeHeaders(writeCount, endOfRequest);
475
else if (_requestContext.
Response
.BoundaryType == BoundaryType.ContentLength)
477
_leftToWrite = _requestContext.
Response
.ExpectedBodyLength;
485
if (endOfRequest && _requestContext.
Response
.BoundaryType == BoundaryType.Close)
490
&& (_leftToWrite != writeCount || _requestContext.
Response
.TrailersExpected))
508
if (_leftToWrite == 0 && !_requestContext.
Response
.TrailersExpected)
511
_requestContext.
Response
.MakeTrailersReadOnly();
528
if (count == 0 && _requestContext.
Response
.HasStarted)
550
var contentLength = _requestContext.
Response
.ContentLength;
552
if (!_requestContext.
Response
.HasComputedHeaders && contentLength < count)
557
else if (_requestContext.
Response
.HasComputedHeaders && _requestContext.
Response
.BoundaryType == BoundaryType.ContentLength
580
if (count == 0 && _requestContext.
Response
.HasStarted)
620
var started = _requestContext.
Response
.HasStarted;
666
var chunked = _requestContext.
Response
.BoundaryType == BoundaryType.Chunked;
674
statusCode = _requestContext.
Response
.SendHeaders(ref allocator, null, asyncResult, flags, false);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (60)
Listener\AuthenticationOnExistingQueueTests.cs (9)
65
Assert.Equal(authType, context.
Response
.AuthenticationChallenges);
106
Assert.Equal(authType, context.
Response
.AuthenticationChallenges);
107
context.
Response
.StatusCode = 401;
131
Assert.Equal(authType, context.
Response
.AuthenticationChallenges);
132
context.
Response
.StatusCode = 401;
156
Assert.Equal(authType, context.
Response
.AuthenticationChallenges);
157
context.
Response
.StatusCode = 401;
163
Assert.Equal(authType, context.
Response
.AuthenticationChallenges);
186
Assert.Equal(authType, context.
Response
.AuthenticationChallenges);
Listener\RequestBodyTests.cs (2)
37
context.
Response
.ContentLength = read;
38
context.
Response
.Body.Write(input, 0, read);
Listener\ResponseBodyTests.cs (36)
31
Assert.Throws<InvalidOperationException>(() => context.
Response
.Body.Flush());
32
Assert.Throws<InvalidOperationException>(() => context.
Response
.Body.Write(new byte[10], 0, 10));
33
Assert.Throws<InvalidOperationException>(() => context.
Response
.Body.Flush());
37
context.
Response
.Body.Flush();
38
context.
Response
.Body.Write(new byte[10], 0, 10);
39
context.
Response
.Body.Flush();
62
context.
Response
.Body.Write(new byte[10], 0, 10);
63
context.
Response
.Body.Flush();
64
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10);
86
context.
Response
.Body.Write(new byte[10], 0, 0);
87
Assert.True(context.
Response
.HasStarted);
88
await context.
Response
.Body.WriteAsync(new byte[10], 0, 0);
112
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
113
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
134
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
135
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
157
var writeTask = context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
177
var writeTask = context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
197
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
200
var writeTask = context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
219
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
222
var writeTask = context.
Response
.Body.WriteAsync(new byte[10], 0, 10, cts.Token);
256
context.
Response
.Body.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
261
Assert.Throws<ObjectDisposedException>(() => context.
Response
.Body.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length));
292
await context.
Response
.Body.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
297
await Assert.ThrowsAsync<ObjectDisposedException>(() => context.
Response
.Body.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length));
325
context.
Response
.Body.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
352
await context.
Response
.Body.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
377
context.
Response
.Body.Write(new byte[10], 0, 10);
390
context.
Response
.Body.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
416
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10);
429
await context.
Response
.Body.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
455
context.
Response
.Body.Write(new byte[10], 0, 10);
466
context.
Response
.Body.Write(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
489
await context.
Response
.Body.WriteAsync(new byte[10], 0, 10);
500
await context.
Response
.Body.WriteAsync(Utilities.WriteBuffer, 0, Utilities.WriteBuffer.Length);
Listener\ResponseHeaderTests.cs (6)
138
context.
Response
.ContentLength = 20;
167
context.
Response
.StatusCode = 204; // No Content
190
context.
Response
.StatusCode = 204; // No Content
262
context.
Response
.Headers["Transfer-Encoding"] = new string[] { "chunked" };
264
await context.
Response
.Body.WriteAsync(responseBytes, 0, responseBytes.Length);
303
var responseHeaders = context.
Response
.Headers;
Listener\ServerOnExistingQueueTests.cs (4)
42
context.
Response
.ContentLength = 11;
43
await using (var writer = new StreamWriter(context.
Response
.Body))
63
context.
Response
.ContentLength = 11;
64
await using (var writer = new StreamWriter(context.
Response
.Body))
Listener\ServerTests.cs (3)
98
context.
Response
.Headers["Connection"] = "close";
100
context.
Response
.ContentLength = 11;
101
var writer = new StreamWriter(context.
Response
.Body);