mirrors/arsd
1
0
Fork 0
mirror of https://github.com/adamdruppe/arsd.git synced 2025-04-27 22:00:13 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

lol 32 bit

Browse source
This commit is contained in:
Adam D. Ruppe 2025-02-22 12:08:56 -05:00
parent 2a065c3a27
commit 269b535196
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
core.d
View file

@ -8299,15 +8299,15 @@ class LoggerOf(T, size_t bufferSize = 16) {
auto startPos = readBufferPosition % bufferSize; auto startPos = readBufferPosition % bufferSize;
auto endPos = us.writeBufferPosition % bufferSize; auto endPos = us.writeBufferPosition % bufferSize;
if(endPos > startPos) { if(endPos > startPos) {
buffer[0 .. n] = us.ring[startPos .. endPos]; buffer[0 .. cast(size_t) n] = us.ring[cast(size_t) startPos .. cast(size_t) endPos];
} else { } else {
auto ourSplit = us.ring.length - startPos; auto ourSplit = us.ring.length - startPos;
buffer[0 .. ourSplit] = us.ring[startPos .. $]; buffer[0 .. cast(size_t) ourSplit] = us.ring[cast(size_t) startPos .. $];
buffer[ourSplit .. ourSplit + endPos] = us.ring[0 .. endPos]; buffer[cast(size_t) ourSplit .. cast(size_t) (ourSplit + endPos)] = us.ring[0 .. cast(size_t) endPos];
} }
readBufferPosition = us.writeBufferPosition; readBufferPosition = us.writeBufferPosition;
} }
foreach(item; buffer[0 .. n]) { foreach(item; buffer[0 .. cast(size_t) n]) {
if(!connected) if(!connected)
break; break;
dg(item, missedMessages); dg(item, missedMessages);