Commit 45d3127f authored by Aggelos Giantsios's avatar Aggelos Giantsios

Change timeout to 0 (Non blocking receive)

And it magically works!!!
parent aabc1ad0
...@@ -43,14 +43,14 @@ par_seq generators n p = ...@@ -43,14 +43,14 @@ par_seq generators n p =
dist :: (Vertex -> GenClos) -> Vertex -> Int -> [NodeId] -> Process String dist :: (Vertex -> GenClos) -> Vertex -> Int -> [NodeId] -> Process String
dist generators n p workers = dist generators n p workers =
orbit (generators n) [0] orbit (generators n) [0]
(Par (Many [(h, p, (2 * n) `div` (w * p) + 1, 1, True) | h <- workers])) (Par (Many [(h, p, (2 * n) `div` (w * p) + 1, 0, True) | h <- workers]))
>>= return . sz . snd >>= return . sz . snd
where w = length workers where w = length workers
dist_seq :: (Vertex -> GenClos) -> Vertex -> Int -> [NodeId] -> Process String dist_seq :: (Vertex -> GenClos) -> Vertex -> Int -> [NodeId] -> Process String
dist_seq generators n p workers = dist_seq generators n p workers =
orbit (generators n) [0] orbit (generators n) [0]
(Par (Many [(h, p, (2 * n) `div` (w * p) + 1, 1, False) | h <- workers])) (Par (Many [(h, p, (2 * n) `div` (w * p) + 1, 0, False) | h <- workers]))
>>= return . sz . snd >>= return . sz . snd
where w = length workers where w = length workers
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment