Index of values

add_task c t adds task t to computation c.

add_worker c w adds worker w to computation c.

clear c clears all tasks from computation c i.e.

compute () starts a worker loop, waiting for computations from the master.

master f handle l applies function f to each first-component of elements in l; for each such computation, both the list element and the result are passed to handle, which returns a list of new elements to be processed (in an identical manner).

create worker master creates a new distributed computation.

create_worker s creates a new worker located on machine s.

declare_workers s declares n workers on machine s (when n is not given, it defaults to 1).

kill c kills computation c.

same result as List.map

map_fold_a f fold acc [x1;...xn] computes fold ... (fold (fold acc (f x1)) (f x2)) ... (f xn) assuming fold is an associative operation with neutral element acc

same specification, assuming fold is an associative and commutative operation; the third argument should be a neutral element for fold

map_local_fold f fold acc l computes fold ... (fold (fold acc (f x1)) (f x2)) ... (f xn) for some permutation x1,x2,...,xn of l

same specification as above

one_step ~timeout c runs one step of computation c.

remove_worker c w removes worker w from computation c.

Sets the debug flag.

Sets the default port number.

set_number_of_cores n indicates that n computations can be done in parallel.

set_ping_interval t sets the interval between consecutive ping messages.

set_pong_timeout t sets the upper time limit t for receiving a pong message from a worker (since last ping message), before we declare the worker unreachable.

status c queries the statis of computation c.