mirror of
https://github.com/sirjonasxx/G-Earth.git
synced 2024-11-23 08:50:52 +01:00
fixes something, i guess
This commit is contained in:
parent
59a0adac82
commit
55198b77c4
@ -36,6 +36,9 @@ public abstract class ProxyProvider {
|
|||||||
server.setTcpNoDelay(true);
|
server.setTcpNoDelay(true);
|
||||||
client.setTcpNoDelay(true);
|
client.setTcpNoDelay(true);
|
||||||
|
|
||||||
|
client.setSoTimeout(0);
|
||||||
|
server.setSoTimeout(0);
|
||||||
|
|
||||||
if (HConnection.DEBUG) System.out.println(server.getLocalAddress().getHostAddress() + ": " + server.getLocalPort());
|
if (HConnection.DEBUG) System.out.println(server.getLocalAddress().getHostAddress() + ": " + server.getLocalPort());
|
||||||
Rc4Obtainer rc4Obtainer = new Rc4Obtainer(hConnection);
|
Rc4Obtainer rc4Obtainer = new Rc4Obtainer(hConnection);
|
||||||
|
|
||||||
@ -83,7 +86,10 @@ public abstract class ProxyProvider {
|
|||||||
packetHandler.act(Arrays.copyOf(buffer, readLength));
|
packetHandler.act(Arrays.copyOf(buffer, readLength));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch (IOException ignore) {} finally {
|
catch (IOException ignore) {
|
||||||
|
// System.err.println(packetHandler instanceof IncomingPacketHandler ? "incoming" : "outgoing");
|
||||||
|
// ignore.printStackTrace();
|
||||||
|
} finally {
|
||||||
abort.release();
|
abort.release();
|
||||||
}
|
}
|
||||||
}).start();
|
}).start();
|
||||||
|
@ -34,6 +34,7 @@ public class IncomingPacketHandler extends PacketHandler {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void act(byte[] buffer) throws IOException {
|
public void act(byte[] buffer) throws IOException {
|
||||||
|
System.out.println("gotincoming");
|
||||||
if (isDataStream) {
|
if (isDataStream) {
|
||||||
continuedAct(buffer);
|
continuedAct(buffer);
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user