Home
last modified time | relevance | path

Searched refs:max_stream_id (Results 1 – 25 of 161) sorted by relevance

1234567

/dports/net-im/py-matrix-synapse/synapse-1.50.2/synapse/handlers/
H A Daccount_data.py58 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 Daccount_data.py61 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 Dstate_deltas.py31 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 Dexceptions.py64 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dexceptions.py65 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 Dts.py38 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 Devent_fields.py38 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 Dsearch_update.py42 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 Dfts.py59 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 Dpusherpool.py214 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 D50zero-sized-timeout.t58 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 D50zero-sized-streaming-body.t63 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 D50reverse-proxy-serialize-posts-2.t63 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 Dzm_packetqueue.cpp33 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 Dsequence.py146 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 Dsend.rs29 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 Dsend.rs28 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()

1234567