distributed
Library
Module
Module type
Parameter
Class
Class type
A description of the implementation (e.g., the url of the code repository ), for logging purposes.
val return : 'a -> 'a treturn v creates a light weight thread returning v.
bind t f is a thread which first waits for the thread t to terminate and then, if the thread succeeds, behaves as the application of function f to the return value of t. If the thread t fails, bind t f also fails, with the same exception.
val ignore_result : 'a t -> unitignore_result t is like Pervasives.ignore t except that: if t already failed, it raises the exception now, if t is sleeping and fails later, the exception will be given to async_exception_hook.
val fail : exn -> 'a tfail e is a thread that fails with the exception e.
catch t f is a thread that behaves as the thread t () if this thread succeeds. If the thread t () fails with some exception, catch t f behaves as the application of f to this exception.
val async : ( unit -> 'a t ) -> unitasync f starts a thread without waiting for the result.
val create_stream : unit -> 'a stream * ( 'a option -> unit )create () returns a new stream and a push function.
get st removes and returns the first element of the stream, if any. Will block if the stream is empty.
stream_append s1 s2 returns a stream which returns all elements of s1, then all elements of s2.
val close_input : input_channel -> unit tclose ch closes the given channel immediately.
val close_output : output_channel -> unit tclose ch closes the given channel. It performs all pending actions, flushes it and closes it.
val read_value : input_channel -> 'a tread_value ic reads a marshalled value from ic.
val write_value :
output_channel ->
?flags:Batteries.Marshal.extern_flags list ->
'a ->
unit twrite_value oc ?flags x marshals the value x to oc.
val open_connection :
Batteries.Unix.sockaddr ->
(input_channel * output_channel) topen_connection addr opens a connection to the given address and returns two channels for using it.
val establish_server :
?backlog:int ->
Batteries.Unix.sockaddr ->
( (input_channel * output_channel) -> unit ) ->
serverestablish_server ?backlog sockaddr f creates a server which will listen for incoming connections. New connections are passed to f. Note that f must not raise any exception. Backlog is the argument passed to Lwt_unix.listen.
val shutdown_server : server -> unitshutdown_server server will shutdown server.
val log :
?exn:exn ->
?location:(string * int * int) ->
logger:logger ->
level:level ->
string ->
unit tlog ?exn ?location logger level message logs a message using logger. If exn is provided, then its string representation (= Printexc.to_string exn) will be append to the message, and if possible the back trace will also be logged. Location contains the location of the logging directive, it is of the form (file_name, line, column).
val sleep : float -> unit tsleep d is a thread that remains suspended for d seconds and then terminates.
val timeout : float -> 'a ttimeout d is a thread that remains suspended for d seconds and then fails with Timeout.
choose l behaves as the first thread in l to terminate. If several threads are already terminated, one is chosen at random.
pick l is the same as choose, except that it cancels all sleeping threads when one terminates.
nchoose l returns the value of all that have successfully terminated. If all threads are sleeping, it waits for at least one to terminates. If one the threads of l fails, nchoose fails with the same exception.
val at_exit : ( unit -> unit t ) -> unitat_exit fn will call fn on program exit.