Tcp monitor per

JuliaLang/MbedTLS.jl#145 (comment)
JuliaWeb · Apr 17, 2018 · 7dd1d92 · 7dd1d92
1 parent 597c0c7
commit 7dd1d92
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/ConnectionPool.jl b/src/ConnectionPool.jl
@@ -453,6 +453,7 @@ function getconnection(::Type{Transaction{T}},
             busy = findall(T, host, port, pipeline_limit)
             if length(busy) < connection_limit
                 io = getconnection(T, host, port; kw...)
+                @schedule tcp_monitor(io)
                 c = Connection(host, port,
                                pipeline_limit, idle_timeout,
                                io)
@@ -488,6 +489,16 @@ struct ConnectTimeout <: Exception
     port
 end
 
+function tcp_monitor(io)
+    tcp = tcpsocket(io)
+    while isopen(io)
+        Base.start_reading(tcp)
+        wait(tcp.readnotify)
+        yield()
+    end
+    close(tcp)
+end
+
 function getconnection(::Type{TCPSocket},
                        host::AbstractString,
                        port::AbstractString;