loader: fix double-close bugs

1 files changed, 3 insertions, 3 deletions

diff --git a/src/loader/loader.nim b/src/loader/loader.nim
index ada37648..71aca5ad 100644
--- a/src/loader/loader.nim
+++ b/src/loader/loader.nim
@@ -323,8 +323,9 @@ proc runFileLoader*(fd: cint, config: LoaderConfig) =
       if Error in event.events:
         assert event.fd != ctx.fd
         let handle = ctx.handleMap[event.fd]
-        if handle.fd == event.fd: # ostream died
-          unregWrite.add(handle)
+        if handle.fd == event.fd:
+          if unregWrite.len == 0 or unregWrite[^1] != handle: # ostream died
+            unregWrite.add(handle)
         else: # istream died
           unregRead.add(handle)
     for handle in unregRead:
@@ -341,7 +342,6 @@ proc runFileLoader*(fd: cint, config: LoaderConfig) =
       handle.ostream.close()
       handle.ostream = nil
       if handle.istream != nil:
-        handle.istream.close()
         ctx.handleMap.del(handle.istream.fd)
         ctx.selector.unregister(handle.istream.fd)
         handle.istream.close()