Reduced size of ByteBuffers to reduce memory use.

Author: jython234

src/main/java/net/beaconpe/jraklib/protocol/EncapsulatedPacket.java

@@ -43,6 +43,8 @@ public class EncapsulatedPacket {
     public boolean needACK = false;
     public int identifierACK = -1;
 
+    public int bufferLength;
+
     protected int offset;
 
     public static EncapsulatedPacket fromBinary(byte[] binary){
@@ -55,6 +57,7 @@ public static EncapsulatedPacket fromBinary(byte[] binary, boolean internal){
 
     public static EncapsulatedPacket fromBinary(byte[] binary, boolean internal, int offset){
         EncapsulatedPacket packet = new EncapsulatedPacket();
+        packet.bufferLength = binary.length;
         byte flags = binary[0];
         packet.reliability = (byte) ((flags & 0b11100000) >> 5);
         packet.hasSplit = (flags & 0b00010000) > 0;
@@ -111,7 +114,7 @@ public int getTotalLength(boolean internal){
 
     public byte[] toBinary(boolean internal){
         int offset = 0;
-        ByteBuffer bb = ByteBuffer.allocate(1024 * 1024 * 32);
+        ByteBuffer bb = ByteBuffer.allocate(64 * 64 * 64);
         bb.put((byte) ((byte) (reliability << 5) | (hasSplit ? 0b00010000 : 0)));
         if(internal){
             bb.put(Binary.writeInt(buffer.length));
@@ -138,6 +141,7 @@ public byte[] toBinary(boolean internal){
 
         bb.put(buffer);
         byte[] data = Arrays.copyOf(bb.array(), bb.position());
+        bufferLength = data.length;
         bb = null;
         return data;
     }

src/main/java/net/beaconpe/jraklib/protocol/Packet.java

@@ -181,7 +181,7 @@ protected void putAddress(String addr, int port, byte version){
     protected abstract void _decode();
 
     public void encode(){
-        sendBuffer = ByteBuffer.allocate(1024*1024);
+        sendBuffer = ByteBuffer.allocate(64 * 64 * 64);
         putByte(getID());
         _encode();
         buffer = ArrayUtils.subarray(sendBuffer.array(), 0, sendBuffer.position());

src/main/java/net/beaconpe/jraklib/server/ServerHandler.java

@@ -46,7 +46,7 @@ public void sendEncapsulated(String identifier, EncapsulatedPacket packet){
     }
 
     public void sendEncapsulated(String identifier, EncapsulatedPacket packet, byte flags){
-        ByteBuffer bb = ByteBuffer.allocate(1024*1024*2);
+        ByteBuffer bb = ByteBuffer.allocate(packet.bufferLength);
         bb.put(JRakLib.PACKET_ENCAPSULATED).put((byte) identifier.getBytes().length).put(identifier.getBytes()).put(flags).put(packet.toBinary(true));
         server.pushMainToThreadPacket(Arrays.copyOf(bb.array(), bb.position()));
         bb = null;

src/main/java/net/beaconpe/jraklib/server/Session.java

@@ -330,7 +330,7 @@ private void handleSplit(EncapsulatedPacket packet) throws IOException {
 
         if(splitPackets.get(packet.splitID).values().size() == packet.splitCount){
             EncapsulatedPacket pk = new EncapsulatedPacket();
-            ByteBuffer bb = ByteBuffer.allocate(1024*1024);
+            ByteBuffer bb = ByteBuffer.allocate(64 * 64 * 64);
             for(int i = 0; i < packet.splitCount; i++){
                 bb.put(splitPackets.get(packet.splitID).get(i).buffer);
             }