projectswg/Holocore
1
0
Fork 0
mirror of https://github.com/ProjectSWGCore/Holocore.git synced 2026-10-10 00:13:42 -04:00
Code Issues Projects Releases Wiki Activity

Fixed timing issue with inbound packets

Browse Source
This commit is contained in:
Obique
2018-02-04 13:08:51 -06:00
parent 47630ac700
commit 484fe033c4
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/network/NetworkClient.java
+5 -2
View File
@@ -75,6 +75,7 @@ public class NetworkClient extends TCPSession {
public void close(ConnectionStoppedReason reason) {
if (sessionManager.getStatus() != SessionStatus.DISCONNECTED) {
sendPacket(new HoloConnectionStopped(reason));
sessionManager.onSessionDestroyed();
intentChain.broadcastAfter(new ConnectionClosedIntent(getSessionId(), reason));
try {
@@ -128,16 +129,18 @@ public class NetworkClient extends TCPSession {
@Override
protected void onIncomingData(byte[] data) {
boolean canDecode = false;
inboundLock.lock();
try {
buffer.write(data);
if (NetworkProtocol.canDecode(buffer))
InboundPacketPendingIntent.broadcast(this);
canDecode = NetworkProtocol.canDecode(buffer);
} catch (IOException e) {
close(ConnectionStoppedReason.INVALID_PROTOCOL);
} finally {
inboundLock.unlock();
}
if (canDecode)
InboundPacketPendingIntent.broadcast(this);
}
@Override