From 79d04bec2ed5f1b9487437d2ed3d291ba416097d Mon Sep 17 00:00:00 2001 From: md_5 Date: Thu, 26 Sep 2013 09:20:52 +1000 Subject: [PATCH] [#582] Widen synchronized block for packet queue. --- .../main/java/net/md_5/bungee/BungeeServerInfo.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/proxy/src/main/java/net/md_5/bungee/BungeeServerInfo.java b/proxy/src/main/java/net/md_5/bungee/BungeeServerInfo.java index ea533a1b..489b2082 100644 --- a/proxy/src/main/java/net/md_5/bungee/BungeeServerInfo.java +++ b/proxy/src/main/java/net/md_5/bungee/BungeeServerInfo.java @@ -89,13 +89,13 @@ public class BungeeServerInfo implements ServerInfo Preconditions.checkNotNull( channel, "channel" ); Preconditions.checkNotNull( data, "data" ); - Server server = ( players.isEmpty() ) ? null : players.iterator().next().getServer(); - if ( server != null ) + synchronized ( packetQueue ) { - server.sendData( channel, data ); - } else - { - synchronized ( packetQueue ) + Server server = ( players.isEmpty() ) ? null : players.iterator().next().getServer(); + if ( server != null ) + { + server.sendData( channel, data ); + } else { packetQueue.add( new PacketFAPluginMessage( channel, data ) ); }