links 0.9.6 · OCaml Package

type chan = Value.chan

val receive_port : chan -> ProcessTypes.channel_id

val send_port : chan -> ProcessTypes.channel_id

val cancel : chan -> unit Lwt.t

val is_endpoint_cancelled : ProcessTypes.channel_id -> bool

type send_result =

type receive_result =

val new_server_access_point : unit -> ProcessTypes.apid

val new_client_access_point : ProcessTypes.client_id -> ProcessTypes.apid

val get_and_mark_pending_aps : ProcessTypes.client_id -> ProcessTypes.apid list

val accept : ProcessTypes.apid -> (chan * bool) Lwt.t

val request : ProcessTypes.apid -> (chan * bool) Lwt.t

val ap_request_from_client : 
  ProcessTypes.client_id ->
  ProcessTypes.process_id ->
  ProcessTypes.apid ->
  unit Lwt.t

val ap_accept_from_client : 
  ProcessTypes.client_id ->
  ProcessTypes.process_id ->
  ProcessTypes.apid ->
  unit Lwt.t

val block : ProcessTypes.channel_id -> ProcessTypes.process_id -> unit

val unblock : ProcessTypes.channel_id -> ProcessTypes.process_id option

val send_from_local : Value.t -> ProcessTypes.channel_id -> send_result Lwt.t

val send_from_remote : 
  ProcessTypes.client_id ->
  Value.delegated_chan list ->
  Value.t ->
  ProcessTypes.channel_id ->
  send_result Lwt.t

val receive : chan -> receive_result

val handle_lost_message_response : 
  ProcessTypes.channel_id ->
  (ProcessTypes.channel_id * Value.t list) list ->
  unit Lwt.t

val handle_remote_cancel : 
  notify_ep:ProcessTypes.channel_id ->
  cancelled_ep:ProcessTypes.channel_id ->
  unit Lwt.t

val link : chan -> chan -> unit

val cancel_client_channels : ProcessTypes.client_id -> unit Lwt.t

val register_client_channel : ProcessTypes.client_id -> chan -> unit

val register_server_channel : chan -> unit

val get_buffer : ProcessTypes.channel_id -> Value.t list option

val close : chan -> unit

package links