diff options
| author | Amber Brown <hawkowl@atleastfornow.net> | 2019-05-21 11:36:50 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-05-21 11:36:50 -0500 |
| commit | 4a30e4acb4ef14431914bd42ad09a51bd81d6c3e (patch) | |
| tree | 7857cc1ab121d9255183b51be0e79d8619cc3c8f /synapse/storage/state_deltas.py | |
| parent | Merge pull request #5203 from matrix-org/erikj/aggregate_by_sender (diff) | |
| download | synapse-4a30e4acb4ef14431914bd42ad09a51bd81d6c3e.tar.xz | |
Room Statistics (#4338)
Diffstat (limited to 'synapse/storage/state_deltas.py')
| -rw-r--r-- | synapse/storage/state_deltas.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/synapse/storage/state_deltas.py b/synapse/storage/state_deltas.py index 31a0279b18..5fdb442104 100644 --- a/synapse/storage/state_deltas.py +++ b/synapse/storage/state_deltas.py @@ -84,10 +84,16 @@ class StateDeltasStore(SQLBaseStore): "get_current_state_deltas", get_current_state_deltas_txn ) - def get_max_stream_id_in_current_state_deltas(self): - return self._simple_select_one_onecol( + def _get_max_stream_id_in_current_state_deltas_txn(self, txn): + return self._simple_select_one_onecol_txn( + txn, table="current_state_delta_stream", keyvalues={}, retcol="COALESCE(MAX(stream_id), -1)", - desc="get_max_stream_id_in_current_state_deltas", + ) + + def get_max_stream_id_in_current_state_deltas(self): + return self.runInteraction( + "get_max_stream_id_in_current_state_deltas", + self._get_max_stream_id_in_current_state_deltas_txn, ) |