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

Revert "db: use channel instead of semaphore + result variable"

Browse Source 
Using a sync. channel breaks kill-safety.

This reverts commit 8363db9258.
This commit is contained in:
Ryan Culpepper 2012-08-28 22:04:05 -04:00
parent d953bc27ba
commit ecb88ffd45
1 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
collects/db/private/generic/connect-util.rkt
View File

@ -38,18 +38,20 @@
(define/private (call* proc chan as-evt?)
(thread-resume mthread (current-thread))
(let* ([return-channel (make-channel)]
(let* ([result #f]
[sema (make-semaphore 0)]
[proc (lambda ()
(channel-put return-channel
(with-handlers ([(lambda (e) #t)
(lambda (e) (cons 'exn e))])
(cons 'values (call-with-values proc list)))))]
(set! result
(with-handlers ([(lambda (e) #t)
(lambda (e) (cons 'exn e))])
(cons 'values (call-with-values proc list))))
(semaphore-post sema))]
[handler
(lambda (_evt)
(let ([result (channel-get return-channel)])
(case (car result)
((values) (apply values (cdr result)))
((exn) (raise (cdr result))))))])
(semaphore-wait sema)
(case (car result)
((values) (apply values (cdr result)))
((exn) (raise (cdr result)))))])
(if as-evt?
(wrap-evt (channel-put-evt chan proc) handler)
(begin (channel-put chan proc)