am-wd/common
1
0
Fork 0
Code Actions Activity

Small async fixes for AsyncQueue and over-/underflow for IPAddress

Browse Source
This commit is contained in:
Andreas Müller
2022-08-17 23:38:51 +02:00
parent 18c9bb7cee
commit c4870ad799
5 changed files with 105 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
AMWD.Common/Extensions/IPAddressExtensions.cs
View File

@@ -18,6 +18,9 @@
{
bytes[bytePos] = 0;
bytePos--;
if (bytePos < 0)
return new IPAddress(bytes);
}
bytes[bytePos]++;
@@ -37,6 +40,9 @@
{
bytes[bytePos] = byte.MaxValue;
bytePos--;
if (bytePos < 0)
return new IPAddress(bytes);
}
bytes[bytePos]--;

8
AMWD.Common/Utilities/AsyncQueue.cs
View File

@@ -220,7 +220,7 @@ namespace System.Collections.Generic
internalDequeueTcs = ResetToken(ref dequeueTcs);
}
await WaitAsync(internalDequeueTcs, cancellationToken);
await WaitAsync(internalDequeueTcs, cancellationToken).ConfigureAwait(false);
}
}
@@ -251,7 +251,7 @@ namespace System.Collections.Generic
internalDequeueTcs = ResetToken(ref dequeueTcs);
}
await WaitAsync(internalDequeueTcs, cancellationToken);
await WaitAsync(internalDequeueTcs, cancellationToken).ConfigureAwait(false);
}
}
@@ -273,7 +273,7 @@ namespace System.Collections.Generic
internalDequeueTcs = ResetToken(ref dequeueTcs);
}
await WaitAsync(internalDequeueTcs, cancellationToken);
await WaitAsync(internalDequeueTcs, cancellationToken).ConfigureAwait(false);
}
}
@@ -293,7 +293,7 @@ namespace System.Collections.Generic
internalAvailableTcs = ResetToken(ref availableTcs);
}
await WaitAsync(internalAvailableTcs, cancellationToken);
await WaitAsync(internalAvailableTcs, cancellationToken).ConfigureAwait(false);
}
#endregion Async implementation