mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-23 01:55:53 +03:00
Code Issues Projects Releases Packages Wiki Activity

Fix bug where we reconnected to the database on every query.

Browse source
This commit is contained in:
Erik Johnston 2015-05-01 10:24:24 +01:00
parent 23c639ff32
commit fabb7acd45
2 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
synapse/storage/_base.py
View file

@ -301,6 +301,7 @@ class SQLBaseStore(object):
def inner_func(conn, *args, **kwargs): def inner_func(conn, *args, **kwargs):
with LoggingContext("runInteraction") as context: with LoggingContext("runInteraction") as context:
if self.database_engine.is_connection_closed(conn): if self.database_engine.is_connection_closed(conn):
logger.debug("Reconnecting closed database connection")
conn.reconnect() conn.reconnect()
current_context.copy_to(context) current_context.copy_to(context)

2
synapse/storage/engines/postgres.py
View file

@ -53,7 +53,7 @@ class PostgresEngine(object):
return False return False
def is_connection_closed(self, conn): def is_connection_closed(self, conn):
return bool(conn) return bool(conn.closed)
def lock_table(self, txn, table): def lock_table(self, txn, table):
txn.execute("LOCK TABLE %s in EXCLUSIVE MODE" % (table,)) txn.execute("LOCK TABLE %s in EXCLUSIVE MODE" % (table,))