uncomment flink
This commit is contained in:
parent
50d2d1a6fa
commit
db3fc2acd9
|
@ -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)))
|
||||||
|#
|
|
||||||
|
|
Loading…
Reference in New Issue