diff options
| author | Erik Johnston <erik@matrix.org> | 2016-01-28 14:45:36 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2016-01-28 14:45:36 +0000 |
| commit | 167d1df699d64683f1f9ace759c772af1890ca56 (patch) | |
| tree | a9222f66b36c828df5ca2fcd455db820dcd80dca /synapse/storage/stream.py | |
| parent | Quot all the things (diff) | |
| parent | Clean up a bit. Add comment (diff) | |
| download | synapse-167d1df699d64683f1f9ace759c772af1890ca56.tar.xz | |
Merge pull request #534 from matrix-org/erikj/setup
Add a Homeserver.setup method
Diffstat (limited to 'synapse/storage/stream.py')
| -rw-r--r-- | synapse/storage/stream.py | 13 |
1 files changed, 0 insertions, 13 deletions
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py index 02b1913e26..e31bad258a 100644 --- a/synapse/storage/stream.py +++ b/synapse/storage/stream.py @@ -444,19 +444,6 @@ class StreamStore(SQLBaseStore): rows = txn.fetchall() return rows[0][0] if rows else 0 - @defer.inlineCallbacks - def _get_min_token(self): - row = yield self._execute( - "_get_min_token", None, "SELECT MIN(stream_ordering) FROM events" - ) - - self.min_token = row[0][0] if row and row[0] and row[0][0] else -1 - self.min_token = min(self.min_token, -1) - - logger.debug("min_token is: %s", self.min_token) - - defer.returnValue(self.min_token) - @staticmethod def _set_before_and_after(events, rows): for event, row in zip(events, rows): |