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

Merge pull request #62 from vibe-d/fix_winapi_watcher_shutdown

Browse source 
Fix cleanup code for directory watchers in the WinAPI driver.
This commit is contained in:
Sönke Ludwig 2018-03-14 19:11:53 +01:00 committed by GitHub
parent 574de0760d 53bb8eeead
commit 0044946413
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
source/eventcore/drivers/winapi/watchers.d
View file

@ -82,7 +82,7 @@ final class WinAPIEventDriverWatchers : EventDriverWatchers {
catch (Exception e) assert(false, "Freeing directory watcher buffer failed."); catch (Exception e) assert(false, "Freeing directory watcher buffer failed.");
} (); } ();
slot.watcher.buffer = null; slot.watcher.buffer = null;
core.discardEvents(&slot.watcher.overlapped, &slot.file.write.overlapped); core.discardEvents(&slot.watcher.overlapped);
core.freeSlot(handle); core.freeSlot(handle);
})) }))
{ {
@ -159,10 +159,13 @@ final class WinAPIEventDriverWatchers : EventDriverWatchers {
catch (Exception e) {} // FIXME: can happen if the base path is relative and the CWD has changed catch (Exception e) {} // FIXME: can happen if the base path is relative and the CWD has changed
if (ch.kind != FileChangeKind.modified || !ch.isDirectory) if (ch.kind != FileChangeKind.modified || !ch.isDirectory)
slot.callback(id, ch); slot.callback(id, ch);
if (fni.NextEntryOffset == 0) break; if (fni.NextEntryOffset == 0 || !slot.callback) break;
} }
if (slot.callback)
triggerRead(handle, *slot); triggerRead(handle, *slot);
else if (gslot.refCount == 1)
doReleaseRef(handle);
} }
private static bool triggerRead(HANDLE handle, ref WatcherSlot slot) private static bool triggerRead(HANDLE handle, ref WatcherSlot slot)