summary refs log tree commit diff
path: root/synapse
diff options
context:
space:
mode:
Diffstat (limited to 'synapse')
-rw-r--r--synapse/federation/replication.py23
1 files changed, 0 insertions, 23 deletions
diff --git a/synapse/federation/replication.py b/synapse/federation/replication.py
index dd8124dbb9..e798304353 100644
--- a/synapse/federation/replication.py
+++ b/synapse/federation/replication.py
@@ -356,12 +356,6 @@ class ReplicationLayer(object):
             )
         else:
             raise NotImplementedError("Specify an event")
-        #     results = yield self.store.get_current_state_for_context(
-        #         context
-        #     )
-        #     pdus = [Pdu.from_pdu_tuple(p) for p in results]
-        #
-        # logger.debug("Context returning %d results", len(pdus))
 
         defer.returnValue((200, self._transaction_from_pdus(pdus).get_dict()))
 
@@ -382,21 +376,6 @@ class ReplicationLayer(object):
     def on_pull_request(self, origin, versions):
         raise NotImplementedError("Pull transacions not implemented")
 
-        # transaction_id = max([int(v) for v in versions])
-        #
-        # response = yield self.pdu_actions.after_transaction(
-        #     transaction_id,
-        #     origin,
-        #     self.server_name
-        # )
-        #
-        # if not response:
-        #     response = []
-        #
-        # defer.returnValue(
-        #     (200, self._transaction_from_pdus(response).get_dict())
-        # )
-
     @defer.inlineCallbacks
     def on_query_request(self, query_type, args):
         if query_type in self.query_handlers:
@@ -570,8 +549,6 @@ class ReplicationLayer(object):
                     origin, pdu.room_id, pdu.event_id,
                 )
 
-        # Persist the Pdu, but don't mark it as processed yet.
-        # yield self.store.persist_event(pdu=pdu)
 
         if not backfilled:
             ret = yield self.handler.on_receive_pdu(