debian-packages/eventcore
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fix IOMode.immediate for Windows sockets to guarantee calling the callback.

Browse source
This commit is contained in:
Sönke Ludwig 2020-03-15 20:24:55 +01:00
parent e8ed523c08
commit 00b8607fc1
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
source/eventcore/drivers/winapi/sockets.d
View file

@ -552,8 +552,11 @@ final class WinAPIEventDriverSockets : EventDriverSockets {
} }
} }
if (mode == IOMode.immediate) if (mode == IOMode.immediate) {
() @trusted { CancelIoEx(cast(HANDLE)cast(SOCKET)socket, cast(LPOVERLAPPED)&slot.read.overlapped); } (); () @trusted { CancelIoEx(cast(HANDLE)cast(SOCKET)socket, cast(LPOVERLAPPED)&slot.read.overlapped); } ();
on_read_finish(socket, IOStatus.wouldBlock, 0, null);
return;
}
slot.read.callback = on_read_finish; slot.read.callback = on_read_finish;
addRef(socket); addRef(socket);
@ -646,8 +649,11 @@ final class WinAPIEventDriverSockets : EventDriverSockets {
} }
} }
if (mode == IOMode.immediate) if (mode == IOMode.immediate) {
() @trusted { CancelIoEx(cast(HANDLE)cast(SOCKET)socket, cast(LPOVERLAPPED)&slot.write.overlapped); } (); () @trusted { CancelIoEx(cast(HANDLE)cast(SOCKET)socket, cast(LPOVERLAPPED)&slot.write.overlapped); } ();
on_write_finish(socket, IOStatus.wouldBlock, 0, null);
return;
}
slot.write.callback = on_write_finish; slot.write.callback = on_write_finish;
addRef(socket); addRef(socket);