/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/handlers/ |
H A D | account_data.py | 58 max_stream_id = await self._store.add_account_data_to_room( 63 "account_data_key", max_stream_id, users=[user_id] 66 return max_stream_id 97 "account_data_key", max_stream_id, users=[user_id] 99 return max_stream_id 124 max_stream_id = await self._store.add_tag_to_room( 129 "account_data_key", max_stream_id, users=[user_id] 131 return max_stream_id 149 max_stream_id = await self._store.remove_tag_from_room( 154 "account_data_key", max_stream_id, users=[user_id] [all …]
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/replication/http/ |
H A D | account_data.py | 61 max_stream_id = await self.handler.add_account_data_for_user( 65 return 200, {"max_stream_id": max_stream_id} 102 max_stream_id = await self.handler.add_account_data_to_room( 106 return 200, {"max_stream_id": max_stream_id} 143 max_stream_id = await self.handler.add_tag_to_room( 147 return 200, {"max_stream_id": max_stream_id} 181 max_stream_id = await self.handler.remove_tag_from_room( 187 return 200, {"max_stream_id": max_stream_id}
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/databases/main/ |
H A D | state_deltas.py | 31 self, prev_stream_id: int, max_stream_id: int 60 prev_stream_id <= max_stream_id 69 return max_stream_id, [] 86 txn.execute(sql, (prev_stream_id, max_stream_id)) 103 clipped_stream_id = max_stream_id
|
/dports/www/py-h2/h2-4.0.0/src/h2/ |
H A D | exceptions.py | 64 def __init__(self, stream_id, max_stream_id): argument 69 self.max_stream_id = max_stream_id 73 self.stream_id, self.max_stream_id
|
/dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/h2/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/www/firefox-esr/firefox-91.8.0/testing/web-platform/tests/tools/third_party/hyper/hyper/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/blink/tools/blinkpy/third_party/wpt/wpt/tools/third_party/h2/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/www/firefox/firefox-99.0/testing/web-platform/tests/tools/third_party/h2/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/www/firefox/firefox-99.0/testing/web-platform/tests/tools/third_party/hyper/hyper/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/hyper/hyper/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/mail/thunderbird/thunderbird-91.8.0/testing/web-platform/tests/tools/third_party/h2/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/hyper/hyper/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/lang/spidermonkey78/firefox-78.9.0/testing/web-platform/tests/tools/third_party/h2/h2/ |
H A D | exceptions.py | 65 def __init__(self, stream_id, max_stream_id): argument 70 self.max_stream_id = max_stream_id 74 self.stream_id, self.max_stream_id
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/27/ |
H A D | ts.py | 38 max_stream_id = rows[0][0] 40 if min_stream_id is not None and max_stream_id is not None: 43 "max_stream_id_exclusive": max_stream_id + 1,
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/33/ |
H A D | event_fields.py | 38 max_stream_id = rows[0][0] 40 if min_stream_id is not None and max_stream_id is not None: 43 "max_stream_id_exclusive": max_stream_id + 1,
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/31/ |
H A D | search_update.py | 42 max_stream_id = rows[0][0] 44 if min_stream_id is not None and max_stream_id is not None: 47 "max_stream_id_exclusive": max_stream_id + 1,
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/schema/main/delta/25/ |
H A D | fts.py | 59 max_stream_id = rows[0][0] 61 if min_stream_id is not None and max_stream_id is not None: 64 "max_stream_id_exclusive": max_stream_id + 1,
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/push/ |
H A D | pusherpool.py | 214 max_stream_id = max_token.stream 216 if max_stream_id < self._last_room_stream_id_seen: 229 max_stream_id = max_token.stream 232 self._last_room_stream_id_seen = max_stream_id 236 prev_stream_id, max_stream_id 253 self, min_stream_id: int, max_stream_id: int, affected_room_ids: Iterable[str] 263 min_stream_id - 1, max_stream_id 274 p.on_new_receipts(min_stream_id, max_stream_id)
|
/dports/www/h2o-devel/h2o-dcc7134/t/ |
H A D | 50zero-sized-timeout.t | 58 max_stream_id = 0 74 if f.stream_id > max_stream_id 75 max_stream_id = f.stream_id 77 if max_stream_id > f.stream_id
|
H A D | 50zero-sized-streaming-body.t | 63 max_stream_id = 0 80 if f.stream_id > max_stream_id 81 max_stream_id = f.stream_id 83 if max_stream_id > f.stream_id
|
H A D | 50reverse-proxy-serialize-posts-2.t | 63 max_stream_id = 0 80 if f.stream_id > max_stream_id 81 max_stream_id = f.stream_id 83 if max_stream_id > f.stream_id
|
/dports/multimedia/zoneminder/zoneminder-1.36.5/src/ |
H A D | zm_packetqueue.cpp | 33 max_stream_id(-1), in PacketQueue() 45 if (max_stream_id == -1) { in addStream() 47 max_stream_id = 0; in addStream() 49 max_stream_id ++; in addStream() 53 packet_counts = new int[max_stream_id+1]; in addStream() 54 for (int i=0; i <= max_stream_id; ++i) in addStream() 56 return max_stream_id; in addStream() 361 max_stream_id = -1; in clear() 372 if (stream_id < 0 or stream_id > max_stream_id) { in packet_count() 373 Error("Invalid stream_id %d max is %d", stream_id, max_stream_id); in packet_count()
|
/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/storage/util/ |
H A D | sequence.py | 146 max_stream_id = row[0] 172 if max_stream_id > last_value: 178 max_stream_id,
|
/dports/net/oha/oha-0.4.7/cargo-crates/h2-0.3.6/src/proto/streams/ |
H A D | send.rs | 29 max_stream_id: StreamId, field 52 max_stream_id: StreamId::MAX, in new() 394 if last_stream_id > self.max_stream_id { in recv_go_away() 404 last_stream_id, self.max_stream_id, in recv_go_away() 409 self.max_stream_id = last_stream_id; in recv_go_away()
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/h2-0.3.4/src/proto/streams/ |
H A D | send.rs | 28 max_stream_id: StreamId, field 51 max_stream_id: StreamId::MAX, in new() 391 if last_stream_id > self.max_stream_id { in recv_go_away() 401 last_stream_id, self.max_stream_id, in recv_go_away() 406 self.max_stream_id = last_stream_id; in recv_go_away()
|