From 87db64b83962873a3cf2af951e4c4bc2e4d50d76 Mon Sep 17 00:00:00 2001
From: Erik Johnston <erik@matrix.org>
Date: Fri, 20 Mar 2015 13:52:56 +0000
Subject: Rearrange storage modules

---
 synapse/storage/stream.py | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

(limited to 'synapse/storage/stream.py')

diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py
index 09bc522210..df234efdff 100644
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -419,6 +419,25 @@ class StreamStore(SQLBaseStore):
             self._get_room_events_max_id_txn
         )
 
+    @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)
+
+    def get_next_stream_id(self):
+        with self._next_stream_id_lock:
+            i = self._next_stream_id
+            self._next_stream_id += 1
+            return i
+
     def _get_room_events_max_id_txn(self, txn):
         txn.execute(
             "SELECT MAX(stream_ordering) as m FROM events"
-- 
cgit 1.4.1