1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
(***********************************************************************)
(* *)
(* Objective Caml *)
(* *)
(* Luc Maranget, projet Moscova, INRIA Rocquencourt *)
(* *)
(* Copyright 2004 Institut National de Recherche en Informatique et *)
(* en Automatique. All rights reserved. This file is distributed *)
(* under the terms of the Q Public License version 1.0. *)
(* *)
(***********************************************************************)
open Join_types
(* Process managment *)
val create_process : (unit -> unit) -> unit
(* Automaton *)
val get_queue : automaton -> int -> 'a
val init_unit_queue : automaton -> int -> unit
val create_automaton : int -> automaton
(* create_automaton nchans *)
val create_automaton_debug : int -> string array -> automaton
val wrap_automaton : automaton -> stub
val patch_table : automaton -> reaction array -> unit
(* Asynchronous channels *)
val create_async : stub -> int -> 'a async
val create_alone : ('a -> unit) -> string -> 'a async
val alloc_alone : string -> 'a async
val patch_alone : 'a async -> ('a -> unit) -> unit
val local_send_async : automaton -> int -> 'a -> unit
val local_tail_send_async : automaton -> int -> 'a -> unit
val local_send_alone : ('a -> unit) -> 'a -> unit
val local_tail_send_alone : ('a -> unit) -> 'a -> unit
val send_async : 'a async -> 'a -> unit
val tail_send_async : 'a async -> 'a -> unit
val space_id_of_chan : 'a async -> space_id
(* Synchronous channels are plain fonctions *)
val local_send_sync : automaton -> int -> 'a -> 'b
val create_sync : stub -> int -> ('a -> 'b)
val create_sync_alone : ('a -> 'b) -> string -> ('a -> 'b)
val alloc_stub_guard : unit -> stub
val alloc_sync_alone : stub -> string -> ('a -> 'b)
val patch_sync_alone : stub -> ('a -> 'b) -> unit
(* Explicit reply to continuation *)
val reply_to : 'a -> continuation -> unit
val reply_to_exn : exn -> continuation -> unit
(* Silent suicide of a join thread (compiler use only) *)
val raise_join_exit : unit -> 'a
(* Register an exception as a global one, compiler use *)
val exn_global : (string * int * int) -> Obj.t -> unit
(* Services provide RPC by name, library use only *)
(*
val remote_service : Unix.sockaddr -> string -> service
(** Raise Join.Exit *)
*)
val register_service : string -> ('a -> 'b) -> unit
val call_service : service -> 'a -> 'b
|
