proxy progress
This commit is contained in:
parent
a15c7104fd
commit
4448550dc9
|
@ -49,12 +49,13 @@ public class PortHolder {
|
||||||
MessagesCentral.getInstance().postMessage(logger, getClass(), "Opening port: " + port);
|
MessagesCentral.getInstance().postMessage(logger, getClass(), "Opening port: " + port);
|
||||||
|
|
||||||
stream = streamFactory.call();
|
stream = streamFactory.call();
|
||||||
|
IncomingDataBuffer dataBuffer = IncomingDataBuffer.createDataBuffer(stream, logger);
|
||||||
if (stream == null) {
|
if (stream == null) {
|
||||||
// error already reported
|
// error already reported
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
synchronized (portLock) {
|
synchronized (portLock) {
|
||||||
bp = new BinaryProtocol(linkManager, logger, stream, IncomingDataBuffer.createDataBuffer(stream, logger));
|
bp = new BinaryProtocol(linkManager, logger, stream, dataBuffer);
|
||||||
portLock.notifyAll();
|
portLock.notifyAll();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue