Module Make.BatchedSource

Sourcetype cfg = {
  1. size : int;
}
Sourcetype 'a op =
  1. | Insert : V.t -> unit op
  2. | Member : V.t -> bool op
  3. | Size : int op
Sourcetype wrapped_op =
  1. | Mk : 'a op * 'a Picos.Computation.t -> wrapped_op
Sourceval init : ?cfg:cfg -> unit -> Sequential.t
Sourcetype intermediate = {
  1. batch_size : int;
  2. maxinsertlevel : int ref;
  3. level_arr : int array;
  4. new_node_arr : Sequential.node array;
  5. new_node_back_arr : Sequential.node array;
  6. prev_node_idx : int array;
}
Sourceval build_node : Sequential.t -> int -> V.t -> intermediate -> unit
Sourceval relate_nodes : Sequential.t -> int -> intermediate -> unit
Sourceval merge_list : Sequential.t -> int -> intermediate -> unit
Sourceval remove_duplicates : 'a array -> int -> int
Sourceval par_insert : Sequential.t -> V.t array -> unit
Sourceval par_size : Sequential.t -> int array -> int array
Sourceval run : Sequential.t -> wrapped_op array -> unit