|
Lines 152-164
Link Here
|
| 152 |
// Don't close the underlying stream as it belongs to the session |
152 |
// Don't close the underlying stream as it belongs to the session |
| 153 |
} |
153 |
} |
| 154 |
}, |
154 |
}, |
| 155 |
8192 /*bufferSize*/, 1000 /*readTimeout*/, -1 /*closeTimeout*/, true /* growWhenFull */), timeout > 0 ? timeout : 1, monitor); |
155 |
8192 /*bufferSize*/, timeout /*readTimeout*/, -1 /*closeTimeout*/, true /* growWhenFull */), timeout > 0 ? timeout : 1, monitor); |
| 156 |
outputStream = new PollingOutputStream(new TimeoutOutputStream(new FilterOutputStream(channel_out) { |
156 |
outputStream = new PollingOutputStream(new TimeoutOutputStream(new FilterOutputStream(channel_out) { |
| 157 |
public void close() { |
157 |
public void close() { |
| 158 |
// Don't close the underlying stream as it belongs to the session |
158 |
// Don't close the underlying stream as it belongs to the session |
| 159 |
} |
159 |
} |
| 160 |
}, |
160 |
}, |
| 161 |
8192 /*buffersize*/, 1000 /*writeTimeout*/, 1000 /*closeTimeout*/), timeout > 0 ? timeout : 1, monitor); |
161 |
8192 /*buffersize*/, timeout /*writeTimeout*/, 1000 /*closeTimeout*/), timeout > 0 ? timeout : 1, monitor); |
| 162 |
} catch (final JSchException e) { |
162 |
} catch (final JSchException e) { |
| 163 |
if (isSSH2Unsupported(e)) { |
163 |
if (isSSH2Unsupported(e)) { |
| 164 |
ssh1 = new SSHServerConnection(location, password); |
164 |
ssh1 = new SSHServerConnection(location, password); |
