clean ups
This commit is contained in:
parent
52275e27b4
commit
e3bdf43112
|
@ -160,8 +160,8 @@ public class ChannelEndPoint implements EndPoint
|
|||
}
|
||||
catch(SocketException e)
|
||||
{
|
||||
LOG.warn(e.toString());
|
||||
LOG.debug(e);
|
||||
LOG.debug(e.toString());
|
||||
LOG.ignore(e);
|
||||
if (!socket.isClosed())
|
||||
close();
|
||||
}
|
||||
|
|
|
@ -35,12 +35,5 @@ public class ChannelEndPointTest extends EndPointTest<ChannelEndPoint>
|
|||
c.server=new ChannelEndPoint(connector.accept());
|
||||
return c;
|
||||
}
|
||||
|
||||
@Test
|
||||
public void stress() throws Exception
|
||||
{
|
||||
|
||||
testClientServerExchange();
|
||||
}
|
||||
|
||||
}
|
||||
|
|
|
@ -154,12 +154,12 @@ public class SelectChannelEndPointTest
|
|||
|
||||
public void onClose()
|
||||
{
|
||||
System.err.println("onClose");
|
||||
// System.err.println("onClose");
|
||||
}
|
||||
|
||||
public void onInputShutdown() throws IOException
|
||||
{
|
||||
System.err.println("onInputShutdown");
|
||||
// System.err.println("onInputShutdown");
|
||||
}
|
||||
|
||||
}
|
||||
|
@ -303,7 +303,7 @@ public class SelectChannelEndPointTest
|
|||
catch(SocketTimeoutException e)
|
||||
{
|
||||
int elapsed = Long.valueOf(System.currentTimeMillis() - start).intValue();
|
||||
System.err.println("blocked " + elapsed);
|
||||
// System.err.println("blocked " + elapsed);
|
||||
Assert.assertThat("Expected timeout", elapsed, greaterThanOrEqualTo(specifiedTimeout));
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue