lineage2/l2j_mobius
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Addition of GameClient pending packet queue.

Browse Source
This commit is contained in:
MobiusDevelopment
2022-12-02 06:05:40 +00:00
parent 0ebddd779a
commit 4ab90ca2df
31 changed files with 590 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
L2J_Mobius_C4_ScionsOfDestiny/java/org/l2jmobius/gameserver/network/GameClient.java
View File

@@ -22,6 +22,8 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;
import java.util.Queue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.locks.ReentrantLock;
@@ -68,6 +70,7 @@ public class GameClient extends NetClient
(byte) 0x87 // The last 4 bytes are fixed.
};
private final Queue<ServerPacket> _pendingPackets = new ConcurrentLinkedQueue<>();
private final FloodProtectors _floodProtectors = new FloodProtectors(this);
private final ReentrantLock _playerLock = new ReentrantLock();
private ConnectionState _connectionState = ConnectionState.CONNECTED;
@@ -183,23 +186,28 @@ public class GameClient extends NetClient
return;
}
try
_pendingPackets.add(packet);
synchronized (_pendingPackets)
{
if ((getChannel() != null) && getChannel().isConnected())
try
{
final ByteBuffer byteBuffer = packet.getSendableByteBuffer(_encryption);
if (byteBuffer != null)
if ((getChannel() != null) && getChannel().isConnected())
{
// Send the packet data.
getChannel().write(byteBuffer);
// Run packet implementation.
packet.run(_player);
final ServerPacket nextPacket = _pendingPackets.poll();
final ByteBuffer byteBuffer = nextPacket.getSendableByteBuffer(_encryption);
if (byteBuffer != null)
{
// Send the packet data.
getChannel().write(byteBuffer);
// Run packet implementation.
nextPacket.run(_player);
}
}
}
}
catch (Exception ignored)
{
catch (Exception ignored)
{
}
}
}