PandacubeFr/BungeeCord
1
0
Fork 0
Code Releases Activity

[#582] Widen synchronized block for packet queue.

Browse Source
This commit is contained in:
md_5 2013-09-26 09:20:52 +10:00
parent cbcd874d47
commit 79d04bec2e
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
proxy/src/main/java/net/md_5/bungee/BungeeServerInfo.java
View File

@ -89,13 +89,13 @@ public class BungeeServerInfo implements ServerInfo
Preconditions.checkNotNull( channel, "channel" ); Preconditions.checkNotNull( channel, "channel" );
Preconditions.checkNotNull( data, "data" ); Preconditions.checkNotNull( data, "data" );
synchronized ( packetQueue )
{
Server server = ( players.isEmpty() ) ? null : players.iterator().next().getServer(); Server server = ( players.isEmpty() ) ? null : players.iterator().next().getServer();
if ( server != null ) if ( server != null )
{ {
server.sendData( channel, data ); server.sendData( channel, data );
} else } else
{
synchronized ( packetQueue )
{ {
packetQueue.add( new PacketFAPluginMessage( channel, data ) ); packetQueue.add( new PacketFAPluginMessage( channel, data ) );
} }