/dports/www/p5-Protocol-HTTP2/Protocol-HTTP2-1.10/lib/Protocol/HTTP2/ |
H A D | Stream.pm | 46 my $stream_id = shift; 65 $self->{streams}->{$stream_id} = { 79 my ( $self, $stream_id ) = @_; 82 $self->{streams}->{$stream_id}; 89 my $stream_id = shift; 135 my $stream_id = shift; 164 my $stream_id = shift; 186 my $stream_id = shift; 332 my $stream_id = shift; 352 my ( $self, $stream_id ) = @_; [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/tests/ |
H A D | test_h3.py | 101 stream_id=stream_id, 125 stream_id=stream_id, 134 stream_id=stream_id, 142 stream_id=stream_id, 430 stream_id=stream_id, 517 stream_id=stream_id, 589 stream_id=stream_id, 627 stream_id=stream_id, 639 stream_id=stream_id, 936 stream_id=stream_id, [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/aioquic/tests/ |
H A D | test_h3.py | 101 stream_id=stream_id, 125 stream_id=stream_id, 134 stream_id=stream_id, 142 stream_id=stream_id, 430 stream_id=stream_id, 517 stream_id=stream_id, 589 stream_id=stream_id, 627 stream_id=stream_id, 639 stream_id=stream_id, 936 stream_id=stream_id, [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/aioquic/tests/ |
H A D | test_h3.py | 101 stream_id=stream_id, 125 stream_id=stream_id, 134 stream_id=stream_id, 142 stream_id=stream_id, 430 stream_id=stream_id, 517 stream_id=stream_id, 589 stream_id=stream_id, 627 stream_id=stream_id, 639 stream_id=stream_id, 936 stream_id=stream_id, [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/spdy/core/ |
H A D | fifo_write_scheduler.h | 67 StreamIdType stream_id, in RegisterStream() argument 69 if (StreamRegistered(stream_id)) { in RegisterStream() 80 StreamIdType stream_id) { in UnregisterStream() argument 86 ready_streams_.erase(stream_id); in UnregisterStream() 91 StreamIdType stream_id) const { in StreamRegistered() argument 99 StreamIdType stream_id) const { in GetStreamPrecedence() argument 110 StreamIdType stream_id, in UpdateStreamPrecedence() argument 128 StreamIdType stream_id, in RecordStreamEventTime() argument 140 StreamIdType stream_id) const { in GetLatestEventWithPrecedence() argument 148 if (stream_id <= it->first) { in GetLatestEventWithPrecedence() [all …]
|
H A D | lifo_write_scheduler.h | 98 StreamIdType stream_id, in RegisterStream() argument 100 if (StreamRegistered(stream_id)) { in RegisterStream() 111 StreamIdType stream_id) { in UnregisterStream() argument 117 ready_streams_.erase(stream_id); in UnregisterStream() 123 StreamIdType stream_id) const { in GetStreamPrecedence() argument 134 StreamIdType stream_id, in UpdateStreamPrecedence() argument 146 StreamIdType stream_id, in RecordStreamEventTime() argument 158 StreamIdType stream_id) const { in GetLatestEventWithPrecedence() argument 166 if (stream_id < it->first) { in GetLatestEventWithPrecedence() 200 ready_streams_.insert(stream_id); in MarkStreamReady() [all …]
|
/dports/www/py-aioquic/aioquic-0.9.17/tests/ |
H A D | test_h3.py | 140 stream_id=stream_id, 164 stream_id=stream_id, 173 stream_id=stream_id, 181 stream_id=stream_id, 575 stream_id=stream_id, 584 stream_id=stream_id, 666 stream_id=stream_id, 698 stream_id=stream_id, 732 stream_id=stream_id, 1090 stream_id=stream_id, [all …]
|
H A D | test_h0.py | 39 stream_id=stream_id, 57 self.assertEqual(events[0].stream_id, stream_id) 62 self.assertEqual(events[1].stream_id, stream_id) 67 stream_id=stream_id, 74 stream_id=stream_id, 85 self.assertEqual(events[0].stream_id, stream_id) 90 self.assertEqual(events[1].stream_id, stream_id) 101 stream_id=stream_id, 119 self.assertEqual(events[0].stream_id, stream_id) 124 self.assertEqual(events[1].stream_id, stream_id) [all …]
|
H A D | test_webtransport.py | 33 stream_id=stream_id, 56 stream_id=stream_id, 65 stream_id=stream_id, 80 stream_id=stream_id, 112 stream_id=stream_id, 141 stream_id=stream_id, 147 stream_id=stream_id, 153 stream_id=stream_id, 159 stream_id=stream_id, 188 stream_id=stream_id, [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/spdy/core/ |
H A D | fifo_write_scheduler.h | 61 StreamIdType stream_id, in RegisterStream() argument 63 if (StreamRegistered(stream_id)) { in RegisterStream() 72 StreamIdType stream_id) { in UnregisterStream() argument 78 ready_streams_.erase(stream_id); in UnregisterStream() 83 StreamIdType stream_id) const { in StreamRegistered() argument 108 StreamIdType stream_id, in RecordStreamEventTime() argument 120 StreamIdType stream_id) const { in GetLatestEventWithPrecedence() argument 128 if (stream_id <= it->first) { in GetLatestEventWithPrecedence() 138 StreamIdType stream_id) const { in ShouldYield() argument 153 ready_streams_.insert(stream_id); in MarkStreamReady() [all …]
|
H A D | lifo_write_scheduler.h | 94 StreamIdType stream_id, in RegisterStream() argument 96 if (StreamRegistered(stream_id)) { in RegisterStream() 105 StreamIdType stream_id) { in UnregisterStream() argument 106 if (!StreamRegistered(stream_id)) { in UnregisterStream() 111 ready_streams_.erase(stream_id); in UnregisterStream() 116 StreamIdType stream_id, in RecordStreamEventTime() argument 128 StreamIdType stream_id) const { in GetLatestEventWithPrecedence() argument 136 if (stream_id < it->first) { in GetLatestEventWithPrecedence() 170 ready_streams_.insert(stream_id); in MarkStreamReady() 175 StreamIdType stream_id) { in MarkStreamNotReady() argument [all …]
|
/dports/www/py-priority/priority-2.0.0/test/ |
H A D | test_priority.py | 50 p.insert_stream(stream_id=1) 51 p.insert_stream(stream_id=3) 87 for stream_id in tree: 160 for stream_id in blocked: 246 stream_id=stream, 443 stream_id=stream_id, depends_on=stream_id, exclusive=exclusive 453 p.insert_stream(stream_id=stream_id) 456 stream_id=stream_id, depends_on=stream_id, exclusive=exclusive 569 action(stream_id) 580 if stream_id != 0: [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/neqo-transport/src/ |
H A D | events.rs | 17 use crate::stream_id::StreamId; 26 stream_id: u64, 62 stream_id: stream_id.as_u64(), in new_stream() 69 stream_id: stream_id.as_u64(), in recv_stream_readable() 78 stream_id: stream_id.as_u64(), in recv_stream_reset() 85 stream_id: stream_id.as_u64(), in send_stream_writable() 94 stream_id: stream_id.as_u64(), in send_stream_stop_sending() 105 stream_id: stream_id.as_u64(), in send_stream_complete() 156 if *x == *stream_id) in insert() 161 if *x == *stream_id) in insert() [all …]
|
/dports/www/py-priority1/priority-1.3.0/src/priority/ |
H A D | priority.py | 88 self.stream_id = stream_id 216 return self.stream_id == other.stream_id 225 return self.stream_id < other.stream_id 231 return self.stream_id <= other.stream_id 237 return self.stream_id > other.stream_id 243 return self.stream_id >= other.stream_id 257 if parent.stream_id == current.stream_id: 382 if stream_id == 0: 431 if stream_id == 0: 448 if stream_id == 0: [all …]
|
/dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/ |
H A D | h2load_http3_session.cc | 56 if (stream_id < 0) { in submit_request() 92 int64_t stream_id; in submit_request_internal() local 112 client_->on_request(stream_id); in submit_request_internal() 117 return stream_id; in submit_request_internal() 142 if (!ngtcp2_is_bidi_stream(stream_id)) { in stream_close() 154 s->recv_data(stream_id, data, datalen); in recv_data() 163 consume(stream_id, datalen); in recv_data() 170 s->consume(stream_id, nconsumed); in deferred_consume() 185 s->begin_headers(stream_id); in begin_headers() 204 s->recv_header(stream_id, &k, &v); in recv_header() [all …]
|
/dports/www/libnghttp2/nghttp2-1.46.0/src/ |
H A D | h2load_http3_session.cc | 56 if (stream_id < 0) { in submit_request() 92 int64_t stream_id; in submit_request_internal() local 112 client_->on_request(stream_id); in submit_request_internal() 117 return stream_id; in submit_request_internal() 142 if (!ngtcp2_is_bidi_stream(stream_id)) { in stream_close() 154 s->recv_data(stream_id, data, datalen); in recv_data() 163 consume(stream_id, datalen); in recv_data() 170 s->consume(stream_id, nconsumed); in deferred_consume() 185 s->begin_headers(stream_id); in begin_headers() 204 s->recv_header(stream_id, &k, &v); in recv_header() [all …]
|
/dports/www/nghttp2/nghttp2-1.46.0/src/ |
H A D | h2load_http3_session.cc | 56 if (stream_id < 0) { in submit_request() 92 int64_t stream_id; in submit_request_internal() local 112 client_->on_request(stream_id); in submit_request_internal() 117 return stream_id; in submit_request_internal() 142 if (!ngtcp2_is_bidi_stream(stream_id)) { in stream_close() 154 s->recv_data(stream_id, data, datalen); in recv_data() 163 consume(stream_id, datalen); in recv_data() 170 s->consume(stream_id, nconsumed); in deferred_consume() 185 s->begin_headers(stream_id); in begin_headers() 204 s->recv_header(stream_id, &k, &v); in recv_header() [all …]
|
/dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/neqo-transport/src/ |
H A D | events.rs | 30 stream_id: StreamId, 34 stream_id: StreamId, 38 stream_id: u64, 42 stream_id: u64, 47 stream_id: u64, 52 stream_id: u64, 88 stream_id: stream_id.as_u64(), in recv_stream_readable() 97 stream_id: stream_id.as_u64(), in recv_stream_reset() 111 stream_id: stream_id.as_u64(), in send_stream_stop_sending() 122 stream_id: stream_id.as_u64(), in send_stream_complete() [all …]
|
/dports/www/firefox-esr/firefox-91.8.0/third_party/rust/neqo-transport/src/ |
H A D | events.rs | 30 stream_id: StreamId, 34 stream_id: StreamId, 38 stream_id: u64, 42 stream_id: u64, 47 stream_id: u64, 52 stream_id: u64, 88 stream_id: stream_id.as_u64(), in recv_stream_readable() 97 stream_id: stream_id.as_u64(), in recv_stream_reset() 111 stream_id: stream_id.as_u64(), in send_stream_stop_sending() 122 stream_id: stream_id.as_u64(), in send_stream_complete() [all …]
|
/dports/www/py-hypercorn/Hypercorn-0.12.0/src/hypercorn/protocol/ |
H A D | h2.py | 135 await self.streams[event.stream_id].handle(EndBody(stream_id=event.stream_id)) 233 Body(stream_id=event.stream_id, data=event.data) 239 await self.streams[event.stream_id].handle(EndBody(stream_id=event.stream_id)) 260 if stream_id is None or stream_id == 0: 264 elif stream_id is not None and stream_id in self.stream_buffers: 271 stream_id=event.stream_id, 279 stream_id=event.stream_id, 327 stream_id=request.stream_id, 344 stream_id=stream_id, 358 await self.streams[event.stream_id].handle(EndBody(stream_id=event.stream_id)) [all …]
|
/dports/www/py-priority/priority-2.0.0/src/priority/ |
H A D | priority.py | 93 self.stream_id = stream_id 224 return self.stream_id == other.stream_id 233 return self.stream_id < other.stream_id 239 return self.stream_id <= other.stream_id 245 return self.stream_id > other.stream_id 251 return self.stream_id >= other.stream_id 265 if parent.stream_id == current.stream_id: 341 stream_id: int, 385 stream_id: int, 401 if stream_id == 0: [all …]
|
/dports/www/mitmproxy/mitmproxy-7.0.4/mitmproxy/proxy/layers/http/ |
H A D | _events.py | 34 def __init__(self, stream_id: int, data: bytes): 35 self.stream_id = stream_id 44 self.stream_id = stream_id 53 self.stream_id = stream_id 62 self.stream_id = stream_id 68 def __init__(self, stream_id: int): 69 self.stream_id = stream_id 74 def __init__(self, stream_id: int): 75 self.stream_id = stream_id 84 self.stream_id = stream_id [all …]
|
/dports/www/firefox/firefox-99.0/third_party/rust/neqo-http3/src/ |
H A D | connection.rs | 234 stream_id, in add_new_stream() 323 stream_id, in handle_stream_reset() 339 stream_id, in handle_stream_stop_sending() 653 stream_id, in fetch_with_stream() 664 stream_id, in fetch_with_stream() 720 stream_id, in stream_reset_send() 742 stream_id, in stream_stop_sending() 999 stream_id, in webtransport_create_stream_local() 1005 Ok(stream_id) in webtransport_create_stream_local() 1018 stream_id in webtransport_create_stream_remote() [all …]
|
/dports/lang/spidermonkey78/firefox-78.9.0/third_party/rust/neqo-http3/src/ |
H A D | client_events.rs | 18 HeaderReady { stream_id: u64 }, 20 DataWritable { stream_id: u64 }, 22 DataReadable { stream_id: u64 }, 24 Reset { stream_id: u64, error: AppError }, 26 StopSending { stream_id: u64, error: AppError }, 28 NewPushStream { stream_id: u64 }, 47 pub fn header_ready(&self, stream_id: u64) { in header_ready() 51 pub fn data_writable(&self, stream_id: u64) { in data_writable() 55 pub fn data_readable(&self, stream_id: u64) { in data_readable() 63 stream_id: x } if *x == stream_id) in stop_sending() [all …]
|
/dports/devel/grpc/grpc-1.42.0/test/http2_test/ |
H A D | http2_base_server.py | 78 event.stream_id) 83 event.stream_id) 88 event.stream_id) 106 self._stream_id = event.stream_id 109 stream_id=event.stream_id, 125 self.default_send(stream_id, 135 stream_id, argument 142 self.default_send(stream_id, 147 stream_id, argument 196 if self._stream_status[stream_id]: [all …]
|