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

Merge pull request #167 from vibe-d/threadedfile_tuning

Browse source 
Threadedfile tuning
This commit is contained in:
Sönke Ludwig 2021-01-12 14:42:27 +01:00 committed by GitHub
parent 5e060d2d0b 7c2fd87308
commit 21916f3022
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
source/eventcore/drivers/threadedfile.d
View file

@ -224,6 +224,26 @@ final class ThreadedFileEventDriver(Events : EventDriverEvents) : EventDriverFil
return; return;
} }
on_finish(file, IOStatus.ok, 0); on_finish(file, IOStatus.ok, 0);
} else version (Windows) {
import core.sys.windows.windows : FILE_BEGIN, HANDLE, INVALID_HANDLE_VALUE,
LARGE_INTEGER, SetFilePointerEx, SetEndOfFile;
import core.stdc.stdio : _get_osfhandle;
auto h = () @trusted { return cast(HANDLE)_get_osfhandle(cast(int)file); } ();
if (h == INVALID_HANDLE_VALUE) {
on_finish(file, IOStatus.error, 0);
return;
}
LARGE_INTEGER ls = { QuadPart: size };
if (!() @trusted { return SetFilePointerEx(h, ls, null, FILE_BEGIN); } ()) {
on_finish(file, IOStatus.error, 0);
return;
}
if (!() @trusted { return SetEndOfFile(h); } ()) {
on_finish(file, IOStatus.error, 0);
return;
}
on_finish(file, IOStatus.ok, 0);
} else { } else {
on_finish(file, IOStatus.error, 0); on_finish(file, IOStatus.error, 0);
} }
@ -379,7 +399,7 @@ log("trigger event");
if (bytes.length == 0) safeAtomicStore(f.ioStatus, IOStatus.ok); if (bytes.length == 0) safeAtomicStore(f.ioStatus, IOStatus.ok);
while (bytes.length > 0) { while (bytes.length > 0) {
auto sz = min(bytes.length, 4096); auto sz = min(bytes.length, 512*1024);
auto ret = () @trusted { return mixin("."~op)(cast(int)file, bytes.ptr, cast(uint)sz); } (); auto ret = () @trusted { return mixin("."~op)(cast(int)file, bytes.ptr, cast(uint)sz); } ();
if (ret != sz) { if (ret != sz) {
safeAtomicStore(f.ioStatus, IOStatus.error); safeAtomicStore(f.ioStatus, IOStatus.error);