summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRandom Hacker <random_hacker@xapek.org>2012-03-08 11:28:44 +0100
committerRandom Hacker <random_hacker@xapek.org>2012-03-08 11:28:44 +0100
commita84447cf9c06c2813df831b3fde105c45d02727c (patch)
treec2a092128d7a69d01b859960e7dbadfe583fb652
parent7b1045693d28f999d86b78a8506f2dbeaf5de9d7 (diff)
downloadebus-alt-a84447cf9c06c2813df831b3fde105c45d02727c.tar.gz
ebus-alt-a84447cf9c06c2813df831b3fde105c45d02727c.zip
ebus-racket: fix error handling in inserter
-rwxr-xr-xebus-racket/inserter-pq.rkt3
-rwxr-xr-xebus-racket/inserter.rkt3
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))