Module `Scheduler.Make`Source

Parameters

module Streamd : StreamDescriptor

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 =

| Root

type nonroot = PriorityTreeNode.nonroot =

| NonRoot

type stream = nonroot node

and parent = PriorityTreeNode.parent =

| Parent : _ node -> parent

and _ node = _ PriorityTreeNode.node =

| 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
| 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

Source

val create : 
  parent:parent ->
  initial_send_window_size:Settings.WindowSize.t ->
  initial_recv_window_size:Settings.WindowSize.t ->
  Streamd.t ->
  nonroot node

Source

val pq_add : 
  PriorityQueue.k ->
  PriorityQueue.p ->
  PriorityQueue.t ->
  PriorityQueue.t

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

Source

val reprioritize_stream : 
  root node ->
  priority:Priority.t ->
  nonroot node ->
  unit

Source

val 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

Source

val 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

Source

val mark_for_removal : 
  root node ->
  Stream_identifier.t ->
  Stream.closed ->
  unit

Source

val implicitly_close_idle_stream : 
  Streamd.t ->
  (Stream_identifier.t * Stream_identifier.t) ->
  unit

Sourceval flush : root node -> (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

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Scheduler/Make/index.html

Module `Scheduler.Make`Source

Parameters

Signature

package dream-httpaf

Install

Dune Dependency

Authors

Maintainers

Sources

doc/dream-httpaf.dream-h2/Dream_h2/Scheduler/Make/index.html

Module Scheduler.MakeSource

Parameters

Signature

Module `Scheduler.Make`Source