summary refs log tree commit diff
path: root/synapse/handlers/sync.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-03-16 11:56:59 +0000
committerErik Johnston <erik@matrix.org>2017-03-16 11:57:45 +0000
commita158c36a8a739226347e56b87047a97507442dff (patch)
tree24cbeba900b519e1d80df551e0d5d835e599e7bb /synapse/handlers/sync.py
parentDon't recreate so many sets (diff)
downloadsynapse-a158c36a8a739226347e56b87047a97507442dff.tar.xz
Comment
Diffstat (limited to 'synapse/handlers/sync.py')
-rw-r--r--synapse/handlers/sync.py11
1 files changed, 8 insertions, 3 deletions
diff --git a/synapse/handlers/sync.py b/synapse/handlers/sync.py
index e17fb30733..3dbedb2c40 100644
--- a/synapse/handlers/sync.py
+++ b/synapse/handlers/sync.py
@@ -764,6 +764,8 @@ class SyncHandler(object):
             )
             sync_result_builder.now_token = now_token
 
+        # We check up front if anything has changed, if it hasn't then there is
+        # no point in going futher.
         since_token = sync_result_builder.since_token
         if not sync_result_builder.full_state:
             if since_token and not ephemeral_by_room and not account_data_by_room:
@@ -830,11 +832,14 @@ class SyncHandler(object):
 
     @defer.inlineCallbacks
     def _have_rooms_changed(self, sync_result_builder):
+        """Returns whether any rooms have changed since the sync. Must be an
+        incremental sync
+        """
         user_id = sync_result_builder.sync_config.user.to_string()
         since_token = sync_result_builder.since_token
         now_token = sync_result_builder.now_token
 
-        # assert since_token
+        assert since_token
 
         # Get a list of membership change events that have happened.
         rooms_changed = yield self.store.get_membership_changes_for_user(
@@ -851,9 +856,9 @@ class SyncHandler(object):
         else:
             joined_room_ids = yield self.store.get_rooms_for_user(user_id)
 
-        strema_id = RoomStreamToken.parse_stream_token(since_token.room_key).stream
+        stream_id = RoomStreamToken.parse_stream_token(since_token.room_key).stream
         for room_id in joined_room_ids:
-            if self.store.has_room_changed_since(room_id, strema_id):
+            if self.store.has_room_changed_since(room_id, stream_id):
                 defer.returnValue(True)
         defer.returnValue(False)