suzanne.soy/racket
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

protect against errors in chunking or gunziping... without this there can be hangs

Browse Source
This commit is contained in:
Jay McCarthy 2014-05-08 09:46:45 -06:00
parent 718cbd4c41
commit fc8075245a
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
racket/collects/net/http-client.rkt
View File

@ -192,9 +192,13 @@
(loop bs))))) (loop bs)))))
(define-values (in out) (make-pipe PIPE-SIZE)) (define-values (in out) (make-pipe PIPE-SIZE))
(define chunk-t
(thread (thread
(λ () (λ ()
(http-pipe-chunk (http-conn-from hc) out) (http-pipe-chunk (http-conn-from hc) out))))
(thread
(λ ()
(thread-wait chunk-t)
(when close? (when close?
(http-conn-close! hc)) (http-conn-close! hc))
(close-output-port out))) (close-output-port out)))
@ -237,9 +241,13 @@
(cond (cond
[(and (memq 'gzip decodes) (regexp-member #rx#"^(?i:Content-Encoding: +gzip)$" headers)) [(and (memq 'gzip decodes) (regexp-member #rx#"^(?i:Content-Encoding: +gzip)$" headers))
(define-values (in out) (make-pipe PIPE-SIZE)) (define-values (in out) (make-pipe PIPE-SIZE))
(define gunzip-t
(thread (thread
(λ () (λ ()
(gunzip-through-ports raw-response-port out) (gunzip-through-ports raw-response-port out))))
(thread
(λ ()
(thread-wait gunzip-t)
(close-output-port out))) (close-output-port out)))
in] in]
[else [else