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

Places: fix asynchronous receive

Browse Source
This commit is contained in:
Kevin Tew 2010-09-18 09:35:51 -06:00
parent 688b08408f
commit faa0c86f50
2 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
collects/tests/racket/place-channel.rktl
View File

@ -34,7 +34,8 @@
(cons (car x) 'b) (cons (car x) 'b)
(list (car x) 'b (cadr x)) (list (car x) 'b (cadr x))
(vector (vector-ref x 0) 'b (vector-ref x 1)) (vector (vector-ref x 0) 'b (vector-ref x 1))
#s((abuilding 1 building 2) 6 'utah 'no)) #s((abuilding 1 building 2) 6 'utah 'no)
`(,x))
(define pc1 (place-channel-recv ch)) (define pc1 (place-channel-recv ch))
(pcrss pc1 (string-append x "-ok")) (pcrss pc1 (string-append x "-ok"))
@ -46,6 +47,9 @@
(pcrss ch (begin (flvector-set! x 2 6.0) "Ready2")) (pcrss ch (begin (flvector-set! x 2 6.0) "Ready2"))
(pcrss ch (begin (bytes-set! x 2 67) "Ready3")) (pcrss ch (begin (bytes-set! x 2 67) "Ready3"))
(pcrss ch (begin (bytes-set! x 2 67) "Ready4")) (pcrss ch (begin (bytes-set! x 2 67) "Ready4"))
(define pc5 (place-channel-recv ch))
(place-channel-send pc5 "Ready5")
) )
) )
END END
@ -72,7 +76,8 @@ END
((cons 'a 'a) (cons 'a 'b)) ((cons 'a 'a) (cons 'a 'b))
((list 'a 'a) (list 'a 'b 'a)) ((list 'a 'a) (list 'a 'b 'a))
(#(a a) #(a b a)) (#(a a) #(a b a))
(h1 #s((abuilding 1 building 2) 6 'utah 'no))) (h1 #s((abuilding 1 building 2) 6 'utah 'no))
('(printf "Hello") '((printf "Hello"))))
(define-values (pc1 pc2) (place-channel)) (define-values (pc1 pc2) (place-channel))
(place-channel-send pl pc2) (place-channel-send pl pc2)
@ -94,6 +99,9 @@ END
(test "Ready4" place-channel-send/recv pl b2) (test "Ready4" place-channel-send/recv pl b2)
(test 67 bytes-ref b2 2) (test 67 bytes-ref b2 2)
(define-values (pc5 pc6) (place-channel))
(place-channel-send pl pc5)
(test "Ready5" sync (handle-evt pc6 (lambda (p) (place-channel-recv p))))
(place-wait pl) (place-wait pl)
) )

3
src/racket/src/places.c
View File

@ -1455,6 +1455,9 @@ static int scheme_place_async_ch_ready(Scheme_Place_Async_Channel *ch) {
int ready = 0; int ready = 0;
mzrt_mutex_lock(ch->lock); mzrt_mutex_lock(ch->lock);
{ {
void *signaldescr;
signaldescr = scheme_get_signal_handle();
ch->wakeup_signal = signaldescr;
if (ch->count > 0) ready = 1; if (ch->count > 0) ready = 1;
} }
mzrt_mutex_unlock(ch->lock); mzrt_mutex_unlock(ch->lock);