(define local-queue (make-fifo))
(define (send-message address . message)
- (print "send-message: Sending " message " to " address)
(apply (if (address-local? address)
send-local-message
send-network-message)
(uri (address->uri address))
(packet (with-output-to-string
(lambda ()
- (print (cons address message))))))
+ (write (cons address message))))))
(udp-bind! s #f 0)
(udp-connect! s
(uri-host uri)
(udp-bind! s #f sam-port)
(let loop ()
(let-values (((n str) (udp-recv s 1024)))
- (print "network-listener: Received " n " bytes over network: " str)
(match (with-input-from-string str read)
((address message ...)
(apply send-message (cons address message)))
(define (start-console)
(let loop ()
(let ((reader (next-reader)))
- (print "console: received next reader: " reader)
(##sys#thread-block-for-i/o! (current-thread) 0 #t)
(thread-yield!)
(send-message reader (read-line)))