Created
July 7, 2015 11:12
-
-
Save ktoso/d831dab56639742bc647 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| kka-stream-tests-experimental > testOnly *TcpSpec* | |
| [info] TcpSpec: | |
| Coroner Thread Count starts at 15 in akka.stream.io.TcpSpec | |
| [info] Outgoing TCP stream | |
| [WARN] [07/07/2015 13:11:40.739] [TcpSpec-akka.actor.default-dispatcher-3] [akka://TcpSpec/user/$b] received dead letter from Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#2045015129]: Unbound | |
| [WARN] [07/07/2015 13:11:40.749] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/1] received dead letter from Actor[akka://TcpSpec/deadLetters]: ChannelReadable | |
| [info] - must work in the happy case (2 seconds, 417 milliseconds) | |
| [info] - must be able to write a sequence of ByteStrings (272 milliseconds) | |
| [info] - must be able to read a sequence of ByteStrings (399 milliseconds) | |
| [WARN] [07/07/2015 13:11:41.582] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/7] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/client-3-%2F127.0.0.1%3A50097#-231405531]: ResumeReading | |
| [WARN] [07/07/2015 13:11:42.225] [TcpSpec-akka.actor.default-dispatcher-11] [akka://TcpSpec/user/$e/$a] received dead letter from Actor[akka://TcpSpec/deadLetters]: PingClose(Actor[akka://TcpSpec/system/testActor16#-1443855332]) | |
| [info] - must work when client closes write, then remote closes write (649 milliseconds) | |
| [WARN] [07/07/2015 13:11:42.748] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/13] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/client-5-%2F127.0.0.1%3A50101#-2016783489]: ResumeReading | |
| [info] - must work when remote closes write, then client closes write (559 milliseconds) | |
| [WARN] [07/07/2015 13:11:43.637] [TcpSpec-akka.actor.default-dispatcher-12] [akka://TcpSpec/system/IO-TCP-STREAM/client-6-%2F127.0.0.1%3A50103] received dead letter from Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/16#-733902079]: Received(ByteString(1, 2, 3, 4, 5)) | |
| [WARN] [07/07/2015 13:11:44.934] [TcpSpec-akka.actor.default-dispatcher-15] [akka://TcpSpec/system/IO-TCP/selectors/$a/17] unhandled message from Actor[akka://TcpSpec/user/$g/$a#-29346997]: ResumeReading | |
| [WARN] [07/07/2015 13:11:46.238] [TcpSpec-akka.actor.default-dispatcher-12] [akka://TcpSpec/system/IO-TCP/selectors/$a/17] received dead letter from Actor[akka://TcpSpec/user/$g/$a#-29346997]: ResumeReading | |
| [info] - must work when client closes read, then client closes write (3 seconds, 451 milliseconds) | |
| [WARN] [07/07/2015 13:11:46.983] [TcpSpec-akka.actor.default-dispatcher-15] [akka://TcpSpec/user/$h/$a] received dead letter from Actor[akka://TcpSpec/deadLetters]: PingClose(Actor[akka://TcpSpec/system/testActor31#53259060]) | |
| [info] - must work when client closes write, then client closes read (744 milliseconds) | |
| [info] - must work when client closes read, then server closes write, then client closes write (542 milliseconds) | |
| [info] - must shut everything down if client signals error (665 milliseconds) | |
| [WARN] [07/07/2015 13:11:48.292] [TcpSpec-akka.actor.default-dispatcher-8] [akka://TcpSpec/system/IO-TCP/selectors/$a/28] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/client-10-%2F127.0.0.1%3A50122#-369307932]: ResumeReading | |
| [info] - must shut everything down if client signals error after remote has closed write (102 milliseconds) | |
| [WARN] [07/07/2015 13:11:48.361] [TcpSpec-akka.actor.default-dispatcher-15] [akka://TcpSpec/system/IO-TCP/selectors/$a/31] received dead letter from Actor[akka://TcpSpec/system/IO-TCP-STREAM/client-11-%2F127.0.0.1%3A50124#-553883295]: ResumeReading | |
| [info] - must shut down both streams when connection is aborted remotely (70 milliseconds) | |
| [info] - must materialize correctly when used in multiple flows (119 milliseconds) | |
| [WARN] [07/07/2015 13:11:48.486] [TcpSpec-akka.actor.default-dispatcher-12] [akka://TcpSpec/user/$m] received dead letter from Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/33#-714092717]: Unbound | |
| [WARN] [07/07/2015 13:11:48.488] [TcpSpec-akka.actor.default-dispatcher-12] [akka://TcpSpec/system/IO-TCP/selectors/$a/36] received dead letter from Actor[akka://TcpSpec/system/IO-TCP-STREAM/client-13-%2F127.0.0.1%3A50126#1733260537]: ResumeReading | |
| [info] - must properly full-close if requested *** FAILED *** (81 milliseconds) | |
| [info] akka.stream.StreamTcpException: Connection failed. | |
| [WARN] [07/07/2015 13:11:49.387] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/42] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-16-localhost%2F127.0.0.1%3A50131/$a#1858881941]: ResumeReading | |
| [info] - must Echo should work even if server is in full close mode (812 milliseconds) | |
| [INFO] [07/07/2015 13:11:49.911] [default-akka.actor.default-dispatcher-9] [akka://default/system/IO-TCP/selectors/$a/2] Message [akka.io.Tcp$ResumeReading$] from Actor[akka://default/system/IO-TCP-STREAM/server-1-localhost%2F127.0.0.1%3A50134/$a#-456534495] to Actor[akka://default/system/IO-TCP/selectors/$a/2#-1574287357] was not delivered. [1] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. | |
| [INFO] [07/07/2015 13:11:49.911] [default-akka.actor.default-dispatcher-9] [akka://default/system/IO-TCP/selectors/$a/1] Message [akka.io.Tcp$ResumeReading$] from Actor[akka://default/system/IO-TCP-STREAM/client-2-localhost%2F127.0.0.1%3A50134#2100355583] to Actor[akka://default/system/IO-TCP/selectors/$a/1#193961536] was not delivered. [2] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. | |
| [INFO] [07/07/2015 13:11:49.919] [default-akka.actor.default-dispatcher-10] [akka://default/system/IO-TCP/selectors/$a/0] Message [akka.io.Tcp$Unbind$] from Actor[akka://default/system/IO-TCP-STREAM/server-1-localhost%2F127.0.0.1%3A50134#1585533282] to Actor[akka://default/system/IO-TCP/selectors/$a/0#-1434452256] was not delivered. [3] dead letters encountered. This logging can be turned off or adjusted with configuration settings 'akka.log-dead-letters' and 'akka.log-dead-letters-during-shutdown'. | |
| [info] - must handle when connection actor terminates unexpectedly (517 milliseconds) | |
| [info] TCP listen stream | |
| [WARN] [07/07/2015 13:11:50.179] [TcpSpec-akka.actor.default-dispatcher-11] [akka://TcpSpec/system/IO-TCP/selectors/$a/45] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-18-localhost%2F127.0.0.1%3A50136/$a#1188659052]: ResumeReading | |
| [info] - must be able to implement echo (253 milliseconds) | |
| [WARN] [07/07/2015 13:11:50.242] [TcpSpec-akka.actor.default-dispatcher-8] [akka://TcpSpec/system/IO-TCP/selectors/$a/54] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-20-localhost%2F127.0.0.1%3A50139/$d#1985484554]: ResumeReading | |
| [WARN] [07/07/2015 13:11:50.247] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/52] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-20-localhost%2F127.0.0.1%3A50139/$b#-802376008]: ResumeReading | |
| [WARN] [07/07/2015 13:11:50.252] [TcpSpec-akka.actor.default-dispatcher-4] [akka://TcpSpec/system/IO-TCP/selectors/$a/53] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-20-localhost%2F127.0.0.1%3A50139/$c#-208104149]: ResumeReading | |
| [WARN] [07/07/2015 13:11:50.259] [TcpSpec-akka.actor.default-dispatcher-16] [akka://TcpSpec/system/IO-TCP/selectors/$a/50] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-20-localhost%2F127.0.0.1%3A50139/$a#1787291588]: ResumeReading | |
| [info] - must work with a chain of echoes (75 milliseconds) | |
| [ERROR] [07/07/2015 13:11:50.300] [TcpSpec-akka.actor.default-dispatcher-4] [akka://TcpSpec/system/IO-TCP/selectors/$a/56] Bind failed for TCP channel on endpoint [localhost/127.0.0.1:50144] | |
| java.net.BindException: Address already in use | |
| at sun.nio.ch.Net.bind(Native Method) | |
| at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124) | |
| at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) | |
| at akka.io.TcpListener.liftedTree1$1(TcpListener.scala:53) | |
| at akka.io.TcpListener.<init>(TcpListener.scala:50) | |
| at sun.reflect.GeneratedConstructorAccessor19.newInstance(Unknown Source) | |
| at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) | |
| at java.lang.reflect.Constructor.newInstance(Constructor.java:513) | |
| at akka.util.Reflect$.instantiate(Reflect.scala:66) | |
| at akka.actor.ArgsReflectConstructor.produce(Props.scala:352) | |
| at akka.actor.Props.newActor(Props.scala:252) | |
| at akka.actor.ActorCell.newActor(ActorCell.scala:552) | |
| at akka.actor.ActorCell.create(ActorCell.scala:578) | |
| at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) | |
| at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) | |
| at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) | |
| at akka.dispatch.Mailbox.run(Mailbox.scala:219) | |
| at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) | |
| at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
| at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
| at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
| at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
| [ERROR] [07/07/2015 13:11:50.472] [TcpSpec-akka.actor.default-dispatcher-12] [akka://TcpSpec/system/IO-TCP/selectors/$a/57] Bind failed for TCP channel on endpoint [localhost/127.0.0.1:50144] | |
| java.net.BindException: Address already in use | |
| at sun.nio.ch.Net.bind(Native Method) | |
| at sun.nio.ch.ServerSocketChannelImpl.bind(ServerSocketChannelImpl.java:124) | |
| at sun.nio.ch.ServerSocketAdaptor.bind(ServerSocketAdaptor.java:59) | |
| at akka.io.TcpListener.liftedTree1$1(TcpListener.scala:53) | |
| at akka.io.TcpListener.<init>(TcpListener.scala:50) | |
| at sun.reflect.GeneratedConstructorAccessor19.newInstance(Unknown Source) | |
| at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:27) | |
| at java.lang.reflect.Constructor.newInstance(Constructor.java:513) | |
| at akka.util.Reflect$.instantiate(Reflect.scala:66) | |
| at akka.actor.ArgsReflectConstructor.produce(Props.scala:352) | |
| at akka.actor.Props.newActor(Props.scala:252) | |
| at akka.actor.ActorCell.newActor(ActorCell.scala:552) | |
| at akka.actor.ActorCell.create(ActorCell.scala:578) | |
| at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) | |
| at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) | |
| at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:263) | |
| at akka.dispatch.Mailbox.run(Mailbox.scala:219) | |
| at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) | |
| at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) | |
| at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) | |
| at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) | |
| at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) | |
| [info] - must bind and unbind correctly (308 milliseconds) | |
| [WARN] [07/07/2015 13:11:50.585] [TcpSpec-akka.actor.default-dispatcher-15] [akka://TcpSpec/system/IO-TCP-STREAM/server-14-localhost%2F127.0.0.1%3A50129] received dead letter from Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/39#1504785886]: Unbound | |
| [WARN] [07/07/2015 13:11:50.661] [TcpSpec-akka.actor.default-dispatcher-11] [akka://TcpSpec/system/IO-TCP/selectors/$a/61] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-29-localhost%2F127.0.0.1%3A50145/$a#764112107]: ResumeReading | |
| [info] - must not shut down connections after the connection stream cancelled (97 milliseconds) | |
| [WARN] [07/07/2015 13:11:50.746] [TcpSpec-akka.actor.default-dispatcher-15] [akka://TcpSpec/system/IO-TCP/selectors/$a/65] unhandled message from Actor[akka://TcpSpec/system/IO-TCP-STREAM/server-31-localhost%2F127.0.0.1%3A50147/$a#-519616808]: ResumeReading | |
| [info] - must shut down properly even if some accepted connection Flows have not been subscribed to (3 seconds, 863 milliseconds) | |
| Coroner Thread Count started at 15, ended at 10, peaked at 43 in akka.stream.io.TcpSpec | |
| [info] ScalaTest | |
| [info] Run completed in 18 seconds, 942 milliseconds. | |
| [info] Total number of tests run: 20 | |
| [info] Suites: completed 1, aborted 0 | |
| [info] Tests: succeeded 19, failed 1, canceled 0, ignored 0, pending 0 | |
| [info] *** 1 TEST FAILED *** | |
| [error] Failed: Total 20, Failed 1, Errors 0, Passed 19 | |
| [error] Failed tests: | |
| [error] akka.stream.io.TcpSpec | |
| [error] (akka-stream-tests-experimental/test:testOnly) sbt.TestsFailedException: Tests unsuccessful | |
| [error] Total time: 22 s, completed Jul 7, 2015 1:11:55 PM |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment