syndicate-lang
/
syndicate-2017
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

uncomment flink

This commit is contained in:
Sam Caldwell 2020-09-25 20:36:47 -04:00
parent d53b5041f3
commit e63da2679b
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
racket/typed/examples/roles/flink.rkt
View File

@ -3,7 +3,6 @@
;; --------------------------------------------------------------------------------------------------- ;; ---------------------------------------------------------------------------------------------------
;; Protocol ;; Protocol
#|
#| #|
Conversations in the flink dataspace primarily concern two topics: presence and Conversations in the flink dataspace primarily concern two topics: presence and
@ -170,13 +169,11 @@ The JobManager then performs the job and, when finished, asserts
(printf fmt . args) (printf fmt . args)
(printf "\n"))) (printf "\n")))
|#
;; --------------------------------------------------------------------------------------------------- ;; ---------------------------------------------------------------------------------------------------
;; TaskRunner ;; TaskRunner
#|
(define (word-count-increment [h : WordCount] (define (word-count-increment [h : WordCount]
[word : String] [word : String]
@ -314,11 +311,10 @@ The JobManager then performs the job and, when finished, asserts
-> (Tuple (List X) (List X)))) -> (Tuple (List X) (List X))))
(define l (split-at/lenient- xs n)) (define l (split-at/lenient- xs n))
(tuple (first l) (second l))) (tuple (first l) (second l)))
|#
;; Task -> Bool ;; Task -> Bool
;; Test if the task is ready to run ;; Test if the task is ready to run
#;(define (task-ready? [t : PendingTask] -> (Maybe ConcreteTask)) (define (task-ready? [t : PendingTask] -> (Maybe ConcreteTask))
(match t (match t
[(task $tid (map-work $s)) [(task $tid (map-work $s))
;; having to re-produce this is directly bc of no occurrence typing ;; having to re-produce this is directly bc of no occurrence typing
@ -330,7 +326,7 @@ The JobManager then performs the job and, when finished, asserts
none])) none]))
#;(define (partition-ready-tasks [tasks : (List PendingTask)] (define (partition-ready-tasks [tasks : (List PendingTask)]
-> (Tuple (List PendingTask) -> (Tuple (List PendingTask)
(List ConcreteTask))) (List ConcreteTask)))
(define part (inst partition/either PendingTask PendingTask ConcreteTask)) (define part (inst partition/either PendingTask PendingTask ConcreteTask))
@ -343,7 +339,7 @@ The JobManager then performs the job and, when finished, asserts
(left t)])))) (left t)]))))
(define (partition-ready-tasks [tasks : (List Int)] #;(define (partition-ready-tasks [tasks : (List Int)]
-> (Tuple (List Int) -> (Tuple (List Int)
(List Int))) (List Int)))
(define part (inst partition/either Int Int Int)) (define part (inst partition/either Int Int Int))
@ -362,7 +358,6 @@ The JobManager then performs the job and, when finished, asserts
(part tasks (part tasks
(lambda ([t : Int]) (lambda ([t : Int])
(left "hi")))) (left "hi"))))
#|
(define (input->pending-task [t : InputTask] -> PendingTask) (define (input->pending-task [t : InputTask] -> PendingTask)
(match t (match t
@ -560,4 +555,3 @@ The JobManager then performs the job and, when finished, asserts
(spawn-task-manager 3) (spawn-task-manager 3)
(spawn-client (file->job "lorem.txt")) (spawn-client (file->job "lorem.txt"))
(spawn-client (string->job INPUT))) (spawn-client (string->job INPUT)))
|#