3 writes to _lineBuffer
System.Net.ServerSentEvents (3)
System\Net\ServerSentEvents\SseParser_1.cs (3)
105
_lineBuffer
= ArrayPool<byte>.Shared.Rent(DefaultArrayPoolRentSize);
185
_lineBuffer
= ArrayPool<byte>.Shared.Rent(DefaultArrayPoolRentSize);
307
GrowBuffer(ref
_lineBuffer
, _lineBuffer.Length * 2);
23 references to _lineBuffer
System.Net.ServerSentEvents (23)
System\Net\ServerSentEvents\SseParser_1.cs (23)
54
/// <summary>The starting offset of valid data in <see cref="
_lineBuffer
"/>.</summary>
56
/// <summary>The length of valid data in <see cref="
_lineBuffer
"/>, starting from <see cref="_lineOffset"/>.</summary>
58
/// <summary>The index in <see cref="
_lineBuffer
"/> where a newline ('\r', '\n', or "\r\n") was found.</summary>
60
/// <summary>The index in <see cref="
_lineBuffer
"/> of characters already checked for newlines.</summary>
122
_newlineIndex =
_lineBuffer
.AsSpan(searchOffset, searchLength).IndexOfAny(CR, LF);
127
if (
_lineBuffer
[_newlineIndex] is LF || // the newline is LF
165
ArrayPool<byte>.Shared.Return(
_lineBuffer
);
202
_newlineIndex =
_lineBuffer
.AsSpan(searchOffset, searchLength).IndexOfAny(CR, LF);
207
if (
_lineBuffer
[_newlineIndex] is LF || // newline is LF
245
ArrayPool<byte>.Shared.Return(
_lineBuffer
);
269
Debug.Assert(searchOffset <=
_lineBuffer
.Length, $"{searchOffset}, {
_lineBuffer
.Length}");
278
return
_lineBuffer
.AsSpan(_newlineIndex, _lineLength - (_newlineIndex - _lineOffset)).StartsWith(CRLF) ? 2 : 1;
294
if (_lineOffset + _lineLength ==
_lineBuffer
.Length)
298
_lineBuffer
.AsSpan(_lineOffset, _lineLength).CopyTo(
_lineBuffer
);
305
else if (_lineLength ==
_lineBuffer
.Length)
307
GrowBuffer(ref _lineBuffer,
_lineBuffer
.Length * 2);
318
ReadOnlySpan<byte> line =
_lineBuffer
.AsSpan(_lineOffset, _newlineIndex - _lineOffset);
376
ReadOnlySpan<byte> remainder =
_lineBuffer
.AsSpan(_newlineIndex + newlineLength, _lineLength - line.Length - newlineLength);
480
_lineBuffer
.AsSpan(offset));
504
int bytesRead = await _stream.ReadAsync(
_lineBuffer
.AsMemory(offset), cancellationToken).ConfigureAwait(false);
527
if (
_lineBuffer
.AsSpan(0, _lineLength).StartsWith(Utf8Bom))