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

Update change log.

Browse source
This commit is contained in:
Sönke Ludwig 2020-03-18 15:32:26 +01:00
parent 3e649f0024
commit cef4885a63
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
source/vibe/core/file.d
View file

@ -13,6 +13,7 @@ import vibe.core.internal.release;
import vibe.core.log; import vibe.core.log;
import vibe.core.path; import vibe.core.path;
import vibe.core.stream; import vibe.core.stream;
import vibe.core.task : Task, TaskSettings;
import vibe.internal.async : asyncAwait, asyncAwaitUninterruptible; import vibe.internal.async : asyncAwait, asyncAwaitUninterruptible;
import core.stdc.stdio; import core.stdc.stdio;
@ -357,7 +358,9 @@ void listDirectory(string path, scope bool delegate(FileInfo info) @safe del)
} }
auto ch = createChannel!S(); auto ch = createChannel!S();
runWorkerTaskH((string path, Channel!S ch) nothrow { TaskSettings ts;
ts.priority = 10 * Task.basePriority;
runWorkerTaskH(ioTaskSettings, (string path, Channel!S ch) nothrow {
scope (exit) ch.close(); scope (exit) ch.close();
try { try {
foreach (DirEntry ent; dirEntries(path, SpanMode.shallow)) { foreach (DirEntry ent; dirEntries(path, SpanMode.shallow)) {
@ -895,7 +898,7 @@ private auto performInWorker(C, ARGS...)(C callable, auto ref ARGS args)
alias RET = typeof(callable(args)); alias RET = typeof(callable(args));
shared(RET) ret; shared(RET) ret;
runWorkerTask((shared(RET)* r, Tid caller, C c, ref ARGS a) nothrow { runWorkerTask(ioTaskSettings, (shared(RET)* r, Tid caller, C c, ref ARGS a) nothrow {
*() @trusted { return cast(RET*)r; } () = c(a); *() @trusted { return cast(RET*)r; } () = c(a);
// Just as a precaution, because ManualEvent is not well defined in // Just as a precaution, because ManualEvent is not well defined in
// terms of fence semantics // terms of fence semantics
@ -908,3 +911,5 @@ private auto performInWorker(C, ARGS...)(C callable, auto ref ARGS args)
return ret; return ret;
} }
} }
private immutable TaskSettings ioTaskSettings = { priority: 20 * Task.basePriority };