parent
8300a8b505
commit
9b6fd3537a
|
@ -188,11 +188,7 @@ public class LinkManager {
|
|||
int portPart = TcpConnector.getTcpPort(port);
|
||||
String hostname = TcpConnector.getHostname(port);
|
||||
socket = new Socket(hostname, portPart);
|
||||
TcpIoStream tcpIoStream = new TcpIoStream(logger, socket);
|
||||
IncomingDataBuffer dataBuffer = IncomingDataBuffer.createDataBuffer(tcpIoStream, logger);
|
||||
tcpIoStream.setDataBuffer(dataBuffer);
|
||||
|
||||
return tcpIoStream;
|
||||
return new TcpIoStream(logger, socket);
|
||||
} catch (Throwable e) {
|
||||
stateListener.onConnectionFailed();
|
||||
return null;
|
||||
|
|
|
@ -35,6 +35,8 @@ public class TcpIoStream implements IoStream {
|
|||
throw new NullPointerException("output");
|
||||
this.output = output;
|
||||
this.input = input;
|
||||
IncomingDataBuffer dataBuffer = IncomingDataBuffer.createDataBuffer(this, logger);
|
||||
setDataBuffer(dataBuffer);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
Loading…
Reference in New Issue