...
original commit: 05972f6cc305a5022e6514e47a2eee4aaf947ae5
This commit is contained in:
parent
51fece2bc9
commit
2924bf0d2d
|
@ -1,21 +1,20 @@
|
|||
(printf "creating thread~n")
|
||||
(printf "mred:creating thread~n")
|
||||
(thread
|
||||
(letrec ([restart
|
||||
(lambda ()
|
||||
(printf "initializing loop~n")
|
||||
(let*-values ([(listener) (tcp-listen (require-library "receive-sexps-port.ss" "tests" "framework"))]
|
||||
[(in out) (tcp-accept listener)]
|
||||
(printf "mred:initializing loop~n")
|
||||
(let*-values ([(in out) (tcp-connect "localhost" (load-relative "receive-sexps-port.ss"))]
|
||||
[(continue) (make-semaphore 0)]
|
||||
[(error) #f]
|
||||
[(answer) (void)])
|
||||
(printf "mred:made connection~n")
|
||||
(let loop ()
|
||||
(let ([sexp (read in)])
|
||||
(if (eof-object? sexp)
|
||||
(begin
|
||||
(close-input-port in)
|
||||
(close-output-port out)
|
||||
(tcp-close listener)
|
||||
(restart))
|
||||
(exit))
|
||||
(begin
|
||||
(queue-callback (lambda ()
|
||||
(set! error #f)
|
||||
|
|
Loading…
Reference in New Issue
Block a user