| /dports/net-im/py-matrix-synapse/synapse-1.50.2/tests/storage/ |
| H A D | test_devices.py | 129 next_stream_id, device_updates = self.get_success(
137 next_stream_id, device_updates = self.get_success(
138 self.store.get_device_updates_by_remote("somehost", next_stream_id, limit=3)
151 next_stream_id, device_updates = self.get_success(
152 self.store.get_device_updates_by_remote("somehost", next_stream_id, limit=3)
160 self.store.get_device_updates_by_remote("somehost", next_stream_id, limit=3)
228 next_stream_id, device_updates = self.get_success(
245 next_stream_id, device_updates = self.get_success(
246 self.store.get_device_updates_by_remote("somehost", next_stream_id, limit=3)
264 self.store.get_device_updates_by_remote("somehost", next_stream_id, limit=3)
|
| /dports/www/libnghttp2/nghttp2-1.46.0/doc/ |
| H A D | nghttp2_session_set_next_stream_id.rst | 10 …function:: int nghttp2_session_set_next_stream_id(nghttp2_session *session, int32_t next_stream_id)
13 Tells the *session* that next stream ID is *next_stream_id*. The
14 *next_stream_id* must be equal or greater than the value returned
21 The *next_stream_id* is strictly less than the value
23 *next_stream_id* is invalid (e.g., even integer for client, or
|
| /dports/www/nghttp2/nghttp2-1.46.0/doc/ |
| H A D | nghttp2_session_set_next_stream_id.rst | 10 …function:: int nghttp2_session_set_next_stream_id(nghttp2_session *session, int32_t next_stream_id)
13 Tells the *session* that next stream ID is *next_stream_id*. The
14 *next_stream_id* must be equal or greater than the value returned
21 The *next_stream_id* is strictly less than the value
23 *next_stream_id* is invalid (e.g., even integer for client, or
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-proto/src/circuit/ |
| H A D | streammap.rs | 63 next_stream_id: u16, field
70 let next_stream_id: u16 = loop { in new() localVariable
78 next_stream_id, in new()
105 let id: StreamId = self.next_stream_id.into(); in add_ent()
106 self.next_stream_id = self.next_stream_id.wrapping_add(1); in add_ent()
206 let mut next_id = map.next_stream_id; in streammap_basics()
|
| /dports/www/h2o-devel/h2o-dcc7134/fuzz/ |
| H A D | quicly_mock.c | 49 conn->super.local.bidi.next_stream_id = 0; in create_connection()
50 conn->super.local.uni.next_stream_id = 2; in create_connection()
51 conn->super.remote.bidi.next_stream_id = 1; in create_connection()
52 conn->super.remote.uni.next_stream_id = 3; in create_connection()
54 conn->super.local.bidi.next_stream_id = 1; in create_connection()
55 conn->super.local.uni.next_stream_id = 3; in create_connection()
56 conn->super.remote.bidi.next_stream_id = 0; in create_connection()
57 conn->super.remote.uni.next_stream_id = 2; in create_connection()
262 *stream = open_stream(conn, group->next_stream_id); in mquicly_open_stream()
263 group->next_stream_id += 4; in mquicly_open_stream()
|
| /dports/databases/grass7/grass-7.8.6/raster/r.stream.extract/ |
| H A D | del_streams.c | 8 int seg_length(CELL stream_id, CELL *next_stream_id) in seg_length() argument
19 if (next_stream_id) in seg_length()
20 *next_stream_id = stream_id; in seg_length()
36 if (next_stream_id) in seg_length()
37 *next_stream_id = curr_stream; in seg_length()
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/h2-0.3.7/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
53 next_stream_id: Ok(config.local_next_stream_id), in new()
66 self.next_stream_id = stream_id.next_id(); in open()
72 self.next_stream_id = stream_id.next_id(); in reserve_local()
523 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
534 self.next_stream_id in ensure_next_stream_id()
539 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
549 if let Ok(next_id) = self.next_stream_id { in maybe_reset_next_stream_id()
553 self.next_stream_id = id.next_id(); in maybe_reset_next_stream_id()
|
| /dports/lang/gleam/gleam-0.18.2/cargo-crates/h2-0.3.9/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
60 next_stream_id: Ok(config.local_next_stream_id), in new()
74 self.next_stream_id = stream_id.next_id(); in open()
80 self.next_stream_id = stream_id.next_id(); in reserve_local()
529 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
540 self.next_stream_id in ensure_next_stream_id()
545 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
555 if let Ok(next_id) = self.next_stream_id { in maybe_reset_next_stream_id()
559 self.next_stream_id = id.next_id(); in maybe_reset_next_stream_id()
|
| /dports/audio/gnome-podcasts/podcasts-c86f7bfdef7692bbf20f315a90450321f6ca9ce7/cargo-crates/h2-0.3.9/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
60 next_stream_id: Ok(config.local_next_stream_id), in new()
74 self.next_stream_id = stream_id.next_id(); in open()
80 self.next_stream_id = stream_id.next_id(); in reserve_local()
529 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
540 self.next_stream_id in ensure_next_stream_id()
545 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
555 if let Ok(next_id) = self.next_stream_id { in maybe_reset_next_stream_id()
559 self.next_stream_id = id.next_id(); in maybe_reset_next_stream_id()
|
| /dports/textproc/mdbook-linkcheck/mdbook-linkcheck-0.7.6/cargo-crates/h2-0.3.7/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
53 next_stream_id: Ok(config.local_next_stream_id), in new()
66 self.next_stream_id = stream_id.next_id(); in open()
72 self.next_stream_id = stream_id.next_id(); in reserve_local()
523 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
534 self.next_stream_id in ensure_next_stream_id()
539 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
549 if let Ok(next_id) = self.next_stream_id { in maybe_reset_next_stream_id()
553 self.next_stream_id = id.next_id(); in maybe_reset_next_stream_id()
|
| /dports/www/zola/zola-0.15.2/cargo-crates/h2-0.3.7/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
53 next_stream_id: Ok(config.local_next_stream_id), in new()
66 self.next_stream_id = stream_id.next_id(); in open()
72 self.next_stream_id = stream_id.next_id(); in reserve_local()
523 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
534 self.next_stream_id in ensure_next_stream_id()
539 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
549 if let Ok(next_id) = self.next_stream_id { in maybe_reset_next_stream_id()
553 self.next_stream_id = id.next_id(); in maybe_reset_next_stream_id()
|
| /dports/audio/ncspot/ncspot-0.9.3/cargo-crates/h2-0.3.9/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
60 next_stream_id: Ok(config.local_next_stream_id), in new()
74 self.next_stream_id = stream_id.next_id(); in open()
80 self.next_stream_id = stream_id.next_id(); in reserve_local()
529 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
540 self.next_stream_id in ensure_next_stream_id()
545 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
555 if let Ok(next_id) = self.next_stream_id { in maybe_reset_next_stream_id()
559 self.next_stream_id = id.next_id(); in maybe_reset_next_stream_id()
|
| /dports/sysutils/u-boot-tools/u-boot-2020.07/drivers/pci/ |
| H A D | pcie_layerscape_fixup_common.c | 117 static int next_stream_id = FSL_PEX_STREAM_ID_START; in pcie_next_streamid() local
119 if (next_stream_id > FSL_PEX_STREAM_ID_END) in pcie_next_streamid()
122 return next_stream_id++; in pcie_next_streamid()
|
| /dports/net/oha/oha-0.4.7/cargo-crates/h2-0.3.6/src/proto/streams/ |
| H A D | send.rs | 20 next_stream_id: Result<StreamId, StreamIdOverflow>, field
53 next_stream_id: Ok(config.local_next_stream_id), in new()
66 self.next_stream_id = stream_id.next_id(); in open()
72 self.next_stream_id = stream_id.next_id(); in reserve_local()
523 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
534 self.next_stream_id in ensure_next_stream_id()
539 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/h2-0.3.4/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
52 next_stream_id: Ok(config.local_next_stream_id), in new()
65 self.next_stream_id = stream_id.next_id(); in open()
71 self.next_stream_id = stream_id.next_id(); in reserve_local()
520 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
531 self.next_stream_id in ensure_next_stream_id()
536 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/h2-0.2.4/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
50 next_stream_id: Ok(config.local_next_stream_id), in new()
62 self.next_stream_id = stream_id.next_id(); in open()
68 self.next_stream_id = stream_id.next_id(); in reserve_local()
509 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
520 self.next_stream_id in ensure_next_stream_id()
525 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/net-im/fractal/fractal-4.4.0/vendor/h2/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
50 next_stream_id: Ok(config.local_next_stream_id), in new()
62 self.next_stream_id = stream_id.next_id(); in open()
68 self.next_stream_id = stream_id.next_id(); in reserve_local()
509 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
520 self.next_stream_id in ensure_next_stream_id()
525 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/net/routinator/routinator-0.10.2/cargo-crates/h2-0.3.3/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
52 next_stream_id: Ok(config.local_next_stream_id), in new()
65 self.next_stream_id = stream_id.next_id(); in open()
71 self.next_stream_id = stream_id.next_id(); in reserve_local()
520 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
531 self.next_stream_id in ensure_next_stream_id()
536 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/textproc/angle-grinder/angle-grinder-0.18.0/cargo-crates/h2-0.2.7/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
52 next_stream_id: Ok(config.local_next_stream_id), in new()
65 self.next_stream_id = stream_id.next_id(); in open()
71 self.next_stream_id = stream_id.next_id(); in reserve_local()
520 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
531 self.next_stream_id in ensure_next_stream_id()
536 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/www/rearx/rearx-0.1.4/cargo-crates/h2-0.3.1/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
52 next_stream_id: Ok(config.local_next_stream_id), in new()
65 self.next_stream_id = stream_id.next_id(); in open()
71 self.next_stream_id = stream_id.next_id(); in reserve_local()
520 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
531 self.next_stream_id in ensure_next_stream_id()
536 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/security/cargo-audit/rustsec-cargo-audit-v0.15.2/cargo-audit/cargo-crates/h2-0.2.7/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
52 next_stream_id: Ok(config.local_next_stream_id), in new()
65 self.next_stream_id = stream_id.next_id(); in open()
71 self.next_stream_id = stream_id.next_id(); in reserve_local()
520 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
531 self.next_stream_id in ensure_next_stream_id()
536 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/www/firefox/firefox-99.0/third_party/rust/h2/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
50 next_stream_id: Ok(config.local_next_stream_id), in new()
62 self.next_stream_id = stream_id.next_id(); in open()
68 self.next_stream_id = stream_id.next_id(); in reserve_local()
509 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
520 self.next_stream_id in ensure_next_stream_id()
525 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/net/proby/proby-1.0.2/cargo-crates/h2-0.2.6/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
50 next_stream_id: Ok(config.local_next_stream_id), in new()
62 self.next_stream_id = stream_id.next_id(); in open()
68 self.next_stream_id = stream_id.next_id(); in reserve_local()
509 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
520 self.next_stream_id in ensure_next_stream_id()
525 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/games/abstreet/abstreet-0.2.9-49-g74aca40c0/cargo-crates/h2-0.2.5/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
50 next_stream_id: Ok(config.local_next_stream_id), in new()
62 self.next_stream_id = stream_id.next_id(); in open()
68 self.next_stream_id = stream_id.next_id(); in reserve_local()
509 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
520 self.next_stream_id in ensure_next_stream_id()
525 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/rust/h2/src/proto/streams/ |
| H A D | send.rs | 19 next_stream_id: Result<StreamId, StreamIdOverflow>, field
50 next_stream_id: Ok(config.local_next_stream_id), in new()
62 self.next_stream_id = stream_id.next_id(); in open()
68 self.next_stream_id = stream_id.next_id(); in reserve_local()
509 if let Ok(next) = self.next_stream_id { in ensure_not_idle()
520 self.next_stream_id in ensure_next_stream_id()
525 if let Ok(next_id) = self.next_stream_id { in may_have_created_stream()
|