minor printing stuff in examples
This commit is contained in:
parent
458bf93fef
commit
affa47a2a5
|
@ -102,7 +102,7 @@
|
||||||
|
|
||||||
(define (spawn-leader [titles : (List String)])
|
(define (spawn-leader [titles : (List String)])
|
||||||
(spawn τc
|
(spawn τc
|
||||||
(begin
|
(print-role
|
||||||
(start-facet get-quotes
|
(start-facet get-quotes
|
||||||
(field [book-list (List String) (rest titles)]
|
(field [book-list (List String) (rest titles)]
|
||||||
[title String (first titles)])
|
[title String (first titles)])
|
||||||
|
@ -167,7 +167,7 @@
|
||||||
(define (spawn-club-member [name : String]
|
(define (spawn-club-member [name : String]
|
||||||
[titles : (List String)])
|
[titles : (List String)])
|
||||||
(spawn τc
|
(spawn τc
|
||||||
(begin
|
(print-role
|
||||||
(start-facet member
|
(start-facet member
|
||||||
;; assert our presence
|
;; assert our presence
|
||||||
(assert (club-member name))
|
(assert (club-member name))
|
||||||
|
|
|
@ -116,7 +116,7 @@ TaskRunners.
|
||||||
(Role (assign)
|
(Role (assign)
|
||||||
(Shares (TaskAssignment ID ID ConcreteTask))
|
(Shares (TaskAssignment ID ID ConcreteTask))
|
||||||
;; would be nice to say how the IDs relate to each other (first two are the same)
|
;; would be nice to say how the IDs relate to each other (first two are the same)
|
||||||
(Reacts (Know (TaskState ID ID ID ★/t))
|
(Reacts (Know (TaskState ID ID TaskID ★/t))
|
||||||
(Branch (Stop assign)
|
(Branch (Stop assign)
|
||||||
(Effs)))))
|
(Effs)))))
|
||||||
|
|
||||||
|
@ -186,6 +186,7 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
(define (spawn-task-runner)
|
(define (spawn-task-runner)
|
||||||
(define id (gensym 'task-runner))
|
(define id (gensym 'task-runner))
|
||||||
(spawn τc
|
(spawn τc
|
||||||
|
(begin
|
||||||
(start-facet runner
|
(start-facet runner
|
||||||
(field [status Status IDLE])
|
(field [status Status IDLE])
|
||||||
(define (idle?) (equal? IDLE (ref status)))
|
(define (idle?) (equal? IDLE (ref status)))
|
||||||
|
@ -210,7 +211,7 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
(set! state (finished wc))])
|
(set! state (finished wc))])
|
||||||
(set! status IDLE)]
|
(set! status IDLE)]
|
||||||
[#t
|
[#t
|
||||||
(set! status OVERLOAD)])))))
|
(set! status OVERLOAD)]))))))
|
||||||
|
|
||||||
;; ---------------------------------------------------------------------------------------------------
|
;; ---------------------------------------------------------------------------------------------------
|
||||||
;; TaskManager
|
;; TaskManager
|
||||||
|
@ -218,6 +219,7 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
(define (spawn-task-manager)
|
(define (spawn-task-manager)
|
||||||
(define id (gensym 'task-manager))
|
(define id (gensym 'task-manager))
|
||||||
(spawn τc
|
(spawn τc
|
||||||
|
(print-role
|
||||||
(start-facet tm
|
(start-facet tm
|
||||||
(log "Task Manager (TM) ~a is running" id)
|
(log "Task Manager (TM) ~a is running" id)
|
||||||
(during (job-manager-alive)
|
(during (job-manager-alive)
|
||||||
|
@ -257,7 +259,7 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
[OVERLOAD/ts
|
[OVERLOAD/ts
|
||||||
(set! status OVERLOAD/ts)]
|
(set! status OVERLOAD/ts)]
|
||||||
[(finished discard)
|
[(finished discard)
|
||||||
(set! status st)]))))))))
|
(set! status st)])))))))))
|
||||||
|
|
||||||
;; ---------------------------------------------------------------------------------------------------
|
;; ---------------------------------------------------------------------------------------------------
|
||||||
;; JobManager
|
;; JobManager
|
||||||
|
@ -313,12 +315,14 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
(define (input->pending-task [t : InputTask] -> PendingTask)
|
(define (input->pending-task [t : InputTask] -> PendingTask)
|
||||||
(match t
|
(match t
|
||||||
[(task $id (map-work $s))
|
[(task $id (map-work $s))
|
||||||
|
;; with occurrence typing, could just return t
|
||||||
(task id (map-work s))]
|
(task id (map-work s))]
|
||||||
[(task $id (reduce-work $l $r))
|
[(task $id (reduce-work $l $r))
|
||||||
(task id (reduce-work (left l) (left r)))]))
|
(task id (reduce-work (left l) (left r)))]))
|
||||||
|
|
||||||
(define (spawn-job-manager)
|
(define (spawn-job-manager)
|
||||||
(spawn τc
|
(spawn τc
|
||||||
|
(begin
|
||||||
(start-facet jm
|
(start-facet jm
|
||||||
(assert (job-manager-alive))
|
(assert (job-manager-alive))
|
||||||
(log "Job Manager Up")
|
(log "Job Manager Up")
|
||||||
|
@ -458,7 +462,7 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
(perform-task t push-results))
|
(perform-task t push-results))
|
||||||
(unless (empty? ts)
|
(unless (empty? ts)
|
||||||
;; the empty? check may be necessary to avoid a dataflow loop
|
;; the empty? check may be necessary to avoid a dataflow loop
|
||||||
(set! ready-tasks readys)))))))
|
(set! ready-tasks readys))))))))
|
||||||
|
|
||||||
;; ---------------------------------------------------------------------------------------------------
|
;; ---------------------------------------------------------------------------------------------------
|
||||||
;; Client
|
;; Client
|
||||||
|
@ -488,5 +492,5 @@ The JobManager then performs the job and, when finished, asserts (job-finished I
|
||||||
(spawn-task-manager)
|
(spawn-task-manager)
|
||||||
(spawn-task-runner)
|
(spawn-task-runner)
|
||||||
(spawn-task-runner)
|
(spawn-task-runner)
|
||||||
(spawn-client (file->job "lorem.txt"))
|
#;(spawn-client (file->job "lorem.txt"))
|
||||||
(spawn-client (string->job INPUT)))
|
(spawn-client (string->job INPUT)))
|
||||||
|
|
Loading…
Reference in New Issue