You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2011/10/03 22:11:36 UTC
svn commit: r1178553 -
/incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
Author: jkreps
Date: Mon Oct 3 20:11:36 2011
New Revision: 1178553
URL: http://svn.apache.org/viewvc?rev=1178553&view=rev
Log:
KAFKA-125 On Linux, the test can throw SocketException instead of EOFException, that is cool too.
Modified:
incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
Modified: incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala?rev=1178553&r1=1178552&r2=1178553&view=diff
==============================================================================
--- incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala (original)
+++ incubator/kafka/trunk/core/src/test/scala/unit/kafka/network/SocketServerTest.scala Mon Oct 3 20:11:36 2011
@@ -71,11 +71,11 @@ class SocketServerTest extends JUnitSuit
}
- @Test(expected=classOf[EOFException])
+ @Test(expected=classOf[IOException])
def tooBigRequestIsRejected() {
val tooManyBytes = new Array[Byte](server.maxRequestSize + 1)
new Random().nextBytes(tooManyBytes)
sendRequest(0, tooManyBytes)
}
-}
\ No newline at end of file
+}