AstralTransRocketries/minosoft
1
0
Fork 0
mirror of https://gitlab.bixilon.de/bixilon/minosoft.git synced 2025-09-12 08:58:02 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix network packet stuff, better network performance

Browse Source
This commit is contained in:
bixilon 2020-06-04 21:18:09 +02:00
parent f5fa4c9ead
commit b9e1d9ba5e
No known key found for this signature in database
GPG Key ID: 5CAD791931B09AC4
2 changed files with 19 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
src/main/java/de/bixilon/minosoft/protocol/network/Network.java
View File

@ -50,6 +50,7 @@ public class Network {
socket.setKeepAlive(true);
DataOutputStream dOut = new DataOutputStream(socket.getOutputStream());
DataInputStream dIn = new DataInputStream(socket.getInputStream());
socket.getInputStream();
while (connection.getConnectionState() != ConnectionState.DISCONNECTING) {
@ -73,31 +74,25 @@ public class Network {
continue;
}
// everything sent for now, waiting for data
List<Byte> raw = new ArrayList<>();
byte[] buffer = new byte[1];
while (true) {
if (raw.size() > ProtocolDefinition.PROTOCOL_PACKET_MAX_SIZE) {
raw = null;
break;
}
if (dIn.available() == 0) {
// packet end
break;
}
dIn.readFully(buffer, 0, 1);
raw.add(buffer[0]);
if (dIn.available() > 0) {
int numRead = 0;
int length = 0;
byte read;
do {
read = dIn.readByte();
int value = (read & 0b01111111);
length |= (value << (7 * numRead));
numRead++;
if (numRead > 5) {
throw new RuntimeException("VarInt is too big");
}
} while ((read & 0b10000000) != 0);
byte[] raw = dIn.readNBytes(length);
binQueueIn.add(raw);
}
if (raw == null || raw.size() == 0) {
// data was tto long, ...
continue;
}
// convert to array
byte[] in = new byte[raw.size()];
for (int i = 0; i < raw.size(); i++) {
in[i] = raw.get(i);
}
// add to queue
binQueueIn.add(in);
Util.sleep(1);
}

2
src/main/java/de/bixilon/minosoft/protocol/protocol/InPacketBuffer.java
View File

@ -2,12 +2,10 @@ package de.bixilon.minosoft.protocol.protocol;
public class InPacketBuffer extends InByteBuffer {
private final int command;
private final int length; // not interested in yet
public InPacketBuffer(byte[] bytes) {
super(bytes);
// ToDo: compression
length = readVarInt();
command = readVarInt();
}