+(define (next-reader)
+ (let ((res #f))
+ (mutex-lock! reader-available-mutex #f #f)
+ (mutex-lock! reader-queue-mutex)
+ (set! res (fifo-pop reader-queue))
+ (if (not (fifo-empty? reader-queue))
+ (mutex-unlock! reader-available-mutex))
+ (mutex-unlock! reader-queue-mutex)
+ res))
+
+(define (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)))
+
+
+;; Network
+
+(define (start-network-listener)
+ (thread-start!
+ (lambda ()
+ (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)
+ ((uri-str message ...)
+ (apply send-message (cons (uri-reference uri-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)