big-data/hadoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

HADOOP-7349. HADOOP-7121 accidentally disabled some tests in TestIPC. Contributed by Todd Lipcon.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1130758 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Todd Lipcon 2011-06-02 19:23:43 +00:00
parent 3c863fada4
commit 8ed5d34214
2 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
CHANGES.txt
View File

@ -763,6 +763,9 @@ Release 0.22.0 - Unreleased
so subclasses could supply alternate webapps path but it was made private so subclasses could supply alternate webapps path but it was made private
by HADOOP-6461 (Stack) by HADOOP-6461 (Stack)
HADOOP-7349. HADOOP-7121 accidentally disabled some tests in TestIPC.
(todd)
Release 0.21.1 - Unreleased Release 0.21.1 - Unreleased
IMPROVEMENTS IMPROVEMENTS

3
src/test/core/org/apache/hadoop/ipc/TestIPC.java
View File

@ -445,6 +445,7 @@ private static void assertExceptionContains(
* Test that, if the socket factory throws an IOE, it properly propagates * Test that, if the socket factory throws an IOE, it properly propagates
* to the client. * to the client.
*/ */
@Test
public void testSocketFactoryException() throws Exception { public void testSocketFactoryException() throws Exception {
SocketFactory mockFactory = mock(SocketFactory.class); SocketFactory mockFactory = mock(SocketFactory.class);
doThrow(new IOException("Injected fault")).when(mockFactory).createSocket(); doThrow(new IOException("Injected fault")).when(mockFactory).createSocket();
@ -460,6 +461,7 @@ public void testSocketFactoryException() throws Exception {
} }
} }
@Test
public void testIpcTimeout() throws Exception { public void testIpcTimeout() throws Exception {
// start server // start server
Server server = new TestServer(1, true); Server server = new TestServer(1, true);
@ -485,6 +487,7 @@ public void testIpcTimeout() throws Exception {
* Check that file descriptors aren't leaked by starting * Check that file descriptors aren't leaked by starting
* and stopping IPC servers. * and stopping IPC servers.
*/ */
@Test
public void testSocketLeak() throws Exception { public void testSocketLeak() throws Exception {
Assume.assumeTrue(FD_DIR.exists()); // only run on Linux Assume.assumeTrue(FD_DIR.exists()); // only run on Linux