Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-22 06:44:58 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug where we used an unbound local variable if we ended up rolling back the persist_event transaction

Browse Source
This commit is contained in:
Erik Johnston 2014-09-09 16:27:59 +01:00
parent 1ef51e7939
commit a75f8686ba
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
synapse/storage/__init__.py
View File

@ -77,7 +77,7 @@ class DataStore(RoomMemberStore, RoomStore,
stream_ordering = self.min_token stream_ordering = self.min_token
try: try:
latest = yield self._db_pool.runInteraction( yield self._db_pool.runInteraction(
self._persist_pdu_event_txn, self._persist_pdu_event_txn,
pdu=pdu, pdu=pdu,
event=event, event=event,
@ -86,7 +86,6 @@ class DataStore(RoomMemberStore, RoomStore,
) )
except _RollbackButIsFineException as e: except _RollbackButIsFineException as e:
pass pass
defer.returnValue(latest)
@defer.inlineCallbacks @defer.inlineCallbacks
def get_event(self, event_id, allow_none=False): def get_event(self, event_id, allow_none=False):
@ -214,8 +213,6 @@ class DataStore(RoomMemberStore, RoomStore,
} }
) )
return self._get_room_events_max_id_txn(txn)
@defer.inlineCallbacks @defer.inlineCallbacks
def get_current_state(self, room_id, event_type=None, state_key=""): def get_current_state(self, room_id, event_type=None, state_key=""):
sql = ( sql = (