Module Scheduler.MakeSource

Parameters

Signature

Sourcemodule PriorityTreeNode : sig ... end
module PriorityQueue : Psq.S with type k = Int32.t and type p = PriorityTreeNode.stream
include module type of struct include PriorityTreeNode end
type root = PriorityTreeNode.root =
  1. | Root
type nonroot = PriorityTreeNode.nonroot =
  1. | NonRoot
type stream = nonroot node
and parent = PriorityTreeNode.parent =
  1. | Parent : _ node -> parent
and _ node = _ PriorityTreeNode.node =
  1. | Connection : {
    1. all_streams : stream StreamsTbl.t;
    2. mutable t_last : int;
    3. mutable children : PriorityQueue.t;
    4. mutable flow : Settings.WindowSize.t;
    5. mutable inflow : Settings.WindowSize.t;
    6. mutable marked_for_removal : (Stream_identifier.t * Stream.closed) list;
    } -> root node
  2. | Stream : {
    1. descriptor : Streamd.t;
    2. mutable t_last : int;
    3. mutable t : int;
    4. mutable priority : Priority.t;
    5. mutable parent : parent;
    6. mutable children : PriorityQueue.t;
    7. mutable flow : Settings.WindowSize.t;
    8. mutable inflow : Settings.WindowSize.t;
    } -> nonroot node
Sourcetype t = root node
Sourceval make_root : ?capacity:int -> unit -> root node
Sourceval create : parent:parent -> initial_send_window_size:Settings.WindowSize.t -> initial_recv_window_size:Settings.WindowSize.t -> Streamd.t -> nonroot node
Sourceval remove_from_parent : parent -> PriorityQueue.k -> unit
Sourceval children : 'a. 'a node -> PriorityQueue.t
Sourceval stream_id : 'a. 'a node -> int32
Sourceval set_parent : nonroot node -> exclusive:bool -> parent -> unit
Sourceval would_create_cycle : new_parent:parent -> nonroot node -> bool
Sourceval reprioritize_stream : root node -> priority:Priority.t -> nonroot node -> unit
Sourceval add : root node -> priority:Priority.t -> initial_send_window_size:Settings.WindowSize.t -> initial_recv_window_size:Settings.WindowSize.t -> Streamd.t -> nonroot node
Sourceval get_node : root node -> StreamsTbl.key -> stream option
Sourceval find : root node -> StreamsTbl.key -> Streamd.t option
Sourceval iter : root node -> f:(stream -> unit) -> unit
Sourceval allowed_to_transmit : root node -> nonroot node -> bool
Sourceval allowed_to_receive : root node -> nonroot node -> Settings.WindowSize.t -> bool
Sourceval write : root node -> nonroot node -> int
Sourceval update_t : nonroot node -> int -> unit
Sourceval mark_for_removal : root node -> Stream_identifier.t -> Stream.closed -> unit
Sourceval implicitly_close_idle_stream : Streamd.t -> (Stream_identifier.t * Stream_identifier.t) -> unit
Sourceval check_flow : Int32.t -> Int32.t -> Int32.t -> bool
Sourceval add_flow : 'a. 'a node -> int32 -> bool
Sourceval add_inflow : 'a. 'a node -> int32 -> bool
Sourceval deduct_inflow : 'a. 'a node -> int32 -> unit
Sourceval pp_hum : Format.formatter -> PriorityQueue.t -> unit