Created
November 27, 2015 14:03
-
-
Save ktoso/037a0633fb7726725bcd 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
[DEBUG] [11/27/2015 15:00:23.927] [pool-608-thread-3-ScalaTest-running-TcpSpec] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$StopChildren$] | |
[DEBUG] [11/27/2015 15:00:23.939] [TcpSpec-akka.test.stream-dispatcher-6] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$StoppedChildren$] | |
[DEBUG] [11/27/2015 15:00:24.161] [TcpSpec-akka.actor.default-dispatcher-4] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Successfully bound to /127.0.0.1:61378 | |
ob = Outbound(Actor[akka://TcpSpec/system/IO-TCP#-1374379735],Connect(localhost/127.0.0.1:61378,None,List(),None,true),scala.concurrent.impl.Promise$DefaultPromise@3854aa8c,true) | |
ob = Outbound(Actor[akka://TcpSpec/system/IO-TCP#-1374379735],Connect(localhost/127.0.0.1:61378,None,List(),None,true),scala.concurrent.impl.Promise$DefaultPromise@7d5623e2,true) | |
[DEBUG] [11/27/2015 15:00:24.243] [TcpSpec-akka.actor.default-dispatcher-4] [akka://TcpSpec/system/IO-TCP/selectors/$a/1] Attempting connection to [localhost/127.0.0.1:61378] | |
[DEBUG] [11/27/2015 15:00:24.243] [TcpSpec-akka.actor.default-dispatcher-5] [akka://TcpSpec/system/IO-TCP/selectors/$a/2] Attempting connection to [localhost/127.0.0.1:61378] | |
[DEBUG] [11/27/2015 15:00:24.245] [TcpSpec-akka.io.pinned-dispatcher-8] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.io.SelectionHandler$ChannelConnectable$] | |
[DEBUG] [11/27/2015 15:00:24.246] [TcpSpec-akka.io.pinned-dispatcher-8] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.io.SelectionHandler$ChannelAcceptable$] | |
[DEBUG] [11/27/2015 15:00:24.246] [TcpSpec-akka.actor.default-dispatcher-5] [akka://TcpSpec/system/IO-TCP/selectors/$a/1] Connection established to [localhost/127.0.0.1:61378] | |
[DEBUG] [11/27/2015 15:00:24.246] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] New connection accepted | |
[DEBUG] [11/27/2015 15:00:24.246] [TcpSpec-akka.actor.default-dispatcher-4] [akka://TcpSpec/system/IO-TCP/selectors/$a/2] Connection established to [localhost/127.0.0.1:61378] | |
[DEBUG] [11/27/2015 15:00:24.260] [TcpSpec-akka.actor.default-dispatcher-3] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] New connection accepted | |
[DEBUG] [11/27/2015 15:00:24.292] [TcpSpec-akka.io.pinned-dispatcher-8] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.io.SelectionHandler$ChannelReadable$] | |
[DEBUG] [11/27/2015 15:00:24.587] [TcpSpec-akka.actor.default-dispatcher-16] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.actor.Terminated] | |
listener = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#-2041235648] | |
[DEBUG] [11/27/2015 15:00:25.273] [TcpSpec-akka.actor.default-dispatcher-16] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Unbinding endpoint /127.0.0.1:61378 | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#-2041235648], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/4#1923143221], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
[DEBUG] [11/27/2015 15:00:25.278] [TcpSpec-akka.actor.default-dispatcher-16] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Unbound endpoint /127.0.0.1:61378, stopping listener | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#-2041235648], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/4#1923143221], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
[DEBUG] [11/27/2015 15:00:25.282] [TcpSpec-akka.actor.default-dispatcher-3] [LocalActorRefProvider(akka://TcpSpec)] resolve of path sequence [/user/StreamSupervisor-0/StageActorRef-0] failed | |
[DEBUG] [11/27/2015 15:00:25.289] [TcpSpec-akka.actor.default-dispatcher-16] [akka://TcpSpec/system/IO-TCP/selectors/$a/4] Monitored actor [Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0]] terminated | |
[DEBUG] [11/27/2015 15:00:25.291] [TcpSpec-akka.actor.default-dispatcher-3] [akka://TcpSpec/system/IO-TCP/selectors/$a/2] Closing connection due to IO error java.io.IOException: Connection reset by peer | |
[DEBUG] [11/27/2015 15:00:25.300] [pool-608-thread-3-ScalaTest-running-TcpSpec] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$GetChildren$] | |
[DEBUG] [11/27/2015 15:00:25.307] [TcpSpec-akka.test.stream-dispatcher-14] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$Children] | |
[info] - must xoxoxo shut down properly even if some accepted connection Flows have not been subscribed to (1 second, 486 milliseconds) | |
[DEBUG] [11/27/2015 15:00:25.330] [TcpSpec-akka.actor.default-dispatcher-3] [LocalActorRefProvider(akka://TcpSpec)] resolve of path sequence [/user] failed | |
[DEBUG] [11/27/2015 15:00:25.332] [TcpSpec-akka.actor.default-dispatcher-3] [EventStream] shutting down: StandardOutLogger started | |
Coroner Thread Count started at 43, ended at 37, peaked at 53 in akka.stream.io.TcpSpec | |
[info] ScalaTest | |
[info] Run completed in 2 seconds, 578 milliseconds. | |
[info] Total number of tests run: 1 | |
[info] Suites: completed 1, aborted 0 | |
[info] Tests: succeeded 1, failed 0, canceled 0, ignored 0, pending 0 | |
[info] All tests passed. | |
[info] Passed: Total 1, Failed 0, Errors 0, Passed 1 | |
[success] Total time: 8 s, completed 27-Nov-2015 15:00:25 | |
akka-stream-tests-experimental > testOnly *TcpSpec* -- -z xoxo | |
[DEBUG] [11/27/2015 15:00:32.268] [pool-609-thread-1] [EventStream(akka://TcpSpec)] logger log1-TestEventListener started | |
[DEBUG] [11/27/2015 15:00:32.270] [pool-609-thread-1] [EventStream(akka://TcpSpec)] Default Loggers started | |
[WARN] [11/27/2015 15:00:32.457] [pool-609-thread-1] [ActorMaterializerImpl(akka://TcpSpec)] Fuzzing mode is enabled on this system. If you see this warning on your production system then set akka.materializer.debug.fuzzing-mode to off. | |
[info] TcpSpec: | |
Coroner Thread Count starts at 40 in akka.stream.io.TcpSpec | |
[info] Outgoing TCP stream | |
[info] TCP listen stream | |
[DEBUG] [11/27/2015 15:00:32.690] [pool-609-thread-1-ScalaTest-running-TcpSpec] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$StopChildren$] | |
[DEBUG] [11/27/2015 15:00:32.700] [TcpSpec-akka.test.stream-dispatcher-4] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$StoppedChildren$] | |
[DEBUG] [11/27/2015 15:00:32.904] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Successfully bound to /127.0.0.1:61392 | |
ob = Outbound(Actor[akka://TcpSpec/system/IO-TCP#1348871752],Connect(localhost/127.0.0.1:61392,None,List(),None,true),scala.concurrent.impl.Promise$DefaultPromise@731ee8b3,true) | |
ob = Outbound(Actor[akka://TcpSpec/system/IO-TCP#1348871752],Connect(localhost/127.0.0.1:61392,None,List(),None,true),scala.concurrent.impl.Promise$DefaultPromise@7741a5db,true) | |
[DEBUG] [11/27/2015 15:00:32.985] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/1] Attempting connection to [localhost/127.0.0.1:61392] | |
[DEBUG] [11/27/2015 15:00:32.985] [TcpSpec-akka.actor.default-dispatcher-5] [akka://TcpSpec/system/IO-TCP/selectors/$a/2] Attempting connection to [localhost/127.0.0.1:61392] | |
[DEBUG] [11/27/2015 15:00:32.987] [TcpSpec-akka.io.pinned-dispatcher-7] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.io.SelectionHandler$ChannelConnectable$] | |
[DEBUG] [11/27/2015 15:00:32.988] [TcpSpec-akka.io.pinned-dispatcher-7] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.io.SelectionHandler$ChannelAcceptable$] | |
[DEBUG] [11/27/2015 15:00:32.988] [TcpSpec-akka.actor.default-dispatcher-14] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] New connection accepted | |
[DEBUG] [11/27/2015 15:00:32.988] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/1] Connection established to [localhost/127.0.0.1:61392] | |
[DEBUG] [11/27/2015 15:00:32.988] [TcpSpec-akka.actor.default-dispatcher-5] [akka://TcpSpec/system/IO-TCP/selectors/$a/2] Connection established to [localhost/127.0.0.1:61392] | |
[DEBUG] [11/27/2015 15:00:33.006] [TcpSpec-akka.actor.default-dispatcher-5] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] New connection accepted | |
[DEBUG] [11/27/2015 15:00:33.029] [TcpSpec-akka.io.pinned-dispatcher-7] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.io.SelectionHandler$ChannelReadable$] | |
[DEBUG] [11/27/2015 15:00:33.308] [TcpSpec-akka.actor.default-dispatcher-14] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.actor.Terminated] | |
listener = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#1870880175] | |
[DEBUG] [11/27/2015 15:00:34.028] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Unbinding endpoint /127.0.0.1:61392 | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#1870880175], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/4#1930091694], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
[DEBUG] [11/27/2015 15:00:34.031] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Unbound endpoint /127.0.0.1:61392, stopping listener | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/0#1870880175], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
watcher = Actor[akka://TcpSpec/system/IO-TCP/selectors/$a/4#1930091694], of = Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0] | |
[DEBUG] [11/27/2015 15:00:34.035] [TcpSpec-akka.actor.default-dispatcher-14] [LocalActorRefProvider(akka://TcpSpec)] resolve of path sequence [/user/StreamSupervisor-0/StageActorRef-0] failed | |
[DEBUG] [11/27/2015 15:00:34.042] [TcpSpec-akka.actor.default-dispatcher-2] [akka://TcpSpec/system/IO-TCP/selectors/$a/4] Monitored actor [Actor[akka://TcpSpec/user/StreamSupervisor-0/StageActorRef-0]] terminated | |
[DEBUG] [11/27/2015 15:00:34.043] [TcpSpec-akka.actor.default-dispatcher-14] [akka://TcpSpec/system/IO-TCP/selectors/$a/1] Closing connection due to IO error java.io.IOException: Connection reset by peer | |
[info] - must xoxoxo shut down properly even if some accepted connection Flows have not been subscribed to *** FAILED *** (1 second, 411 milliseconds) | |
[info] akka.stream.StreamTcpException: The connection closed with error: Connection reset by peer | |
[DEBUG] [11/27/2015 15:00:34.070] [TcpSpec-akka.actor.default-dispatcher-3] [LocalActorRefProvider(akka://TcpSpec)] resolve of path sequence [/user] failed | |
[DEBUG] [11/27/2015 15:00:34.072] [TcpSpec-akka.actor.default-dispatcher-3] [EventStream] shutting down: StandardOutLogger started | |
Coroner Thread Count started at 40, ended at 42, peaked at 52 in akka.stream.io.TcpSpec |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment