|
|
@ -143,7 +143,9 @@ abstract class BasePackConnection extends BaseConnection { |
|
|
|
final int timeout = transport.getTimeout(); |
|
|
|
final int timeout = transport.getTimeout(); |
|
|
|
if (timeout > 0) { |
|
|
|
if (timeout > 0) { |
|
|
|
final Thread caller = Thread.currentThread(); |
|
|
|
final Thread caller = Thread.currentThread(); |
|
|
|
myTimer = new InterruptTimer(caller.getName() + "-Timer"); //$NON-NLS-1$
|
|
|
|
if (myTimer == null) { |
|
|
|
|
|
|
|
myTimer = new InterruptTimer(caller.getName() + "-Timer"); //$NON-NLS-1$
|
|
|
|
|
|
|
|
} |
|
|
|
timeoutIn = new TimeoutInputStream(myIn, myTimer); |
|
|
|
timeoutIn = new TimeoutInputStream(myIn, myTimer); |
|
|
|
timeoutOut = new TimeoutOutputStream(myOut, myTimer); |
|
|
|
timeoutOut = new TimeoutOutputStream(myOut, myTimer); |
|
|
|
timeoutIn.setTimeout(timeout * 1000); |
|
|
|
timeoutIn.setTimeout(timeout * 1000); |
|
|
|