[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
branch master updated: web: server: Ignore all client disconnects.
From: |
Mathieu Othacehe |
Subject: |
branch master updated: web: server: Ignore all client disconnects. |
Date: |
Tue, 04 Aug 2020 10:07:09 -0400 |
This is an automated email from the git hooks/post-receive script.
mothacehe pushed a commit to branch master
in repository guix-cuirass.
The following commit(s) were added to refs/heads/master by this push:
new 0abf192 web: server: Ignore all client disconnects.
0abf192 is described below
commit 0abf19203febf61c073280f7531cbeba15a458a5
Author: Mathieu Othacehe <othacehe@gnu.org>
AuthorDate: Tue Aug 4 16:02:46 2020 +0200
web: server: Ignore all client disconnects.
EPIPE and ECONNRESET errors are already ignored when thrown by "sendfile"
and
"put-bytevector" procedures. It turns out "peek-char" can also cause such
errors. So ignore such errors within the whole procedure.
* src/web/server/fiberized.scm (client-loop): Wrap the whole procedure
inside
"with-ignored-disconnects" instead of wrapping individually "sendfile" and
"put-bytevector" calls.
---
src/web/server/fiberized.scm | 113 ++++++++++++++++++++++---------------------
1 file changed, 57 insertions(+), 56 deletions(-)
diff --git a/src/web/server/fiberized.scm b/src/web/server/fiberized.scm
index 654636b..5df1d58 100644
--- a/src/web/server/fiberized.scm
+++ b/src/web/server/fiberized.scm
@@ -126,62 +126,63 @@ disconnection. Re-raise any other kind of exceptions."
;; ourselves.
(setsockopt client IPPROTO_TCP TCP_NODELAY 1)
(setvbuf client 'block 1024)
- (with-throw-handler #t
- (lambda ()
- (let ((response-channel (make-channel)))
- (let loop ()
- (cond
- ((eof-object? (lookahead-u8 client))
- (close-port client))
- (else
- (call-with-values
- (lambda ()
- (catch #t
- (lambda ()
- (let* ((request (read-request client))
- (body (read-request-body request)))
- (have-request response-channel request body)))
- (lambda (key . args)
- (display "While reading request:\n" (current-error-port))
- (print-exception (current-error-port) #f key args)
- (values (build-response #:version '(1 . 0) #:code 400
- #:headers '((content-length .
0)))
- #vu8()))))
- (lambda (response body)
- (match (assoc-ref (response-headers response) 'x-raw-file)
- ((? string? file)
- (non-blocking
- (call-with-input-file file
- (lambda (input)
- (let* ((size (stat:size (stat input)))
- (response (write-response
- (with-content-length response size)
- client))
- (output (response-port response)))
- (setsockopt client SOL_SOCKET SO_SNDBUF
- (* 128 1024))
- (if (file-port? output)
- (with-ignored-disconnects
- (sendfile output input size))
- (dump-port input output))
- (close-port output)
- (values))))))
- (#f (begin
- (write-response response client)
- (when body
- (with-ignored-disconnects
- (put-bytevector client body)))
- (force-output client))
- (if (and (keep-alive? response)
- (not (eof-object? (peek-char client))))
- (loop)
- (close-port client)))))))))))
- (lambda (k . args)
- (catch #t
- (lambda () (close-port client))
- (lambda (k . args)
- (display "While closing port:\n" (current-error-port))
- (print-exception (current-error-port) #f k args))))))
+ (with-ignored-disconnects
+ (with-throw-handler #t
+ (lambda ()
+ (let ((response-channel (make-channel)))
+ (let loop ()
+ (cond
+ ((eof-object? (lookahead-u8 client))
+ (close-port client))
+ (else
+ (call-with-values
+ (lambda ()
+ (catch #t
+ (lambda ()
+ (let* ((request (read-request client))
+ (body (read-request-body request)))
+ (have-request response-channel request body)))
+ (lambda (key . args)
+ (display "While reading request:\n"
+ (current-error-port))
+ (print-exception (current-error-port) #f key args)
+ (values (build-response #:version '(1 . 0) #:code 400
+ #:headers
+ '((content-length . 0)))
+ #vu8()))))
+ (lambda (response body)
+ (match (assoc-ref (response-headers response) 'x-raw-file)
+ ((? string? file)
+ (non-blocking
+ (call-with-input-file file
+ (lambda (input)
+ (let* ((size (stat:size (stat input)))
+ (response (write-response
+ (with-content-length response size)
+ client))
+ (output (response-port response)))
+ (setsockopt client SOL_SOCKET SO_SNDBUF
+ (* 128 1024))
+ (if (file-port? output)
+ (sendfile output input size)
+ (dump-port input output))
+ (close-port output)
+ (values))))))
+ (#f (begin
+ (write-response response client)
+ (when body
+ (put-bytevector client body))
+ (force-output client))
+ (if (and (keep-alive? response)
+ (not (eof-object? (peek-char client))))
+ (loop)
+ (close-port client)))))))))))
+ (lambda (k . args)
+ (catch #t
+ (lambda () (close-port client))
+ (lambda (k . args)
+ (display "While closing port:\n" (current-error-port))
+ (print-exception (current-error-port) #f k args)))))))
(define (socket-loop socket request-channel)
(define (have-request response-channel request body)
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- branch master updated: web: server: Ignore all client disconnects.,
Mathieu Othacehe <=