mirror of
https://github.com/sirjonasxx/G-Earth.git
synced 2025-02-21 13:22:37 +01:00
tcpnodelay
This commit is contained in:
parent
d1cc1d1484
commit
df016d9b51
@ -90,6 +90,7 @@ public abstract class Extension implements IExtension{
|
|||||||
Socket gEarthExtensionServer = null;
|
Socket gEarthExtensionServer = null;
|
||||||
try {
|
try {
|
||||||
gEarthExtensionServer = new Socket("127.0.0.1", port);
|
gEarthExtensionServer = new Socket("127.0.0.1", port);
|
||||||
|
gEarthExtensionServer.setTcpNoDelay(true);
|
||||||
InputStream in = gEarthExtensionServer.getInputStream();
|
InputStream in = gEarthExtensionServer.getInputStream();
|
||||||
DataInputStream dIn = new DataInputStream(in);
|
DataInputStream dIn = new DataInputStream(in);
|
||||||
out = gEarthExtensionServer.getOutputStream();
|
out = gEarthExtensionServer.getOutputStream();
|
||||||
|
@ -260,6 +260,7 @@ public class HConnection {
|
|||||||
while ((state == State.WAITING_FOR_CLIENT) && !proxy_server.isClosed()) {
|
while ((state == State.WAITING_FOR_CLIENT) && !proxy_server.isClosed()) {
|
||||||
try {
|
try {
|
||||||
Socket client = proxy_server.accept();
|
Socket client = proxy_server.accept();
|
||||||
|
client.setTcpNoDelay(true);
|
||||||
actual_proxy = potentialProxy;
|
actual_proxy = potentialProxy;
|
||||||
closeAllProxies(actual_proxy);
|
closeAllProxies(actual_proxy);
|
||||||
if (DEBUG) System.out.println("accepted a proxy");
|
if (DEBUG) System.out.println("accepted a proxy");
|
||||||
@ -293,6 +294,7 @@ public class HConnection {
|
|||||||
final boolean[] datastream = new boolean[1];
|
final boolean[] datastream = new boolean[1];
|
||||||
|
|
||||||
Socket habbo_server = new Socket(proxy.actual_domain, proxy.actual_port);
|
Socket habbo_server = new Socket(proxy.actual_domain, proxy.actual_port);
|
||||||
|
habbo_server.setTcpNoDelay(true);
|
||||||
|
|
||||||
OutputStream client_out = client.getOutputStream();
|
OutputStream client_out = client.getOutputStream();
|
||||||
InputStream client_in = client.getInputStream();
|
InputStream client_in = client.getInputStream();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user