big-random-number
big-random-number-string
simple-message-id-generator
- require-slot
<actor>
actor-id
actor-id-hive
actor-id-string
- make-action-dispatch
+ mlambda define-mhandler
+ simple-dispatcher build-actions make-action-dispatch
define-simple-actor
<hive>
(set! counter (1+ counter))
(string-append prefix (number->string counter)))))
-(define (require-slot slot-name)
- "Generate something for #:init-thunk to complain about unfilled slot"
- (lambda ()
- (throw 'required-slot
- (format #f "Slot ~s not filled" slot-name)
- slot-name)))
-
\f
;;; Messages
(define-class <actor> ()
;; An address object
- (id #:init-thunk (require-slot "id")
- #:init-keyword #:id
+ (id #:init-keyword #:id
#:getter actor-id)
;; The hive we're connected to.
;; We need this to be able to send messages.
- (hive #:init-thunk (require-slot "hive")
- #:init-keyword #:hive
+ (hive #:init-keyword #:hive
#:accessor actor-hive)
;; How we receive and process new messages
- (message-handler #:init-thunk (require-slot "message-handler")
- #:allocation #:each-subclass))
+ (message-handler #:allocation #:each-subclass))
(define-method (actor-message-handler (actor <actor>))
(slot-ref actor 'message-handler))
;;; Actor utilities
;;; ===============
+
+(define-syntax-rule (with-message-args (message message-arg ...)
+ body body* ...)
+ (let ((message-arg (message-ref message (quote message-arg))) ...)
+ body body* ...))
+
+(define-syntax mlambda
+ (lambda (x)
+ "A lambda for building message handlers.
+
+Use it like:
+ (mlambda (actor message foo)
+ ...)
+
+Which is like doing manually:
+ (lambda (actor message)
+ (let ((foo (message-ref message foo)))
+ ...))"
+ (syntax-case x ()
+ ((_ (actor message message-arg ...)
+ docstring
+ body ...)
+ (string? (syntax->datum #'docstring))
+ #'(lambda (actor message)
+ docstring
+ (with-message-args (message message-arg ...) body ...)))
+ ((_ (actor message message-arg ...)
+ body body* ...)
+ #'(lambda (actor message)
+ (with-message-args (message message-arg ...) body body* ...))))))
+
+(define-syntax-rule (define-mhandler (name actor message message-arg ...)
+ body ...)
+ (define name
+ (mlambda (actor message message-arg ...)
+ body ...)))
+
(define (simple-dispatcher action-map)
(lambda (actor message)
(let* ((action (message-action message))
(method (assoc-ref action-map action)))
(if (not method)
+ ;; @@: There's every possibility this should be handled in
+ ;; hive-process-message instead.
(throw 'action-not-found
"No appropriate action handler found for actor"
#:action action
(syntax-rules ()
((_ ((action-name action-args ...) body ...))
(cons (quote action-name)
- (lambda (action-args ...)
+ (mlambda (action-args ...)
body ...)))
((_ (action-name handler))
(cons (quote action-name) handler))))
+(define-syntax-rule (build-actions action-item ...)
+ "Build a mapping of actions. Same syntax as make-action-dispatch
+but this doesn't build the dispatcher for you (you probably want to
+pass it to simple-dispatcher).
+
+The advantage here is that since this simply builds an alist, you can
+compose it with other action maps."
+ (list (%expand-action-item action-item) ...))
+
(define-syntax make-action-dispatch
(syntax-rules ()
"Expand a list of action names and actions into an alist
((party actor message)
(display \"Life of the party!\")))"
((make-action-dispatch action-item ...)
- (simple-dispatcher
- (list (%expand-action-item action-item) ...)))))
+ (simple-dispatcher (build-actions action-item ...)))))
(define-syntax-rule (define-simple-actor class actions ...)
(define-class class (<actor>)
(define-generic hive-handle-failed-forward)
(define-class <hive> (<actor>)
- ;; This gets set to itself immediately after being created
- (hive #:init-value #f)
(actor-registry #:init-thunk make-hash-table
#:getter hive-actor-registry)
(msg-id-generator #:init-thunk simple-message-id-generator
(define (call-catching-coroutine thunk)
(define (call-catching-errors)
- (with-throw-handler
- #t thunk
- (lambda (key . args)
- (if (message-needs-reply message)
- ;; If the message is waiting on a reply, let them know
- ;; something went wrong.
- (hive-reply-with-error hive message key args)))))
+ ;; TODO: maybe parameterize (or attach to hive) and use
+ ;; maybe-catch-all from agenda.scm
+ ;; @@: Why not just use with-throw-handler and let the catch
+ ;; happen at the agenda? That's what we used to do, but
+ ;; it ended up with a SIGABRT. See:
+ ;; http://lists.gnu.org/archive/html/bug-guile/2016-05/msg00003.html
+ (catch #t
+ thunk
+ ;; In the actor model, we don't totally crash on errors.
+ (lambda _ #f)
+ ;; If an error happens, we raise it
+ (lambda (key . args)
+ (if (message-needs-reply message)
+ ;; If the message is waiting on a reply, let them know
+ ;; something went wrong.
+ (hive-reply-with-error hive message key args))
+ ;; print error message
+ (apply print-error-and-continue key args))))
(call-with-prompt (hive-prompt hive)
call-catching-errors
(lambda (kont actor message)
(process-remote-message))))
(define-method (hive-actor-local? (hive <hive>) address)
- (hash-ref (hive-actor-registry hive) address))
+ (equal? (hive-id hive) (address-hive-id address)))
(define-method (hive-register-actor! (hive <hive>) (actor <actor>))
(hash-set! (hive-actor-registry hive) (actor-id actor) actor))
projects / 8sync.git / blobdiff