home
/
code
/
dups.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Remove redundant annotations
[dups.git]
/
dups.ml
diff --git
a/dups.ml
b/dups.ml
index
e340a78
..
b83b4be
100644
(file)
--- a/
dups.ml
+++ b/
dups.ml
@@
-286,18
+286,18
@@
end = struct
let active_vassals = ref njobs in
let results = Queue.create () in
let rec dispatch () =
let active_vassals = ref njobs in
let results = Queue.create () in
let rec dispatch () =
- match
Ipc.recv ic
with
- |
((Exiting i) : ('input, 'output) msg_from_vassal)
->
+ match
((Ipc.recv ic) : ('input, 'output) msg_from_vassal)
with
+ |
Exiting i
->
close_out ocs.(i);
decr active_vassals;
if !active_vassals = 0 then
()
else
dispatch ()
close_out ocs.(i);
decr active_vassals;
if !active_vassals = 0 then
()
else
dispatch ()
- |
((Ready i) : ('input, 'output) msg_from_vassal)
->
+ |
Ready i
->
Ipc.send ocs.(i) (Job (next t));
dispatch ()
Ipc.send ocs.(i) (Job (next t));
dispatch ()
- |
((Result (i, result)) : ('input, 'output) msg_from_vassal
) ->
+ |
Result (i, result
) ->
Queue.add result results;
Ipc.send ocs.(i) (Job (next t));
dispatch ()
Queue.add result results;
Ipc.send ocs.(i) (Job (next t));
dispatch ()
@@
-319,10
+319,10
@@
end = struct
let oc = Unix.out_channel_of_descr lord_pipe_w in
let rec work msg =
Ipc.send oc msg;
let oc = Unix.out_channel_of_descr lord_pipe_w in
let rec work msg =
Ipc.send oc msg;
- match
Ipc.recv ic
with
- |
(Job (Some x) : 'input msg_from_lord
) ->
+ match
(Ipc.recv ic : 'input msg_from_lord)
with
+ |
Job (Some x
) ->
work (Result (i, (x, f x)))
work (Result (i, (x, f x)))
- |
(Job None : 'input msg_from_lord)
->
+ |
Job None
->
Ipc.send oc (Exiting i)
in
work (Ready i);
Ipc.send oc (Exiting i)
in
work (Ready i);
This page took
0.019513 seconds
and
4
git commands to generate.