sum durations

Author: quinnj

src/clientlayers/ConnectionRequest.jl

@@ -84,8 +84,8 @@ function connectionlayer(handler)
             req.context[:connect_errors] = get(req.context, :connect_errors, 0) + 1
             throw(ConnectError(string(url), e))
         finally
-            req.context[:connect_duration_ms] = metrics.connect_duration_ms[]
-            req.context[:ssl_connect_duration_ms] = metrics.ssl_connect_duration_ms[]
+            req.context[:connect_duration_ms] = get(req.context, :connect_duration_ms, 0.0) +  metrics.connect_duration_ms[]
+            req.context[:ssl_connect_duration_ms] = get(req.context, :ssl_connect_duration_ms, 0.0) + metrics.ssl_connect_duration_ms[]
         end
 
         shouldreuse = !(target_url.scheme in ("ws", "wss"))

src/clientlayers/StreamRequest.jl

@@ -47,15 +47,15 @@ function _streamlayer(stream::Stream; iofunction=nothing, decompress::Union{Noth
                     @debugv 2 "client closewrite"
                     closewrite(stream)
                 finally
-                    req.context[:write_duration_ms] = (time() - write_start) * 1000
+                    req.context[:write_duration_ms] = get(req.context, :write_duration_ms, 0.0) + ((time() - write_start) * 1000)
                 end
                 read_start = time()
                 @async try
                     @debugv 2 "client startread"
                     startread(stream)
                     readbody(stream, response, decompress)
                 finally
-                    req.context[:read_duration_ms] = (time() - read_start) * 1000
+                    req.context[:read_duration_ms] = get(req.context, :read_duration_ms, 0.0) + ((time() - read_start) * 1000)
                 end
             else
                 iofunction(stream)