Skip to content

Instantly share code, notes, and snippets.

@ktoso
Created November 27, 2015 14:03
Show Gist options
  • Save ktoso/037a0633fb7726725bcd to your computer and use it in GitHub Desktop.
Save ktoso/037a0633fb7726725bcd to your computer and use it in GitHub Desktop.
[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