Home
last modified time | relevance | path

Searched refs:stream_id (Results 1 – 25 of 4491) sorted by relevance

12345678910>>...180

/dports/www/p5-Protocol-HTTP2/Protocol-HTTP2-1.10/lib/Protocol/HTTP2/
H A DStream.pm46 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 Dtest_h3.py101 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 Dtest_h3.py101 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 Dtest_h3.py101 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 Dfifo_write_scheduler.h67 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 Dlifo_write_scheduler.h98 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 Dtest_h3.py140 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 Dtest_h0.py39 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 Dtest_webtransport.py33 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 Dfifo_write_scheduler.h61 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 Dlifo_write_scheduler.h94 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 Dtest_priority.py50 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 Devents.rs17 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 Dpriority.py88 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 Dh2load_http3_session.cc56 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 Dh2load_http3_session.cc56 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 Dh2load_http3_session.cc56 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 Devents.rs30 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 Devents.rs30 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 Dh2.py135 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 Dpriority.py93 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.py34 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 Dconnection.rs234 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 Dclient_events.rs18 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 Dhttp2_base_server.py78 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 …]

12345678910>>...180