| Overview |  |
pending_send() = {data, reference() | undefined, pid() | undefined, iodata(), boolean()}
stream_entry() = #{state := stream_state(), counted := boolean(), header_fragment := iodata(), header_len := non_neg_integer(), end_headers := boolean(), end_stream_seen := boolean(), headers := undefined | roadrunner_http:headers(), body := iolist(), body_len := non_neg_integer(), send_window := integer(), recv_window := non_neg_integer(), worker_pid := undefined | pid(), worker_ref := undefined | reference(), pending_sends := queue:queue(pending_send()), refused => roadrunner_http2_frame:error_code()}
stream_id() = pos_integer()
stream_state() = open | half_closed_remote | half_closed_local | closed
| enter/6 | |
| recv_more_hib/1 |
enter(Socket::roadrunner_transport:socket(), ProtoOpts::roadrunner_conn:proto_opts(), ListenerName::atom(), Peer::{inet:ip_address(), inet:port_number()} | undefined, StartMono::integer(), Buffered::binary()) -> no_return()
recv_more_hib(Loop::#loop{socket = roadrunner_transport:socket(), proto_opts = roadrunner_conn:proto_opts(), listener_name = atom(), peer = {inet:ip_address(), inet:port_number()} | undefined, start_mono = integer(), scheme = http | https, msg_data = atom(), msg_closed = atom(), msg_error = atom(), buffer = binary(), hpack_dec = roadrunner_http2_hpack:context(), hpack_enc = roadrunner_http2_hpack:context(), last_stream_id = non_neg_integer(), peer_stream_id = non_neg_integer(), req_id_buffer = binary(), conn_send_window = integer(), conn_recv_window = non_neg_integer(), recv_window_peak = pos_integer(), stream_recv_window_peak = pos_integer(), recv_window_threshold = pos_integer(), max_concurrent_streams = pos_integer(), live_streams = non_neg_integer(), max_header_block = pos_integer(), max_content_length = non_neg_integer(), max_header_list_size = pos_integer(), hibernate_after = non_neg_integer(), handshake_timeout = non_neg_integer(), idle_timeout = non_neg_integer(), alt_svc = binary() | undefined, max_concurrent_requests = infinity | pos_integer(), inflight_counter = counters:counters_ref() | undefined, overload = roadrunner_conn:overload(), awaiting_slot = #{stream_id() => roadrunner_req:request()}, rate_limit = roadrunner_conn:rate_limit_state(), streams = #{stream_id() => stream_entry()}, worker_refs = #{reference() => stream_id()}, awaiting_continuation = undefined | stream_id(), peer_initial_window = integer(), draining = boolean()}) -> no_return()
Generated by EDoc