- (let ((s (udp-open-socket*)))
- (udp-bind! s #f this-port)
- (let loop ()
- (let-values (((n str) (udp-recv s 1024)))
- (print "Received " n " bytes over network: " str)
- (match (with-input-from-string str read)
- ((addr-str message ...)
- (apply send-message (cons (string->address addr-str) message)))
- (else
- (print "Warning: received badly formatted message string '" str "'"))))
- (loop))))))
-
-;; System interface
-
-(define system
- (make-actor (lambda (self . message)
- (match message
- (('shutdown)
- (print "## System actor received shutdown message.")
- (exit 0)
- 'done)
- (('println strings ...)
- (apply print strings)
- 'sleep)))))
-
-;; Testing
-
-
-(send-message system 'println "Hello, what is your name?")
-(send-message console
- (make-actor (lambda (self . message)
- (match message
- ((name)
- (send-message system 'println "Hello, " name "!")
- 'done)))))
-
-(thread-start!
- (lambda ()
- (thread-sleep! 120)
- (send-message system 'shutdown)))
-
-(print (uri->string system))
-
-(start-scheduler)
-(start-network-listener)
-(start-console)
+ (let loop ()
+ (let ((reader (next-reader)))
+ (##sys#thread-block-for-i/o! (current-thread) 0 #t)
+ (thread-yield!)
+ (send-message reader (read-line)))
+ (loop)))))