Upstream/BungeeCord
1
0
Fork 0
mirror of https://github.com/SpigotMC/BungeeCord.git synced 2024-11-24 03:05:49 +01:00
Code Issues Projects Releases Wiki Activity

Add tweakable buffer size.

Browse Source
This commit is contained in:
md_5 2012-12-24 11:47:25 +11:00
parent 51ed8beffa
commit bc3f63790a
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/net/md_5/bungee/Configuration.java
View File

@ -133,6 +133,7 @@ public class Configuration
*/ */
public String statsUuid = UUID.randomUUID().toString(); public String statsUuid = UUID.randomUUID().toString();
public boolean metricsEnabled = true; public boolean metricsEnabled = true;
public int bufferSize = 2048;
/** /**
* Load the configuration and save default values. * Load the configuration and save default values.

2
src/main/java/net/md_5/bungee/InitialHandler.java
View File

@ -68,7 +68,7 @@ public class InitialHandler implements Runnable
out.write(new PacketFCEncryptionResponse().getPacket()); out.write(new PacketFCEncryptionResponse().getPacket());
in = new PacketInputStream(new CipherInputStream(socket.getInputStream(), EncryptionUtil.getCipher(false, shared))); in = new PacketInputStream(new CipherInputStream(socket.getInputStream(), EncryptionUtil.getCipher(false, shared)));
out = new CipherOutputStream(new BufferedOutputStream(socket.getOutputStream(), 4096), EncryptionUtil.getCipher(true, shared)); out = new CipherOutputStream(new BufferedOutputStream(socket.getOutputStream(), BungeeCord.instance.config.bufferSize), EncryptionUtil.getCipher(true, shared));
List<byte[]> customPackets = new ArrayList<>(); List<byte[]> customPackets = new ArrayList<>();
byte[] custom; byte[] custom;
while (Util.getId((custom = in.readPacket())) != 0xCD) while (Util.getId((custom = in.readPacket())) != 0xCD)

2
src/main/java/net/md_5/bungee/ServerConnection.java
View File

@ -66,7 +66,7 @@ public class ServerConnection extends GenericConnection
out.write(new PacketFAPluginMessage("REGISTER", channel.getBytes()).getPacket()); out.write(new PacketFAPluginMessage("REGISTER", channel.getBytes()).getPacket());
} }
out = new BufferedOutputStream(out, 4096); out = new BufferedOutputStream(out, BungeeCord.instance.config.bufferSize);
return new ServerConnection(name, socket, in, out, login); return new ServerConnection(name, socket, in, out, login);
} catch (KickException ex) } catch (KickException ex)