mirrors/riiablo
1
0
Fork 0
mirror of https://github.com/collinsmith/riiablo.git synced 2025-01-05 13:08:24 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

Only send connection packets to unconnected players -- prevents flooding until sync packets aggregated

Browse Source
This commit is contained in:
Collin Smith 2019-12-28 22:45:42 -08:00
parent 03c620d574
commit 25e057c08a
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/com/riiablo/engine/client/ClientNetworkSyncronizer.java
View File

@ -115,7 +115,7 @@ public class ClientNetworkSyncronizer extends IntervalSystem {
while (buffer.hasRemaining()) {
int size = ByteBufferUtil.getSizePrefix(buffer);
D2GS.getRootAsD2GS(ByteBufferUtil.removeSizePrefix(buffer), d2gs);
if (DEBUG_PACKET) Gdx.app.debug(TAG, "packet type " + D2GSData.name(d2gs.dataType()) + ":" + ByteBufferUtil.getSizePrefix(buffer) + "B");
if (DEBUG_PACKET) Gdx.app.debug(TAG, "packet type " + D2GSData.name(d2gs.dataType()) + ":" + size + "B");
connected = d2gs.dataType() == D2GSData.Connection;
if (!connected) {
if (DEBUG_CONNECT) Gdx.app.debug(TAG, "dropping... ");

9
server/d2gs/src/com/riiablo/server/d2gs/D2GS.java
View File

@ -152,7 +152,7 @@ public class D2GS extends ApplicationAdapter {
int connected = 0;
final BlockingQueue<Packet> packets = new ArrayBlockingQueue<>(32);
final Collection<Packet> cache = new ArrayList<>();
final Collection<Packet> cache = new ArrayList<>(1024);
final BlockingQueue<Packet> outPackets = new ArrayBlockingQueue<>(1024);
final IntIntMap player = new IntIntMap();
@ -287,7 +287,7 @@ public class D2GS extends ApplicationAdapter {
Gdx.app.log(TAG, "assigned " + socket.getRemoteAddress() + " to " + id);
Client client = clients[id] = new Client(id, socket);
numClients++;
connected |= (1 << id);
//connected |= (1 << id);
client.start();
}
} catch (Throwable t) {
@ -347,7 +347,7 @@ public class D2GS extends ApplicationAdapter {
for (Packet packet : cache) {
Gdx.app.log(TAG, "dispatching " + D2GSData.name(packet.data.dataType()) + " packet to " + String.format("0x%08X", packet.id));
for (int i = 0, flag = 1; i < MAX_CLIENTS; i++, flag <<= 1) {
if ((packet.id & flag) == flag && (connected & flag) == flag) {
if ((packet.id & flag) == flag && ((connected & flag) == flag || packet.data.dataType() == D2GSData.Connection)) {
Client client = clients[i];
if (client == null) continue;
try {
@ -499,6 +499,9 @@ public class D2GS extends ApplicationAdapter {
packet.buffer.mark();
out.write(packet.buffer);
packet.buffer.reset();
if ((connected & (1 << id)) == 0 && packet.data.dataType() == D2GSData.Connection) {
connected |= (1 << id);
}
}
@Override