package dream-httpaf

  1. Overview
  2. Docs
Internal: shared http/af stack for Dream (server) and Hyper (client)

Install 

dune-project
 Dependency

github.com Readme MIT License Edit opam file Versions (4)

Authors

  1. Anton Bachin

Maintainers

  1. Anton Bachin

Sources

dream-1.0.0-alpha6.tar.gz
sha256=8d3b6344c0e175aca628b3d5bb8ee58265e8c1074fc2d40d63f136fef83daf90

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

Module Server_connection.SchedulerSource

Sourcemodule PriorityTreeNode : sig ... end
Sourcemodule PriorityQueue : sig ... end
type root = PriorityTreeNode.root =
  1. | Root
type nonroot = PriorityTreeNode.nonroot =
  1. | NonRoot
type stream = nonroot node
and parent = PriorityTreeNode.parent =
  1. | Parent : 'a node -> parent
and !'a node = 'a PriorityTreeNode.node =
  1. | Connection : {
    1. all_streams : stream Dream_h2__Scheduler.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.closed Dream_h2__Scheduler.StreamsTbl.t;
    } -> root node
  2. | Stream : {
    1. descriptor : Reqd.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 -> Reqd.t -> nonroot node
Sourceval stream_id : 'a node -> int32
Sourceval children : 'a node -> PriorityQueue.t
Sourceval remove_child : 'a node -> int32 -> unit
Sourceval update_children : 'a node -> PriorityQueue.t -> unit
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 update_t : nonroot node -> int -> unit
Sourceval update_t_last : 'a node -> int -> unit
Sourceval add : root node -> priority:Priority.t -> initial_send_window_size:Settings.WindowSize.t -> initial_recv_window_size:Settings.WindowSize.t -> Reqd.t -> nonroot node
Sourceval get_node : root node -> Stream_identifier.t -> stream option
Sourceval find : root node -> Stream_identifier.t -> Reqd.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 mark_for_removal : root node -> Stream_identifier.t -> Stream.closed -> unit
Sourceval implicitly_close_idle_stream : Reqd.t -> (Stream_identifier.t * Stream_identifier.t) -> unit
Sourceval check_flow : Int32.t -> Int32.t -> Int32.t -> bool
Sourceval add_flow : 'a node -> int32 -> bool
Sourceval add_inflow : 'a node -> int32 -> bool
Sourceval deduct_inflow : 'a node -> int32 -> unit
Sourceval pp_hum : Format.formatter -> root node -> unit