|
|
|
|
|
|
|
|
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); |