From 12941ffe6280978a9b8d8ebd1ef9eb4d9f085cf0 Mon Sep 17 00:00:00 2001 From: md_5 Date: Mon, 1 Jul 2013 21:25:39 +1000 Subject: [PATCH] Close #471 - sync sqlite operations to guard against deadlocks --- .../java/net/md_5/bungee/reconnect/SQLReconnectHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/proxy/src/main/java/net/md_5/bungee/reconnect/SQLReconnectHandler.java b/proxy/src/main/java/net/md_5/bungee/reconnect/SQLReconnectHandler.java index 0f1d0a2b..f1b8b8ee 100644 --- a/proxy/src/main/java/net/md_5/bungee/reconnect/SQLReconnectHandler.java +++ b/proxy/src/main/java/net/md_5/bungee/reconnect/SQLReconnectHandler.java @@ -33,7 +33,7 @@ public class SQLReconnectHandler extends AbstractReconnectManager } @Override - protected ServerInfo getStoredServer(ProxiedPlayer player) + protected synchronized ServerInfo getStoredServer(ProxiedPlayer player) { String server = null; try ( PreparedStatement ps = connection.prepareStatement( "SELECT server FROM players WHERE username = ?" ) ) @@ -62,7 +62,7 @@ public class SQLReconnectHandler extends AbstractReconnectManager } @Override - public void setServer(ProxiedPlayer player) + public synchronized void setServer(ProxiedPlayer player) { try ( PreparedStatement ps = connection.prepareStatement( "UPDATE players SET server = ?, seen = ? WHERE username = ?" ) ) @@ -83,7 +83,7 @@ public class SQLReconnectHandler extends AbstractReconnectManager } @Override - public void close() + public synchronized void close() { try {