-
Notifications
You must be signed in to change notification settings - Fork 4
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
132ffa4
commit e7940f3
Showing
13 changed files
with
197 additions
and
68 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
60 changes: 60 additions & 0 deletions
60
tcp/Sisk.ManagedHttpListener/HighPerformance/ArrayPoolExtensions.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,60 @@ | ||
| // The Sisk Framework source code | ||
| // Copyright (c) 2024- PROJECT PRINCIPIUM and all Sisk contributors | ||
| // | ||
| // The code below is licensed under the MIT license as | ||
| // of the date of its publication, available at | ||
| // | ||
| // File name: ArrayPoolExtensions.cs | ||
| // Repository: https://github.com/sisk-http/core | ||
|
|
||
| using System; | ||
| using System.Buffers; | ||
| using System.Collections.Generic; | ||
| using System.Diagnostics.CodeAnalysis; | ||
| using System.Linq; | ||
| using System.Text; | ||
| using System.Threading.Tasks; | ||
|
|
||
| namespace Sisk.ManagedHttpListener.HighPerformance; | ||
| internal static class ArrayPoolExtensions { | ||
|
|
||
| // forked from https://github.com/CommunityToolkit/dotnet/blob/main/src/CommunityToolkit.HighPerformance/Extensions/ArrayPoolExtensions.cs | ||
|
|
||
| /// <summary> | ||
| /// Changes the number of elements of a rented one-dimensional array to the specified new size. | ||
| /// </summary> | ||
| /// <typeparam name="T">The type of items into the target array to resize.</typeparam> | ||
| /// <param name="pool">The target <see cref="ArrayPool{T}"/> instance to use to resize the array.</param> | ||
| /// <param name="array">The rented <typeparamref name="T"/> array to resize, or <see langword="null"/> to create a new array.</param> | ||
| /// <param name="newSize">The size of the new array.</param> | ||
| /// <param name="clearArray">Indicates whether the contents of the array should be cleared before reuse.</param> | ||
| /// <exception cref="ArgumentOutOfRangeException">Thrown when <paramref name="newSize"/> is less than 0.</exception> | ||
| /// <remarks>When this method returns, the caller must not use any references to the old array anymore.</remarks> | ||
| public static void Resize<T> ( this ArrayPool<T> pool, [NotNull] ref T []? array, int newSize, bool clearArray = false ) { | ||
| // If the old array is null, just create a new one with the requested size | ||
| if (array is null) { | ||
| array = pool.Rent ( newSize ); | ||
|
|
||
| return; | ||
| } | ||
|
|
||
| // If the new size is the same as the current size, do nothing | ||
| if (array.Length == newSize) { | ||
| return; | ||
| } | ||
|
|
||
| // Rent a new array with the specified size, and copy as many items from the current array | ||
| // as possible to the new array. This mirrors the behavior of the Array.Resize API from | ||
| // the BCL: if the new size is greater than the length of the current array, copy all the | ||
| // items from the original array into the new one. Otherwise, copy as many items as possible, | ||
| // until the new array is completely filled, and ignore the remaining items in the first array. | ||
| T [] newArray = pool.Rent ( newSize ); | ||
| int itemsToCopy = Math.Min ( array.Length, newSize ); | ||
|
|
||
| Array.Copy ( array, 0, newArray, 0, itemsToCopy ); | ||
|
|
||
| pool.Return ( array, clearArray ); | ||
|
|
||
| array = newArray; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,39 @@ | ||
| // The Sisk Framework source code | ||
| // Copyright (c) 2024- PROJECT PRINCIPIUM and all Sisk contributors | ||
| // | ||
| // The code below is licensed under the MIT license as | ||
| // of the date of its publication, available at | ||
| // | ||
| // File name: HttpHeader.cs | ||
| // Repository: https://github.com/sisk-http/core | ||
|
|
||
| using System.Text; | ||
|
|
||
| namespace Sisk.ManagedHttpListener.HttpSerializer; | ||
|
|
||
| public readonly struct HttpHeader { | ||
| internal readonly ReadOnlyMemory<byte> NameBytes; | ||
| internal readonly ReadOnlyMemory<byte> ValueBytes; | ||
|
|
||
| public HttpHeader ( ReadOnlyMemory<byte> nameBytes, ReadOnlyMemory<byte> valueBytes ) { | ||
| this.NameBytes = nameBytes; | ||
| this.ValueBytes = valueBytes; | ||
| } | ||
|
|
||
| public HttpHeader ( string name, string value ) { | ||
| this.NameBytes = Encoding.UTF8.GetBytes ( name ); | ||
| this.ValueBytes = Encoding.UTF8.GetBytes ( value ); | ||
| } | ||
|
|
||
| public string Name { | ||
| get { | ||
| return Encoding.UTF8.GetString ( this.NameBytes.Span ); | ||
| } | ||
| } | ||
|
|
||
| public string Value { | ||
| get { | ||
| return Encoding.UTF8.GetString ( this.ValueBytes.Span ); | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.