Index of values

at_fail s c registers channel c as a guard on failure of site s.

Ensures that client and server have the same magic number, raising Error (Magic,...) if not.

client cfg uses the cfg to connect to the server, and registers itself to receive computations (i.e.

Used by the server to combine values associated with the same key, compare_keys being used for key equality.

Analogous of JoinProc.command.

Analogous of JoinProc.command.

command prog args executes program prog with arguments args in a child process.

Compare two sites, order is arbitrary.

Ordering over keys.

connect cfg connect as a client to the server referenced by cfg.

connect (prod,cons,k) connnects producer prod and consumer cons.

Pool creator

create e comb y0 returns a pool for computations of type 'a -> 'b, comb being used to combine results with initial result y0.

Create a new fifo buffer.

create comb y0 returns a monitor for computations of type 'a -> 'b, comb being used to combine results with initial result y0.

create comb y0 returns a dynamic collector of events of type 'a, with combining function comb and initial result y0.

create comb y0 n returns a collector of n events of type 'a, with combining function comb and initial result y0.

create n returns a countdown c for n events.

Create a pair of producer/consumer connected by a fifo.

Records of type 'a S.t offer the same fields as the ones of type 'a t, but they hold synchronous channels (of functional type)

If true, gives a few diagnostics on the standard error stream.

Print a message on standard error.

default_configuration () returns a configuration with default values.

do_at_fail f builds a channel that calls f upon failure.

do_forks prog args n does n forks (none if n is negative), using prog as the program name, and passing args to the forked programs.

A channel that does noting upon failure.

Empty producer, get will always return None.

enum_of_interval inf sup returns an enumeration that will iterate the interval from int to sup.

enum_of_list l returns an enumeration that will iterate over the elements of l.

Test the equality of two sites.

Bare alias for exit_at_fail_with_code 0.

exit_at_fail_with_code c builds a channel that terminates the current process with code c upon failure.

Hook to be given as argument to Pervasives.at_exit.

filter_clients argv returns a new array identical to the passed one, except that it contains neither the "-clients" switches, nor their arguments.

Returns the default Internet address of the local site, never fails.

The local name service.

Local site identity.

The identifier for the problem, used to enable multiple map/reduce problems on a single server.

Called at client startup with the data registered at server startup.

init_client ~at_fail cfg initializes a client by connecting it to the server referenced by cfg, forking clients, and registering the at_fail channel to act as a guard on server failure (cf.

init_client_with_lookup ~at_fail ~lookup cfg name behaves as init_client, additionally looking up for name using lookup (defaulting to lookup_times ~-1 1.0) on the returned server name service.

init_server cfg initializes a server listening for connections, registers the magic value, and forks clients.

init_server_with_register cfg name value executes init_server cfg and uses the returned name service to register value as name.

listen cfg initializes a server listening for connections and registers the magic value.

Start to listen for connections on the socket address given as argument.

Find value, raise Not_found when not present, or Join.Exit if attemping to lookup on a failed remote name service.

A lookup function that tries to retrieve the value only once, raising Not_found if value is not present and Join.Exit if remote name service is down (alias for Join.Ns.lookup).

lookup_times n w builds a lookup function that tries up to n times to retrieve the value, waiting w seconds between two attempts.

make_configuration cfg returns a list of argument descriptors that will update the configuration cfg when parsed through Arg.parse (or equivalent).

The computation actually done by client agents.

map f prod returns a producer that produces f x when prod produces x

A given task will be re-issued at most nagain times.

of_list xs returns a producer for the elements of xs

Get remote name service by site identity.

Synonym for there

of_text chan returns a producer prod built from the lines of channel chan.

Analogous of JoinProc.open_full.

Analogous of JoinProc.open_full.

Redirects all three standard channels of the forked command to pipes.

Analogous of JoinProc.open_in.

Analogous of JoinProc.open_in.

Same as JoinProc.command above, except that the forked process standard output is redirected to a pipe, which can be read via the returned input channel.

Analogous of JoinProc.open_in_out.

Analogous of JoinProc.open_in_out.

Redirects both standard output and input of the forked command to pipes.

Analogous of JoinProc.open_out.

Same as JoinProc.command above, except that the forked process standard input is redirected to a pipe, which can be written to via the returned output channel.

Used by the server to fold all client results at the end of the computation.

Register binding, returns when done.

server cfg i e z sets up a server using the passed configuration, and dispatches tasks to registered clients using a pool.

Start iterating over a collection, start c returns the initial state

Iterate once, step st returns None when iteration is over, or Some (e,st') otherwise, where e is the next element and st' is the next explicit state.

Get remote name service by socket address.

Get identity of the remote site listening on sockaddr.

to_list (prod,k) asynchronously consumes all the elements produced by prod.

Converse operation

to_text (prod,chan,k) asynchronously consumes all the elements produced by prod, writing lines to channel chan in production order.

Same as JoinCom.P.to_text above except that the channel is closed as sooon as the producer emits None.

Just waits forever; useful to guarantee that code will not exit prematurely.

when_none k prod returns a producer that acts like prod.

where_from c returns the identity of the remote site where reception on channel c takes place.