daniel/Ryujinx
1
0
Fork 0
mirror of https://github.com/Ryujinx/Ryujinx.git synced 2024-12-23 08:21:21 -08:00
Code Issues Packages Projects Releases Wiki Activity

ConcurrentBitmap: Use Interlocked Or/And (#3937)

Browse Source
This commit is contained in:
merry 2022-11-29 13:47:57 +00:00 committed by GitHub
parent d41c95dcff
commit a5c2aead67
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 12 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
Ryujinx.Memory/Tracking/ConcurrentBitmap.cs
View File

@ -41,7 +41,7 @@ namespace Ryujinx.Memory.Tracking
{ {
for (int i = 0; i < Masks.Length; i++) for (int i = 0; i < Masks.Length; i++)
{ {
if (Volatile.Read(ref Masks[i]) != 0) if (Interlocked.Read(ref Masks[i]) != 0)
{ {
return true; return true;
} }
@ -62,7 +62,7 @@ namespace Ryujinx.Memory.Tracking
long wordMask = 1L << wordBit; long wordMask = 1L << wordBit;
return (Volatile.Read(ref Masks[wordIndex]) & wordMask) != 0; return (Interlocked.Read(ref Masks[wordIndex]) & wordMask) != 0;
} }
/// <summary> /// <summary>
@ -86,7 +86,7 @@ namespace Ryujinx.Memory.Tracking
int endBit = end & IntMask; int endBit = end & IntMask;
long endMask = (long)(ulong.MaxValue >> (IntMask - endBit)); long endMask = (long)(ulong.MaxValue >> (IntMask - endBit));
long startValue = Volatile.Read(ref Masks[startIndex]); long startValue = Interlocked.Read(ref Masks[startIndex]);
if (startIndex == endIndex) if (startIndex == endIndex)
{ {
@ -100,13 +100,13 @@ namespace Ryujinx.Memory.Tracking
for (int i = startIndex + 1; i < endIndex; i++) for (int i = startIndex + 1; i < endIndex; i++)
{ {
if (Volatile.Read(ref Masks[i]) != 0) if (Interlocked.Read(ref Masks[i]) != 0)
{ {
return true; return true;
} }
} }
long endValue = Volatile.Read(ref Masks[endIndex]); long endValue = Interlocked.Read(ref Masks[endIndex]);
if ((endValue & endMask) != 0) if ((endValue & endMask) != 0)
{ {
@ -128,24 +128,15 @@ namespace Ryujinx.Memory.Tracking
long wordMask = 1L << wordBit; long wordMask = 1L << wordBit;
long existing;
long newValue;
do
{
existing = Volatile.Read(ref Masks[wordIndex]);
if (value) if (value)
{ {
newValue = existing | wordMask; Interlocked.Or(ref Masks[wordIndex], wordMask);
} }
else else
{ {
newValue = existing & ~wordMask; Interlocked.And(ref Masks[wordIndex], ~wordMask);
} }
} }
while (Interlocked.CompareExchange(ref Masks[wordIndex], newValue, existing) != existing);
}
/// <summary> /// <summary>
/// Clear the bitmap entirely, setting all bits to 0. /// Clear the bitmap entirely, setting all bits to 0.
@ -154,7 +145,7 @@ namespace Ryujinx.Memory.Tracking
{ {
for (int i = 0; i < Masks.Length; i++) for (int i = 0; i < Masks.Length; i++)
{ {
Volatile.Write(ref Masks[i], 0); Interlocked.Exchange(ref Masks[i], 0);
} }
} }
} }