|
22 | 22 | import java.io.IOException; |
23 | 23 | import java.io.InputStream; |
24 | 24 | import java.io.OutputStream; |
25 | | -import java.io.PipedInputStream; |
26 | | -import java.io.PipedOutputStream; |
27 | 25 | import java.io.StreamCorruptedException; |
28 | 26 | import java.nio.charset.StandardCharsets; |
29 | 27 | import java.time.Duration; |
|
90 | 88 | import org.apache.sshd.util.test.TestChannelListener; |
91 | 89 | import org.junit.jupiter.api.AfterEach; |
92 | 90 | import org.junit.jupiter.api.BeforeEach; |
| 91 | +import org.junit.jupiter.api.Disabled; |
93 | 92 | import org.junit.jupiter.api.MethodOrderer.MethodName; |
94 | 93 | import org.junit.jupiter.api.Test; |
95 | 94 | import org.junit.jupiter.api.TestMethodOrder; |
@@ -284,6 +283,7 @@ public String toString() { |
284 | 283 | * read the data, filling the ssh window and the tcp socket - the server session becomes idle, but the ssh |
285 | 284 | * disconnect message can't be written - the server session is forcibly closed |
286 | 285 | */ |
| 286 | + @Disabled("Unstable test") |
287 | 287 | @Test |
288 | 288 | void serverIdleTimeoutWithForce() throws Exception { |
289 | 289 | final long idleTimeoutValue = TimeUnit.SECONDS.toMillis(5L); |
@@ -329,12 +329,8 @@ public String toString() { |
329 | 329 |
|
330 | 330 | client.start(); |
331 | 331 | try (ClientSession s = createTestClientSession(sshd); |
332 | | - ChannelExec shell = s.createExecChannel("normal"); |
333 | | - // Create a pipe that will block reading when the buffer is full |
334 | | - PipedInputStream pis = new PipedInputStream(); |
335 | | - PipedOutputStream pos = new PipedOutputStream(pis)) { |
| 332 | + ChannelExec shell = s.createExecChannel("normal")) { |
336 | 333 |
|
337 | | - shell.setOut(pos); |
338 | 334 | shell.open().verify(OPEN_TIMEOUT); |
339 | 335 |
|
340 | 336 | assertTrue(channelListener.waitForActiveChannelsChange(5L, TimeUnit.SECONDS), |
|
0 commit comments