Apache
/
httpcomponents-client
mirror of https://github.com/apache/httpcomponents-client.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increased sleep time in some test cases currently failing when executed on Windows 

git-svn-id: https://svn.apache.org/repos/asf/httpcomponents/httpclient/trunk@1153911 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Oleg Kalnichevski 2011-08-04 15:39:23 +00:00
parent f944e26075
commit 030b8d3773
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
httpclient/src/test/java/org/apache/http/impl/conn/tsccm/TestConnPoolByRoute.java
View File

@ -300,7 +300,7 @@ public class TestConnPoolByRoute extends ServerTestBase {
useMockOperator(); useMockOperator();
BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
impl.freeEntry(entry, true, Long.MAX_VALUE, TimeUnit.MILLISECONDS); impl.freeEntry(entry, true, Long.MAX_VALUE, TimeUnit.MILLISECONDS);
Thread.sleep(2); Thread.sleep(200L);
impl.closeIdleConnections(1, TimeUnit.MILLISECONDS); impl.closeIdleConnections(1, TimeUnit.MILLISECONDS);
verify(mockConnection, atLeastOnce()).close(); verify(mockConnection, atLeastOnce()).close();
} }
@ -320,7 +320,7 @@ public class TestConnPoolByRoute extends ServerTestBase {
useMockOperator(); useMockOperator();
BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
impl.freeEntry(entry, true, 1, TimeUnit.MILLISECONDS); impl.freeEntry(entry, true, 1, TimeUnit.MILLISECONDS);
Thread.sleep(2); Thread.sleep(200L);
impl.closeExpiredConnections(); impl.closeExpiredConnections();
verify(mockConnection, atLeastOnce()).close(); verify(mockConnection, atLeastOnce()).close();
} }
@ -329,8 +329,8 @@ public class TestConnPoolByRoute extends ServerTestBase {
public void closeExpiredConnectionsDoesNotCloseUnexpiredOnes() throws Exception { public void closeExpiredConnectionsDoesNotCloseUnexpiredOnes() throws Exception {
useMockOperator(); useMockOperator();
BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
impl.freeEntry(entry, true, 10, TimeUnit.MILLISECONDS); impl.freeEntry(entry, true, 10, TimeUnit.SECONDS);
Thread.sleep(1); Thread.sleep(200L);
impl.closeExpiredConnections(); impl.closeExpiredConnections();
verify(mockConnection, never()).close(); verify(mockConnection, never()).close();
} }
@ -405,7 +405,7 @@ public class TestConnPoolByRoute extends ServerTestBase {
when(mockOperator.createConnection()).thenReturn(mockConnection, mockConnection2); when(mockOperator.createConnection()).thenReturn(mockConnection, mockConnection2);
BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
impl.freeEntry(entry, true, 1, TimeUnit.MILLISECONDS); impl.freeEntry(entry, true, 1, TimeUnit.MILLISECONDS);
Thread.sleep(2); Thread.sleep(200L);
BasicPoolEntry entry2 = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); BasicPoolEntry entry2 = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
assertNotSame(mockConnection, entry2.getConnection()); assertNotSame(mockConnection, entry2.getConnection());
} }
@ -416,7 +416,7 @@ public class TestConnPoolByRoute extends ServerTestBase {
when(mockOperator.createConnection()).thenReturn(mockConnection, mockConnection2); when(mockOperator.createConnection()).thenReturn(mockConnection, mockConnection2);
BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); BasicPoolEntry entry = impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
impl.freeEntry(entry, true, 1, TimeUnit.MILLISECONDS); impl.freeEntry(entry, true, 1, TimeUnit.MILLISECONDS);
Thread.sleep(2); Thread.sleep(200L);
impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS); impl.requestPoolEntry(route, new Object()).getPoolEntry(-1, TimeUnit.MILLISECONDS);
verify(mockConnection, atLeastOnce()).close(); verify(mockConnection, atLeastOnce()).close();
} }