Cosmetic
This commit is contained in:
parent
6684c9e883
commit
956a940480
|
@ -44,13 +44,10 @@
|
||||||
;; EFFECT: Spawn a queue process named `queue-id`.
|
;; EFFECT: Spawn a queue process named `queue-id`.
|
||||||
(define (spawn-queue queue-id)
|
(define (spawn-queue queue-id)
|
||||||
(actor #:name (list 'queue queue-id)
|
(actor #:name (list 'queue queue-id)
|
||||||
(react (define/query-hash credits (subscription queue-id $who) who 0) ;; Start with no credit
|
(react (field [waiters (make-queue)])
|
||||||
(field [waiters (make-queue)])
|
|
||||||
(field [messages (make-queue)])
|
(field [messages (make-queue)])
|
||||||
|
|
||||||
(during (subscription queue-id $who)
|
(define/query-hash credits (subscription queue-id $who) who 0) ;; Start with no credit
|
||||||
(assert (metric (list 'credit queue-id who) (hash-ref (credits) who 0))))
|
|
||||||
(assert (metric (list 'backlog queue-id) (queue-length (messages))))
|
|
||||||
|
|
||||||
(on (message (credit queue-id $who $amount))
|
(on (message (credit queue-id $who $amount))
|
||||||
(define old-credit (hash-ref (credits) who #f))
|
(define old-credit (hash-ref (credits) who #f))
|
||||||
|
@ -75,6 +72,10 @@
|
||||||
(log-info "~a: sending ~a message ~a" queue-id who msg)
|
(log-info "~a: sending ~a message ~a" queue-id who msg)
|
||||||
(send! (delivery queue-id who msg)))))
|
(send! (delivery queue-id who msg)))))
|
||||||
|
|
||||||
|
(during (subscription queue-id $who)
|
||||||
|
(assert (metric (list 'credit queue-id who) (hash-ref (credits) who 0))))
|
||||||
|
(assert (metric (list 'backlog queue-id) (queue-length (messages))))
|
||||||
|
|
||||||
;;------------------------------------------------------------
|
;;------------------------------------------------------------
|
||||||
|
|
||||||
(local-require (submod syndicate/actor priorities))
|
(local-require (submod syndicate/actor priorities))
|
||||||
|
|
Loading…
Reference in New Issue