Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

TCP Test - increase wait time for close

Browse Source
This commit is contained in:
Gary Russell
2019-11-01 10:22:58 -04:00
parent 04ff879f7e
commit e2ba60f021
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/TcpNioConnectionReadTests.java
View File

@@ -235,7 +235,7 @@ public class TcpNioConnectionReadTests {
s -> assertThat(s).contains("Connection is closed"));
assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue();
assertThat(removed.size() > 0).isTrue();
assertThat(removed).hasSizeGreaterThan(0);
scf.stop();
done.countDown();
}
@@ -287,7 +287,7 @@ public class TcpNioConnectionReadTests {
s -> assertThat(s).contains("Connection is closed"));
assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue();
assertThat(removed.size() > 0).isTrue();
assertThat(removed).hasSizeGreaterThan(0);
scf.stop();
done.countDown();
}
@@ -339,7 +339,7 @@ public class TcpNioConnectionReadTests {
s -> assertThat(s).contains("Connection is closed"));
assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue();
assertThat(removed.size() > 0).isTrue();
assertThat(removed).hasSizeGreaterThan(0);
scf.stop();
done.countDown();
}
@@ -447,7 +447,7 @@ public class TcpNioConnectionReadTests {
s -> assertThat(s).contains("Connection is closed"));
assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue();
assertThat(removed.size() > 0).isTrue();
assertThat(removed).hasSizeGreaterThan(0);
scf.stop();
}
@@ -536,7 +536,7 @@ public class TcpNioConnectionReadTests {
assertThat(semaphore.tryAcquire(10000, TimeUnit.MILLISECONDS)).isTrue();
while (added.get(0).isOpen()) {
Thread.sleep(50);
if (n++ > 200) {
if (n++ > 400) {
fail("Failed to close socket");
}
}