diff options
| -rwxr-xr-x | ebus-racket/inserter-pq.rkt | 3 | ||||
| -rwxr-xr-x | ebus-racket/inserter.rkt | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/ebus-racket/inserter-pq.rkt b/ebus-racket/inserter-pq.rkt index 7ed87d9..85073f4 100755 --- a/ebus-racket/inserter-pq.rkt +++ b/ebus-racket/inserter-pq.rkt @@ -28,7 +28,8 @@ (lambda () (let loop () (with-handlers ([exn:fail? (lambda (exn) - (log-message logger 'error (format "Failed to parse paket: ~a" exn) #t))]) + (log-message logger 'error (format "Failed to parse paket: ~a" exn) #t) + (loop) )]) (let ([fields (layer7-read-ebus (current-input-port))]) (when (not (or (void? fields) (eof-object? fields))) (handle-fields fields)) diff --git a/ebus-racket/inserter.rkt b/ebus-racket/inserter.rkt index ab90911..b07207d 100755 --- a/ebus-racket/inserter.rkt +++ b/ebus-racket/inserter.rkt @@ -28,7 +28,8 @@ (lambda () (let loop () (with-handlers ([exn:fail? (lambda (exn) - (log-message logger 'error (format "Failed to parse paket: ~a" exn) #t))]) + (log-message logger 'error (format "Failed to parse paket: ~a" exn) #t) + (loop))]) (let ([fields (layer7-read-ebus (current-input-port))]) (when (not (or (void? fields) (eof-object? fields))) (handle-fields fields)) |