Fix windows ECONNRESET bug

Don't close sockets eagerly. Let GC handle it.

src/Malt.jl

@@ -91,8 +91,6 @@ function _recv(socket)
         response.result
     catch e
         rethrow(e)
-    finally
-        close(socket)
     end
 end
 
@@ -225,7 +223,6 @@ function worker_channel(w::Worker, expr)::Channel
         while isopen(channel) && isopen(s)
             put!(channel, deserialize(s))
         end
-        close(s)
         return
     end)
 end

src/worker.jl

@@ -58,16 +58,14 @@ function handle(::Val{:call}, socket, msg)
     catch e
         # @debug("Exception!", e)
         serialize(socket, (status=:err, result=e))
-    finally
-        close(socket)
     end
 end
 
 function handle(::Val{:remote_do}, socket, msg)
     try
         msg.f(msg.args...; msg.kwargs...)
-    finally
-        close(socket)
+    catch e
+        nothing
     end
 end
 
@@ -76,7 +74,7 @@ function handle(::Val{:channel}, socket, msg)
     while isopen(channel) && isopen(socket)
         serialize(socket, take!(channel))
     end
-    isopen(socket) && close(socket)
+
     isopen(channel) && close(channel)
     return
 end

test/runtests.jl

@@ -13,7 +13,7 @@ using Test
 
     # Terminating workers takes about 0.5s
     m.stop(w)
-    sleep(1)
+    sleep(2)
     @test m.isrunning(w) === false
 end
 
@@ -74,7 +74,7 @@ end
     @test m.isrunning(w) === true
 
     m.stop(w)
-    sleep(1)
+    sleep(2)
     @test m.isrunning(w) === false
 end