-
-
Save ktoso/4c2effc56cf662588026 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
| $ sbt -J-agentpath:/Applications/YourKit_Java_Profiler_2015_build_15074.app/Contents/Resources/bin/mac/libyjpagent.jnilib '; project akka-http-tests-experimental; test:runMain akka.http.scaladsl.server.ConnectionTestApp' | |
| [YourKit Java Profiler 2015 build 15074] Log file: /Users/ktoso/.yjp/log/sbt-launch-14837.log | |
| [info] Loading global plugins from /Users/ktoso/.sbt/0.13/plugins | |
| [info] Loading project definition from /Users/ktoso/code/akka/project | |
| [info] Set current project to akka (in build file:/Users/ktoso/code/akka/) | |
| [info] Set current project to akka-http-tests-experimental (in build file:/Users/ktoso/code/akka/) | |
| [info] Running akka.http.scaladsl.server.ConnectionTestApp | |
| [DEBUG] [11/20/2015 12:37:15.385] [run-main-0] [EventStream(akka://ConnectionTest)] logger log1-TestEventListener started | |
| [DEBUG] [11/20/2015 12:37:15.390] [run-main-0] [EventStream(akka://ConnectionTest)] Default Loggers started | |
| [DEBUG] [11/20/2015 12:37:16.676] [run-main-0] [ActorSystem(ConnectionTest)] Materializing ActorRefSource[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-1-4-actorRefSource#-1741339411]] | |
| u =>http://127.0.0.1:6666/test/1 | |
| u =>http://127.0.0.1:6666/test/2 | |
| u =>http://127.0.0.1:6666/test/3 | |
| u =>http://127.0.0.1:6666/test/4 | |
| u =>http://127.0.0.1:6666/test/5 | |
| u =>http://127.0.0.1:6666/test/6 | |
| u =>http://127.0.0.1:6666/test/7 | |
| u =>http://127.0.0.1:6666/test/8 | |
| u =>http://127.0.0.1:6666/test/9 | |
| u =>http://127.0.0.1:6666/test/10 | |
| u =>http://127.0.0.1:6666/test/11 | |
| u =>http://127.0.0.1:6666/test/12 | |
| u =>http://127.0.0.1:6666/test/13 | |
| u =>http://127.0.0.1:6666/test/14 | |
| u =>http://127.0.0.1:6666/test/15 | |
| u =>http://127.0.0.1:6666/test/16 | |
| .... | |
| u =>http://127.0.0.1:6666/test/2993 | |
| u =>http://127.0.0.1:6666/test/2994 | |
| u =>http://127.0.0.1:6666/test/2995 | |
| u =>http://127.0.0.1:6666/test/2996 | |
| u =>http://127.0.0.1:6666/test/2997 | |
| u =>http://127.0.0.1:6666/test/2998 | |
| u =>http://127.0.0.1:6666/test/2999 | |
| u =>http://127.0.0.1:6666/test/3000 | |
| !!!!! SLOT PRE START !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-2#-260503023] | |
| !!!!! SLOT PRE START !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-0#632896808] | |
| [DEBUG] [11/20/2015 12:37:18.671] [ConnectionTest-akka.actor.default-dispatcher-2] [akka://ConnectionTest/user/SlotProcessor-0] become waitingForSubscribePending | |
| [DEBUG] [11/20/2015 12:37:18.671] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/SlotProcessor-2] become waitingForSubscribePending | |
| [DEBUG] [11/20/2015 12:37:18.678] [ConnectionTest-akka.actor.default-dispatcher-2] [akka://ConnectionTest/user/SlotProcessor-0] become unconnected, from subscriber pending | |
| [DEBUG] [11/20/2015 12:37:18.678] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/SlotProcessor-2] become unconnected, from subscriber pending | |
| [DEBUG] [11/20/2015 12:37:18.678] [ConnectionTest-akka.actor.default-dispatcher-13] [akka://ConnectionTest/user/SlotProcessor-0] unconnected got = Request(16) | |
| [DEBUG] [11/20/2015 12:37:18.678] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/SlotProcessor-2] unconnected got = Request(16) | |
| !!!!! SLOT PRE START !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-1#-1388002785] | |
| [DEBUG] [11/20/2015 12:37:18.710] [ConnectionTest-akka.actor.default-dispatcher-13] [akka://ConnectionTest/user/SlotProcessor-1] become waitingForSubscribePending | |
| [DEBUG] [11/20/2015 12:37:18.710] [ConnectionTest-akka.actor.default-dispatcher-13] [akka://ConnectionTest/user/SlotProcessor-1] become unconnected, from subscriber pending | |
| [DEBUG] [11/20/2015 12:37:18.710] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/SlotProcessor-1] unconnected got = Request(16) | |
| !!!!! SLOT PRE START !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-3#-367729360] | |
| [DEBUG] [11/20/2015 12:37:18.714] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/SlotProcessor-3] become waitingForSubscribePending | |
| [DEBUG] [11/20/2015 12:37:18.714] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/SlotProcessor-3] become unconnected, from subscriber pending | |
| [DEBUG] [11/20/2015 12:37:18.715] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/SlotProcessor-3] unconnected got = Request(16) | |
| [DEBUG] [11/20/2015 12:37:18.728] [ConnectionTest-akka.actor.default-dispatcher-3] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool request = PoolRequest(HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/4,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@125e91a8) | |
| [DEBUG] [11/20/2015 12:37:18.730] [ConnectionTest-akka.actor.default-dispatcher-3] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool request = PoolRequest(HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/2,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@631a5957) | |
| [DEBUG] [11/20/2015 12:37:18.730] [ConnectionTest-akka.actor.default-dispatcher-3] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool request = PoolRequest(HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/3,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1f7c09d3) | |
| [DEBUG] [11/20/2015 12:37:18.730] [ConnectionTest-akka.actor.default-dispatcher-3] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool request = PoolRequest(HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/1,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1ec41436) | |
| [DEBUG] [11/20/2015 12:37:18.734] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforePoolFlow] Element: RequestContext(HttpRequest(HttpMethod(GET),/test/4,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@125e91a8,5) | |
| [DEBUG] [11/20/2015 12:37:18.734] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforePoolFlow] Element: RequestContext(HttpRequest(HttpMethod(GET),/test/2,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@631a5957,5) | |
| [DEBUG] [11/20/2015 12:37:18.735] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforePoolFlow] Element: RequestContext(HttpRequest(HttpMethod(GET),/test/3,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1f7c09d3,5) | |
| [DEBUG] [11/20/2015 12:37:18.735] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforePoolFlow] Element: RequestContext(HttpRequest(HttpMethod(GET),/test/1,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1ec41436,5) | |
| ... | |
| request on Running = http://127.0.0.1:6666/test/47 | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/74,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),74) | |
| [ERROR] [11/20/2015 12:37:19.721] [ConnectionTest-akka.actor.default-dispatcher-19] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream failed. (akka.stream.StreamTcpException) | |
| 42: java.lang.RuntimeException: Unexpected (early) disconnect | |
| 40: java.lang.RuntimeException: Unexpected (early) disconnect | |
| request on Running = http://127.0.0.1:6666/test/50 | |
| request on Running = http://127.0.0.1:6666/test/49 | |
| [DEBUG] [11/20/2015 12:37:19.721] [ConnectionTest-akka.actor.default-dispatcher-4] [akka://ConnectionTest/user/StreamSupervisor-0/flow-12-2-InternalConnectionFlow-actorSubscriberSink] finishing = OnError(akka.stream.StreamTcpException: Connection failed.)and then stop, slot:SlotProcessor-2 | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/75,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),75) | |
| 39: akka.stream.StreamTcpException: Connection failed. | |
| 41: akka.stream.StreamTcpException: Connection failed. | |
| [INFO] [11/20/2015 12:37:19.721] [ConnectionTest-akka.actor.default-dispatcher-4] [akka://ConnectionTest/user/StreamSupervisor-0/flow-12-2-InternalConnectionFlow-actorSubscriberSink] postStop of FlowOutportActor self:flow-12-2-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-2 | |
| 45: java.lang.RuntimeException: Unexpected (early) disconnect | |
| 46: akka.stream.StreamTcpException: Connection failed. | |
| 43: akka.stream.StreamTcpException: Connection failed. | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/76,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),76) | |
| 44: akka.stream.StreamTcpException: Connection failed. | |
| [INFO] [11/20/2015 12:37:19.721] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/SlotProcessor-2] total demand = 15 | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/77,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),77) | |
| [DEBUG] [11/20/2015 12:37:19.721] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/SlotProcessor-2] Slot 2 disconnected after akka.stream.StreamTcpException: Connection failed. | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/78,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),78) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/79,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),79) | |
| [DEBUG] [11/20/2015 12:37:19.733] [ConnectionTest-akka.actor.default-dispatcher-25] [akka://ConnectionTest/system/IO-TCP/selectors/$a/10] Attempting connection to [/127.0.0.1:6666] | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/80,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),80) | |
| [DEBUG] [11/20/2015 12:37:19.735] [ConnectionTest-akka.actor.default-dispatcher-25] [akka://ConnectionTest/system/IO-TCP/selectors/$a/10] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| [WARN] [11/20/2015 12:37:19.736] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] Empty response yet we should signal the failure! | |
| [WARN] [11/20/2015 12:37:19.736] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/SlotProcessor-2] Empty response yet we should signal the failure! | |
| request on Running = http://127.0.0.1:6666/test/51 | |
| 48: java.lang.RuntimeException: Unexpected (early) disconnect | |
| [DEBUG] [11/20/2015 12:37:19.737] [ConnectionTest-akka.actor.default-dispatcher-3] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:19.737] [ConnectionTest-akka.actor.default-dispatcher-26] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:19.738] [ConnectionTest-akka.actor.default-dispatcher-15] [akka://ConnectionTest/user/StreamSupervisor-0/flow-22-0-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:19.738] [ConnectionTest-akka.actor.default-dispatcher-15] [akka://ConnectionTest/user/StreamSupervisor-0/flow-22-0-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-22-0-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:19.745] [ConnectionTest-akka.actor.default-dispatcher-2] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterConnectionFlowIn] Upstream finished. | |
| [DEBUG] [11/20/2015 12:37:19.745] [ConnectionTest-akka.actor.default-dispatcher-22] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [[[CONNECTION_FLOW]]] Upstream finished. | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] results = List(Disconnected(3,1), ResponseDelivery(ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/4,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@125e91a8,2),Failure(java.lang.RuntimeException: Unexpected (early) disconnect)))) | |
| request on Running = http://127.0.0.1:6666/test/54 | |
| request on Running = http://127.0.0.1:6666/test/53 | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/SlotProcessor-2] results = List(Disconnected(2,1), ResponseDelivery(ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/1,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1ec41436,4),Failure(java.lang.RuntimeException: Unexpected (early) disconnect)))) | |
| request on Running = http://127.0.0.1:6666/test/52 | |
| 47: akka.stream.StreamTcpException: Connection failed. | |
| 50: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/SlotProcessor-2] == become unconnected == SlotProcessor-2 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$waitingForDemandFromConnection$1.applyOrElse(PoolSlot.scala:214) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| request on Running = http://127.0.0.1:6666/test/57 | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/SlotProcessor-2] become unconnected, because: Some(Connection failed.) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/81,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),81) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/82,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),82) | |
| request on Running = http://127.0.0.1:6666/test/56 | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/83,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),83) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/84,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),84) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/85,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),85) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/86,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),86) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/87,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),87) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/88,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),88) | |
| request on Running = http://127.0.0.1:6666/test/55 | |
| 49: akka.stream.StreamTcpException: Connection failed. | |
| request on Running = http://127.0.0.1:6666/test/58 | |
| 51: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] == become unconnected == SlotProcessor-3 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$waitingForDemandFromConnection$1.applyOrElse(PoolSlot.scala:214) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| 53: java.lang.RuntimeException: Unexpected (early) disconnect | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] become unconnected, because: Some(Connection failed.) | |
| 52: akka.stream.StreamTcpException: Connection failed. | |
| 54: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] FROM CONNECTION = FromConnection(Cancel) | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-18] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-3] Element: Disconnected(3,1) | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] from = Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-18-36-InternalConnectionFlow-actorPublisherSource#-732481249] | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] totalDemand = 12 | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] remainingRequested = 15 | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] canceled = false | |
| [DEBUG] [11/20/2015 12:37:19.749] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/SlotProcessor-3] isActive = true | |
| [DEBUG] [11/20/2015 12:37:19.750] [ConnectionTest-akka.actor.default-dispatcher-24] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-2] Element: Disconnected(2,1) | |
| [DEBUG] [11/20/2015 12:37:19.750] [ConnectionTest-akka.actor.default-dispatcher-18] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-3] Element: ResponseDelivery(ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/4,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@125e91a8,2),Failure(java.lang.RuntimeException: Unexpected (early) disconnect))) | |
| [DEBUG] [11/20/2015 12:37:19.750] [ConnectionTest-akka.actor.default-dispatcher-24] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-2] Element: ResponseDelivery(ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/1,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1ec41436,4),Failure(java.lang.RuntimeException: Unexpected (early) disconnect))) | |
| [DEBUG] [11/20/2015 12:37:19.750] [ConnectionTest-akka.actor.default-dispatcher-24] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterPoolFlow] Element: ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/4,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@125e91a8,2),Failure(java.lang.RuntimeException: Unexpected (early) disconnect)) | |
| request on Running = http://127.0.0.1:6666/test/59 | |
| [DEBUG] [11/20/2015 12:37:19.750] [ConnectionTest-akka.actor.default-dispatcher-24] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterPoolFlow] Element: ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/1,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1ec41436,4),Failure(java.lang.RuntimeException: Unexpected (early) disconnect)) | |
| 57: java.lang.RuntimeException: Unexpected (early) disconnect | |
| [DEBUG] [11/20/2015 12:37:19.750] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool got response = ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/4,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@125e91a8,2),Failure(java.lang.RuntimeException: Unexpected (early) disconnect)) | |
| 56: akka.stream.StreamTcpException: Connection failed. | |
| request on Running = http://127.0.0.1:6666/test/60 | |
| [DEBUG] [11/20/2015 12:37:19.751] [ConnectionTest-akka.actor.default-dispatcher-18] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool got response = ResponseContext(RequestContext(HttpRequest(HttpMethod(GET),/test/1,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1ec41436,4),Failure(java.lang.RuntimeException: Unexpected (early) disconnect)) | |
| [DEBUG] [11/20/2015 12:37:19.753] [ConnectionTest-akka.actor.default-dispatcher-3] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream finished. | |
| [DEBUG] [11/20/2015 12:37:19.755] [ConnectionTest-akka.actor.default-dispatcher-17] [ActorSystem(ConnectionTest)] Materializing ActorPublisherSource[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource#-1795072031]] | |
| [INFO] [11/20/2015 12:37:19.755] [ConnectionTest-akka.actor.default-dispatcher-14] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource] preStart of FlowInportActor self:flow-21-34-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-0 | |
| request on Running = http://127.0.0.1:6666/test/62 | |
| request on Running = http://127.0.0.1:6666/test/61 | |
| 58: java.lang.RuntimeException: Unexpected (early) disconnect | |
| 55: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:19.755] [ConnectionTest-akka.actor.default-dispatcher-14] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource] request = Request(16), slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-21-36-InternalConnectionFlow-actorSubscriberSink#-614244733]] | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] request from connection in waitingForDemandFromConnection() >>>>> | |
| [INFO] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-36-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-21-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] from = Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource#-1795072031] | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-24] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-36-InternalConnectionFlow-actorSubscriberSink] Requesting 14, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] totalDemand = 14 | |
| request on Running = http://127.0.0.1:6666/test/66 | |
| request on Running = http://127.0.0.1:6666/test/65 | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/89,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),89) | |
| request on Running = http://127.0.0.1:6666/test/64 | |
| request on Running = http://127.0.0.1:6666/test/63 | |
| 59: akka.stream.StreamTcpException: Connection failed. | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/90,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),90) | |
| 60: akka.stream.StreamTcpException: Connection failed. | |
| 62: akka.stream.StreamTcpException: Connection failed. | |
| 61: akka.stream.StreamTcpException: Connection failed. | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/91,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),91) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/92,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),92) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/93,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),93) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/94,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),94) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/95,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),95) | |
| Delivering to client flow: (HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/96,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),96) | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] remainingRequested = 15 | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] canceled = false | |
| [DEBUG] [11/20/2015 12:37:19.757] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] isActive = true | |
| [INFO] [11/20/2015 12:37:19.758] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] inflightRequests = Queue(RequestContext(HttpRequest(HttpMethod(GET),/test/3,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@1f7c09d3,3)) | |
| [DEBUG] [11/20/2015 12:37:19.758] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] become running | |
| [DEBUG] [11/20/2015 12:37:19.758] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource] on next = HttpRequest(HttpMethod(GET),/test/3,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)), slot:SlotProcessor-0 | |
| request on Running = http://127.0.0.1:6666/test/70 | |
| [DEBUG] [11/20/2015 12:37:19.758] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Element: HttpRequest(HttpMethod(GET),/test/3,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [DEBUG] [11/20/2015 12:37:19.758] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/system/IO-TCP/selectors/$a/11] Attempting connection to [/127.0.0.1:6666] | |
| [DEBUG] [11/20/2015 12:37:19.759] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Element: HttpRequest(HttpMethod(GET),/test/3,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [DEBUG] [11/20/2015 12:37:19.759] [ConnectionTest-akka.actor.default-dispatcher-15] [akka://ConnectionTest/system/IO-TCP/selectors/$a/11] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| request on Running = http://127.0.0.1:6666/test/69 | |
| request on Running = http://127.0.0.1:6666/test/68 | |
| request on Running = http://127.0.0.1:6666/test/67 | |
| 66: java.lang.RuntimeException: Unexpected (early) disconnect | |
| [DEBUG] [11/20/2015 12:37:19.761] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| 63: java.lang.RuntimeException: Unexpected (early) disconnect | |
| 65: java.lang.RuntimeException: Unexpected (early) disconnect | |
| 64: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:19.761] [ConnectionTest-akka.actor.default-dispatcher-25] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:19.761] [ConnectionTest-akka.actor.default-dispatcher-4] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:19.761] [ConnectionTest-akka.actor.default-dispatcher-4] [akka://ConnectionTest/user/StreamSupervisor-0/flow-21-34-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-21-34-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:19.762] [ConnectionTest-akka.actor.default-dispatcher-10] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-22-36-InternalConnectionFlow-actorSubscriberSink#-1798055770]] | |
| [DEBUG] [11/20/2015 12:37:19.762] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/SlotProcessor-1] request from connection in waitingForDemandFromConnection() >>>>> | |
| request on Running = http://127.0.0.1:6666/test/71 | |
| .... | |
| ===================== | |
| -> / LocalActorRefProvider$$anon$1 class akka.actor.LocalActorRefProvider$Guardian status=0 2 children | |
| ⌊-> system LocalActorRef class akka.actor.LocalActorRefProvider$SystemGuardian status=0 3 children | |
| | ⌊-> IO-TCP RepointableActorRef class akka.io.TcpManager status=0 1 children | |
| | | ⌊-> selectors RoutedActorRef class akka.routing.RouterPoolActor status=0 1 children | |
| | | ⌊-> $a LocalActorRef class akka.io.SelectionHandler status=0 4 children | |
| | | ⌊-> 1136 LocalActorRef class akka.io.TcpOutgoingConnection status=0 no children | |
| | | ⌊-> 1137 LocalActorRef class akka.io.TcpOutgoingConnection status=0 no children | |
| | | ⌊-> 1138 LocalActorRef class akka.io.TcpOutgoingConnection status=0 no children | |
| | | ⌊-> 1139 LocalActorRef class akka.io.TcpOutgoingConnection status=0 no children | |
| | ⌊-> IO-TCP-STREAM RepointableActorRef class akka.stream.impl.io.StreamTcpManager status=0 4 children | |
| | | ⌊-> client-1137-%2F127.0.0.1%3A6666 LocalActorRef class akka.stream.impl.io.OutboundTcpStreamActor status=0 no children | |
| | | ⌊-> client-1138-%2F127.0.0.1%3A6666 LocalActorRef class akka.stream.impl.io.OutboundTcpStreamActor status=0 no children | |
| | | ⌊-> client-1139-%2F127.0.0.1%3A6666 LocalActorRef class akka.stream.impl.io.OutboundTcpStreamActor status=0 no children | |
| | | ⌊-> client-1140-%2F127.0.0.1%3A6666 LocalActorRef class akka.stream.impl.io.OutboundTcpStreamActor status=0 no children | |
| | ⌊-> log1-TestEventListener RepointableActorRef class akka.testkit.TestEventListener status=2 no children | |
| ⌊-> user LocalActorRef class akka.actor.LocalActorRefProvider$Guardian status=0 6 children | |
| ⌊-> PoolInterfaceActor-0 RepointableActorRef class akka.http.impl.engine.client.PoolInterfaceActor status=0 no children | |
| ⌊-> SlotProcessor-0 RepointableActorRef class akka.http.impl.engine.client.PoolSlot$SlotProcessor status=0 no children | |
| ⌊-> SlotProcessor-1 RepointableActorRef class akka.http.impl.engine.client.PoolSlot$SlotProcessor status=0 no children | |
| ⌊-> SlotProcessor-2 RepointableActorRef class akka.http.impl.engine.client.PoolSlot$SlotProcessor status=0 no children | |
| ⌊-> SlotProcessor-3 RepointableActorRef class akka.http.impl.engine.client.PoolSlot$SlotProcessor status=0 no children | |
| ⌊-> StreamSupervisor-0 RepointableActorRef class akka.stream.impl.StreamSupervisor status=0 1327 children | |
| ⌊-> flow-1-0-unknown-operation RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1-1-foreachSink RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1-2-foreachSink RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1-4-actorRefSource RepointableActorRef class akka.stream.impl.ActorRefSourceActor status=0 no children | |
| ⌊-> flow-1-5-unknown-operation RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1-6-unknown-operation RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1-7-unknown-operation RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-100-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1000-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1001-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1002-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1006-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1007-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1009-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1010-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1014-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1016-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1017-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1018-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-102-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1023-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1024-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1027-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1028-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1030-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1032-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1033-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1034-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1038-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-104-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1040-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1043-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1044-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1047-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1048-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-105-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1051-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1052-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1055-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1056-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1057-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1058-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-106-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1062-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1063-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1066-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1067-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1070-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1071-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1072-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1076-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1078-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1079-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-108-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1080-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1081-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1085-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1086-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1088-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-109-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1090-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1093-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1094-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1098-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1099-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-11-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1101-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1104-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1106-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1107-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1108-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1109-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1113-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1114-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1115-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1117-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1120-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1122-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1123-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1124-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1128-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-113-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1131-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1132-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1133-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1134-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1139-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-114-31-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1140-30-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1141-32-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ⌊-> flow-1143-33-InternalConnectionFlow RepointableActorRef class akka.stream.impl.fusing.ActorGraphInterpreter status=0 no children | |
| ... | |
| ======================== | |
| request on Running = http://127.0.0.1:6666/test/221 | |
| request on Running = http://127.0.0.1:6666/test/220 | |
| request on Running = http://127.0.0.1:6666/test/219 | |
| request on Running = http://127.0.0.1:6666/test/218 | |
| 215: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-20] [akka://ConnectionTest/user/SlotProcessor-1] remainingRequested = 15 | |
| 217: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-20] [akka://ConnectionTest/user/SlotProcessor-1] canceled = false | |
| 213: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-20] [akka://ConnectionTest/user/SlotProcessor-1] isActive = true | |
| [INFO] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-36-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-354-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-36-InternalConnectionFlow-actorSubscriberSink] Requesting 14, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-20] [akka://ConnectionTest/user/SlotProcessor-1] inflightRequests = Queue(RequestContext(HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@623d3c53,3)) | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-20] [akka://ConnectionTest/user/SlotProcessor-1] become running | |
| 214: akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/system/IO-TCP/selectors/$a/204] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:37:21.346] [ConnectionTest-akka.actor.default-dispatcher-20] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-0-InternalConnectionFlow-actorPublisherSource] on next = HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)), slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/system/IO-TCP/selectors/$a/205] Attempting connection to [/127.0.0.1:6666] | |
| [DEBUG] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-6] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-18] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-12] [akka://ConnectionTest/user/StreamSupervisor-0/flow-353-34-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-12] [akka://ConnectionTest/user/StreamSupervisor-0/flow-353-34-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-353-34-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-18] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterConnectionFlowIn] Upstream failed, cause: StreamTcpException: Connection failed. | |
| [ERROR] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-12] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [[[CONNECTION_FLOW]]] Upstream failed. (akka.stream.StreamTcpException) | |
| [ERROR] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-19] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream failed. (akka.stream.StreamTcpException) | |
| [ERROR] [11/20/2015 12:37:21.347] [ConnectionTest-akka.actor.default-dispatcher-7] [ActorSystem(ConnectionTest)] Outgoing request stream error (akka.stream.StreamTcpException) | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-6] [akka://ConnectionTest/system/IO-TCP/selectors/$a/205] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/StreamSupervisor-0/flow-353-36-InternalConnectionFlow-actorSubscriberSink] finishing = OnError(akka.stream.StreamTcpException: Connection failed.)and then stop, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/StreamSupervisor-0/flow-353-36-InternalConnectionFlow-actorSubscriberSink] postStop of FlowOutportActor self:flow-353-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] total demand = 11 | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] Slot 0 disconnected after akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] results = List(Disconnected(0,1), RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@7cc602fe,2))) | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-0] Element: Disconnected(0,1) | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] == become unconnected == SlotProcessor-0 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$running$1.applyOrElse(PoolSlot.scala:249) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/SlotProcessor-0] become unconnected, because: Some(Connection failed.) | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-0] Element: RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@7cc602fe,2)) | |
| [DEBUG] [11/20/2015 12:37:21.348] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterConnectionFlowIn] Upstream failed, cause: StreamTcpException: Connection failed. | |
| [ERROR] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [[[CONNECTION_FLOW]]] Upstream failed. (akka.stream.StreamTcpException) | |
| [ERROR] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-12] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream failed. (akka.stream.StreamTcpException) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-14] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-36-InternalConnectionFlow-actorSubscriberSink] finishing = OnError(akka.stream.StreamTcpException: Connection failed.)and then stop, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-14] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-36-InternalConnectionFlow-actorSubscriberSink] postStop of FlowOutportActor self:flow-354-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] total demand = 14 | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] Slot 1 disconnected after akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-17] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-356-2-InternalConnectionFlow-actorSubscriberSink#1738455622]] | |
| [INFO] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-2-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-356-2-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-25] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Element: HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-25] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] results = List(Disconnected(1,1), RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@623d3c53,2))) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-9] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-0-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-9] [akka://ConnectionTest/user/StreamSupervisor-0/flow-354-0-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-354-0-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] == become unconnected == SlotProcessor-1 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$running$1.applyOrElse(PoolSlot.scala:249) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] become unconnected, because: Some(Connection failed.) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-9] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-1] Element: Disconnected(1,1) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] FROM CONNECTION = FromConnection(Cancel) | |
| [DEBUG] [11/20/2015 12:37:21.349] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] from = Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-354-0-InternalConnectionFlow-actorPublisherSource#955664388] | |
| [DEBUG] [11/20/2015 12:37:21.350] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] totalDemand = 13 | |
| [DEBUG] [11/20/2015 12:37:21.350] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] remainingRequested = 16 | |
| [DEBUG] [11/20/2015 12:37:21.350] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] canceled = false | |
| [DEBUG] [11/20/2015 12:37:21.350] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-1] isActive = true | |
| [DEBUG] [11/20/2015 12:37:21.350] [ConnectionTest-akka.actor.default-dispatcher-9] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-1] Element: RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@623d3c53,2)) | |
| [DEBUG] [11/20/2015 12:37:21.350] [ConnectionTest-akka.actor.default-dispatcher-2] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool request = PoolRequest(HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/50,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@60675677) | |
| [DEBUG] [11/20/2015 12:37:21.351] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforePoolFlow] Element: RequestContext(HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@60675677,5) | |
| [DEBUG] [11/20/2015 12:37:21.351] [ConnectionTest-akka.actor.default-dispatcher-2] [akka://ConnectionTest/user/PoolInterfaceActor-0] pool request = PoolRequest(HttpRequest(HttpMethod(GET),http://127.0.0.1:6666/test/49,List(),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@3d5288ed) | |
| [DEBUG] [11/20/2015 12:37:21.351] [ConnectionTest-akka.actor.default-dispatcher-7] [ActorSystem(ConnectionTest)] Materializing ActorPublisherSource[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource#900079700]] | |
| [INFO] [11/20/2015 12:37:21.351] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource] preStart of FlowInportActor self:flow-358-0-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.351] [ConnectionTest-akka.actor.default-dispatcher-9] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforePoolFlow] Element: RequestContext(HttpRequest(HttpMethod(GET),/test/49,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@3d5288ed,5) | |
| [DEBUG] [11/20/2015 12:37:21.351] [ConnectionTest-akka.actor.default-dispatcher-2] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource] request = Request(16), slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.355] [ConnectionTest-akka.actor.default-dispatcher-17] [ActorSystem(ConnectionTest)] Materializing ActorPublisherSource[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource#-636098539]] | |
| [DEBUG] [11/20/2015 12:37:21.355] [ConnectionTest-akka.actor.default-dispatcher-14] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-2-InternalConnectionFlow-actorSubscriberSink] Requesting 16, slot:SlotProcessor-2 | |
| [INFO] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource] preStart of FlowInportActor self:flow-356-36-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource] request = Request(16), slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] request from connection in waitingForDemandFromConnection() >>>>> | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] from = Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource#-636098539] | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] totalDemand = 16 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] remainingRequested = 15 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] canceled = false | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] isActive = true | |
| [INFO] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] inflightRequests = Queue(RequestContext(HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@7cc602fe,2)) | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/SlotProcessor-2] become running | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-19] [ActorSystem(ConnectionTest)] Materializing ActorPublisherSource[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource#-953959714]] | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/system/IO-TCP/selectors/$a/206] Attempting connection to [/127.0.0.1:6666] | |
| [INFO] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource] preStart of FlowInportActor self:flow-357-34-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-12] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource] on next = HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)), slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource] request = Request(16), slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Element: HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-19] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-357-36-InternalConnectionFlow-actorSubscriberSink#-1350460814]] | |
| [INFO] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-36-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-357-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.356] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] request from connection in waitingForDemandFromConnection() >>>>> | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-36-InternalConnectionFlow-actorSubscriberSink] Requesting 10, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] from = Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource#-953959714] | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] totalDemand = 10 | |
| !!!!! SLOT POST STOP !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-3#-367729360] | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] remainingRequested = 15 | |
| !!!!! SLOT POST STOP !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-1#-1388002785] | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] canceled = false | |
| !!!!! SLOT POST STOP !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-0#632896808] | |
| !!!!! SLOT POST STOP !!!!! @ Actor[akka://ConnectionTest/user/SlotProcessor-2#-260503023] | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] isActive = true | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-16] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Element: HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [INFO] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] inflightRequests = Queue(RequestContext(HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@623d3c53,2)) | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/SlotProcessor-0] become running | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-5] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource] on next = HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)), slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/system/IO-TCP/selectors/$a/206] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Element: HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Element: HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-358-36-InternalConnectionFlow-actorSubscriberSink#551045433]] | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] request from connection in waitingForDemandFromConnection() >>>>> | |
| [INFO] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-36-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-358-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] from = Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource#900079700] | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] totalDemand = 13 | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-36-InternalConnectionFlow-actorSubscriberSink] Requesting 13, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] remainingRequested = 15 | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] canceled = false | |
| [DEBUG] [11/20/2015 12:37:21.357] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] isActive = true | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| [INFO] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] inflightRequests = Queue(RequestContext(HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@60675677,5)) | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-1] become running | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource] on next = HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)), slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-2 | |
| [INFO] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-10] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-36-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-356-36-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-7] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterConnectionFlowIn] Upstream failed, cause: StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-22] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Element: HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [ERROR] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [[[CONNECTION_FLOW]]] Upstream failed. (akka.stream.StreamTcpException) | |
| [ERROR] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-6] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream failed. (akka.stream.StreamTcpException) | |
| [ERROR] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-15] [ActorSystem(ConnectionTest)] Outgoing request stream error (akka.stream.StreamTcpException) | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-2-InternalConnectionFlow-actorSubscriberSink] finishing = OnError(akka.stream.StreamTcpException: Connection failed.)and then stop, slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-22] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Element: HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)) | |
| [INFO] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-2] total demand = 16 | |
| [INFO] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/StreamSupervisor-0/flow-356-2-InternalConnectionFlow-actorSubscriberSink] postStop of FlowOutportActor self:flow-356-2-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-2] Slot 2 disconnected after akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.358] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-2] results = List(Disconnected(2,1), RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@7cc602fe,1))) | |
| [DEBUG] [11/20/2015 12:37:21.359] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-2] == become unconnected == SlotProcessor-2 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$running$1.applyOrElse(PoolSlot.scala:249) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| [DEBUG] [11/20/2015 12:37:21.359] [ConnectionTest-akka.actor.default-dispatcher-7] [akka://ConnectionTest/user/SlotProcessor-2] become unconnected, because: Some(Connection failed.) | |
| [DEBUG] [11/20/2015 12:37:21.359] [ConnectionTest-akka.actor.default-dispatcher-7] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-2] Element: Disconnected(2,1) | |
| [DEBUG] [11/20/2015 12:37:21.359] [ConnectionTest-akka.actor.default-dispatcher-7] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-2] Element: RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/48,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@7cc602fe,1)) | |
| [DEBUG] [11/20/2015 12:37:21.359] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/system/IO-TCP/selectors/$a/207] Attempting connection to [/127.0.0.1:6666] | |
| [DEBUG] [11/20/2015 12:37:21.360] [ConnectionTest-akka.actor.default-dispatcher-21] [akka://ConnectionTest/system/IO-TCP/selectors/$a/208] Attempting connection to [/127.0.0.1:6666] | |
| [DEBUG] [11/20/2015 12:37:21.360] [ConnectionTest-akka.actor.default-dispatcher-4] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-363-2-InternalConnectionFlow-actorSubscriberSink#2018766815]] | |
| [INFO] [11/20/2015 12:37:21.360] [ConnectionTest-akka.actor.default-dispatcher-19] [akka://ConnectionTest/user/StreamSupervisor-0/flow-363-2-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-363-2-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-2 | |
| [DEBUG] [11/20/2015 12:37:21.360] [ConnectionTest-akka.actor.default-dispatcher-15] [akka://ConnectionTest/system/IO-TCP/selectors/$a/207] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:37:21.360] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/system/IO-TCP/selectors/$a/208] Could not establish connection to [/127.0.0.1:6666] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-21] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [DEBUG] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-34-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-357-34-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-0 | |
| [DEBUG] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterConnectionFlowIn] Upstream failed, cause: StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-26] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [BeforeConnectionFlow] Downstream finished. | |
| [ERROR] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-10] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [[[CONNECTION_FLOW]]] Upstream failed. (akka.stream.StreamTcpException) | |
| [DEBUG] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [beforeConnection] Downstream finished. | |
| [ERROR] [11/20/2015 12:37:21.361] [ConnectionTest-akka.actor.default-dispatcher-26] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream failed. (akka.stream.StreamTcpException) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-21] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource] cancel then stop = Cancel, slot:SlotProcessor-1 | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-36-InternalConnectionFlow-actorSubscriberSink] finishing = OnError(akka.stream.StreamTcpException: Connection failed.)and then stop, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-21] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-0-InternalConnectionFlow-actorPublisherSource] postStop of FlowInportActor self:flow-358-0-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-16] [akka://ConnectionTest/user/StreamSupervisor-0/flow-357-36-InternalConnectionFlow-actorSubscriberSink] postStop of FlowOutportActor self:flow-357-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-0 | |
| [INFO] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/SlotProcessor-0] total demand = 10 | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-21] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [AfterConnectionFlowIn] Upstream failed, cause: StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/SlotProcessor-0] Slot 0 disconnected after akka.stream.StreamTcpException: Connection failed. | |
| [ERROR] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-25] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [[[CONNECTION_FLOW]]] Upstream failed. (akka.stream.StreamTcpException) | |
| [ERROR] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-22] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [afterConnection] Upstream failed. (akka.stream.StreamTcpException) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-25] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-36-InternalConnectionFlow-actorSubscriberSink] finishing = OnError(akka.stream.StreamTcpException: Connection failed.)and then stop, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-25] [akka://ConnectionTest/user/StreamSupervisor-0/flow-358-36-InternalConnectionFlow-actorSubscriberSink] postStop of FlowOutportActor self:flow-358-36-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/SlotProcessor-1] total demand = 13 | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/SlotProcessor-0] results = List(Disconnected(0,1), RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@623d3c53,1))) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/SlotProcessor-1] Slot 1 disconnected after akka.stream.StreamTcpException: Connection failed. | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-0] Element: Disconnected(0,1) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/SlotProcessor-0] == become unconnected == SlotProcessor-0 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$running$1.applyOrElse(PoolSlot.scala:249) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-26] [akka://ConnectionTest/user/SlotProcessor-0] become unconnected, because: Some(Connection failed.) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/SlotProcessor-1] results = List(Disconnected(1,1), RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@60675677,4))) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-0] Element: RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/47,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@623d3c53,1)) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/SlotProcessor-1] == become unconnected == SlotProcessor-1 | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.COME_FROM(PoolSlot.scala:305) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.handleDisconnect(PoolSlot.scala:282) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor$$anonfun$running$1.applyOrElse(PoolSlot.scala:249) | |
| akka.actor.Actor$class.aroundReceive(Actor.scala:467) | |
| akka.http.impl.engine.client.PoolSlot$SlotProcessor.akka$stream$actor$ActorSubscriber$$super$aroundReceive(PoolSlot.scala:119) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-1] Element: Disconnected(1,1) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/SlotProcessor-1] become unconnected, because: Some(Connection failed.) | |
| [DEBUG] [11/20/2015 12:37:21.362] [ConnectionTest-akka.actor.default-dispatcher-17] [akka.stream.Log(akka://ConnectionTest/user/StreamSupervisor-0)] [From-SlotProcessor-1] Element: RetryRequest(RequestContext(HttpRequest(HttpMethod(GET),/test/50,List(Host: 127.0.0.1:6666),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1)),scala.concurrent.impl.Promise$DefaultPromise@60675677,4)) | |
| [DEBUG] [11/20/2015 12:37:21.363] [ConnectionTest-akka.actor.default-dispatcher-16] [ActorSystem(ConnectionTest)] Materializing ActorPublisherSource[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-365-0-InternalConnectionFlow-actorPublisherSource#-1368509364]] | |
| [DEBUG] [11/20/2015 12:37:21.363] [ConnectionTest-akka.actor.default-dispatcher-9] [ActorSystem(ConnectionTest)] Materializing ActorSubscriberSink[Actor[akka://ConnectionTest/user/StreamSupervisor-0/flow-359-35-InternalConnectionFlow-actorSubscriberSink#956368714]] | |
| [INFO] [11/20/2015 12:37:21.363] [ConnectionTest-akka.actor.default-dispatcher-22] [akka://ConnectionTest/user/StreamSupervisor-0/flow-365-0-InternalConnectionFlow-actorPublisherSource] preStart of FlowInportActor self:flow-365-0-InternalConnectionFlow-actorPublisherSource, slot:SlotProcessor-1 | |
| [INFO] [11/20/2015 12:37:21.363] [ConnectionTest-akka.actor.default-dispatcher-17] [akka://ConnectionTest/user/StreamSupervisor-0/flow-359-35-InternalConnectionFlow-actorSubscriberSink] preStart of FlowOutportActor self:flow-359-35-InternalConnectionFlow-actorSubscriberSink, slot:SlotProcessor-3 | |
| [success] Total time: 21 s, completed 20-Nov-2015 12:37:30 | |
| [warn] The `-` command is deprecated in favor of `onFailure` and will be removed in 0.14.0 | |
| [warn] The `-` command is deprecated in favor of `onFailure` and will be removed in 0.14.0 | |
| [warn] The `-` command is deprecated in favor of `onFailure` and will be removed in 0.14.0 | |
| [warn] The `-` command is deprecated in favor of `onFailure` and will be removed in 0.14.0 | |
| [warn] The `-` command is deprecated in favor of `onFailure` and will be removed in 0.14.0 |
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
| ktoso @ 月~/code/akka [(no branch, bisect started on wip-props-static-method-anonymous-class-ktoso)*] | |
| $ sbt -J-agentpath:/Applications/YourKit_Java_Profiler_2015_build_15074.app/Contents/Resources/bin/mac/libyjpagent.jnilib '; project akka-http-tests-experimental; test:runMain akka.http.scaladsl.server.TcpLeakApp' | |
| [YourKit Java Profiler 2015 build 15074] Log file: /Users/ktoso/.yjp/log/sbt-launch-13826.log | |
| [info] Loading global plugins from /Users/ktoso/.sbt/0.13/plugins | |
| [info] Loading project definition from /Users/ktoso/code/akka/project | |
| [info] Set current project to akka (in build file:/Users/ktoso/code/akka/) | |
| [info] Set current project to akka-http-tests-experimental (in build file:/Users/ktoso/code/akka/) | |
| [info] Running akka.http.scaladsl.server.TcpLeakApp | |
| [DEBUG] [11/20/2015 12:33:26.855] [run-main-0] [EventStream(akka://ServerTest)] logger log1-TestEventListener started | |
| [DEBUG] [11/20/2015 12:33:26.868] [run-main-0] [EventStream(akka://ServerTest)] Default Loggers started | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-14] [akka://ServerTest/system/IO-TCP/selectors/$a/22] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-20] [akka://ServerTest/system/IO-TCP/selectors/$a/4] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/19] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/10] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/11] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-3] [akka://ServerTest/system/IO-TCP/selectors/$a/13] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-19] [akka://ServerTest/system/IO-TCP/selectors/$a/24] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-17] [akka://ServerTest/system/IO-TCP/selectors/$a/5] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-13] [akka://ServerTest/system/IO-TCP/selectors/$a/25] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/6] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/15] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/2] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-15] [akka://ServerTest/system/IO-TCP/selectors/$a/1] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/3] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/7] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/12] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/0] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/26] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-16] [akka://ServerTest/system/IO-TCP/selectors/$a/20] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/14] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/16] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/17] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/23] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.050] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/27] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.137] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/28] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.137] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/18] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.138] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/29] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.137] [ServerTest-akka.actor.default-dispatcher-19] [akka://ServerTest/system/IO-TCP/selectors/$a/21] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.139] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/34] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.139] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/32] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.140] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/33] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.140] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/30] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.140] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/31] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.142] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/37] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.142] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/36] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.142] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/35] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.143] [ServerTest-akka.actor.default-dispatcher-16] [akka://ServerTest/system/IO-TCP/selectors/$a/8] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.143] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/38] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.143] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/9] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.144] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/39] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.145] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/42] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.144] [ServerTest-akka.actor.default-dispatcher-19] [akka://ServerTest/system/IO-TCP/selectors/$a/40] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.145] [ServerTest-akka.actor.default-dispatcher-3] [akka://ServerTest/system/IO-TCP/selectors/$a/41] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.146] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/44] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.146] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/43] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.146] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/48] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.146] [ServerTest-akka.actor.default-dispatcher-15] [akka://ServerTest/system/IO-TCP/selectors/$a/45] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.147] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/47] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.146] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/46] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.148] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/49] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.166] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/50] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.166] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/51] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.167] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/52] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.167] [ServerTest-akka.actor.default-dispatcher-3] [akka://ServerTest/system/IO-TCP/selectors/$a/53] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.167] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/54] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.169] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/55] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.170] [ServerTest-akka.actor.default-dispatcher-15] [akka://ServerTest/system/IO-TCP/selectors/$a/57] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.170] [ServerTest-akka.actor.default-dispatcher-19] [akka://ServerTest/system/IO-TCP/selectors/$a/56] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.369] [ServerTest-akka.actor.default-dispatcher-3] [akka://ServerTest/system/IO-TCP/selectors/$a/23] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.369] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/9] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.369] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/35] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.369] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/4] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.369] [ServerTest-akka.actor.default-dispatcher-16] [akka://ServerTest/system/IO-TCP/selectors/$a/21] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/26] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/34] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/44] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-14] [akka://ServerTest/system/IO-TCP/selectors/$a/27] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/25] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-13] [akka://ServerTest/system/IO-TCP/selectors/$a/33] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-15] [akka://ServerTest/system/IO-TCP/selectors/$a/39] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-17] [akka://ServerTest/system/IO-TCP/selectors/$a/30] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/22] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/15] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-19] [akka://ServerTest/system/IO-TCP/selectors/$a/2] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.370] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/36] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.371] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/14] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.372] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/31] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.371] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/28] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.372] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/41] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.372] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/24] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.372] [ServerTest-akka.actor.default-dispatcher-20] [akka://ServerTest/system/IO-TCP/selectors/$a/42] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.372] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/3] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.429] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/11] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.429] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/49] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.455] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/45] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.480] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/5] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.481] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/20] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.482] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/19] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.488] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/40] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.489] [ServerTest-akka.actor.default-dispatcher-16] [akka://ServerTest/system/IO-TCP/selectors/$a/18] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.489] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/38] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.492] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/13] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.492] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/16] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.493] [ServerTest-akka.actor.default-dispatcher-20] [akka://ServerTest/system/IO-TCP/selectors/$a/43] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.496] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/12] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.528] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/17] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.528] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/32] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.528] [ServerTest-akka.actor.default-dispatcher-14] [akka://ServerTest/system/IO-TCP/selectors/$a/48] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.528] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/8] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.530] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/6] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.530] [ServerTest-akka.actor.default-dispatcher-25] [akka://ServerTest/system/IO-TCP/selectors/$a/46] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.531] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/10] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.531] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/0] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.531] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/57] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.532] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/29] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.532] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/1] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.532] [ServerTest-akka.actor.default-dispatcher-13] [akka://ServerTest/system/IO-TCP/selectors/$a/37] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.532] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/47] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.532] [ServerTest-akka.actor.default-dispatcher-17] [akka://ServerTest/system/IO-TCP/selectors/$a/7] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.533] [ServerTest-akka.actor.default-dispatcher-16] [akka://ServerTest/system/IO-TCP/selectors/$a/50] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.533] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/54] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.536] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/58] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.536] [ServerTest-akka.actor.default-dispatcher-3] [akka://ServerTest/system/IO-TCP/selectors/$a/52] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.537] [ServerTest-akka.actor.default-dispatcher-20] [akka://ServerTest/system/IO-TCP/selectors/$a/53] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.536] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/51] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.537] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/55] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.537] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/59] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.538] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/56] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.546] [ServerTest-akka.actor.default-dispatcher-19] [akka://ServerTest/system/IO-TCP/selectors/$a/60] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.547] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/61] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.547] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/62] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.549] [ServerTest-akka.actor.default-dispatcher-12] [akka://ServerTest/system/IO-TCP/selectors/$a/63] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.549] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/64] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.559] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/65] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.560] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/67] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.561] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/66] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.560] [ServerTest-akka.actor.default-dispatcher-14] [akka://ServerTest/system/IO-TCP/selectors/$a/69] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.560] [ServerTest-akka.actor.default-dispatcher-7] [akka://ServerTest/system/IO-TCP/selectors/$a/68] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.563] [ServerTest-akka.actor.default-dispatcher-20] [akka://ServerTest/system/IO-TCP/selectors/$a/70] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.568] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/59] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.569] [ServerTest-akka.actor.default-dispatcher-3] [akka://ServerTest/system/IO-TCP/selectors/$a/58] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.570] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/60] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.571] [ServerTest-akka.actor.default-dispatcher-16] [akka://ServerTest/system/IO-TCP/selectors/$a/61] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.572] [ServerTest-akka.actor.default-dispatcher-17] [akka://ServerTest/system/IO-TCP/selectors/$a/63] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.573] [ServerTest-akka.actor.default-dispatcher-13] [akka://ServerTest/system/IO-TCP/selectors/$a/62] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.572] [ServerTest-akka.actor.default-dispatcher-6] [akka://ServerTest/system/IO-TCP/selectors/$a/65] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.573] [ServerTest-akka.actor.default-dispatcher-26] [akka://ServerTest/system/IO-TCP/selectors/$a/64] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| Error: Failure(akka.stream.StreamTcpException: Connection failed.) | |
| [DEBUG] [11/20/2015 12:33:29.575] [ServerTest-akka.actor.default-dispatcher-14] [akka://ServerTest/system/IO-TCP/selectors/$a/68] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.575] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/67] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.576] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/66] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.578] [ServerTest-akka.actor.default-dispatcher-22] [akka://ServerTest/system/IO-TCP/selectors/$a/69] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.578] [ServerTest-akka.actor.default-dispatcher-20] [akka://ServerTest/system/IO-TCP/selectors/$a/70] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.600] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/71] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.603] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/71] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.605] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/72] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.608] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/72] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.612] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/73] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.614] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/73] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.617] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/74] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.619] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/74] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.623] [ServerTest-akka.actor.default-dispatcher-4] [akka://ServerTest/system/IO-TCP/selectors/$a/75] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.626] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/75] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.628] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/76] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.630] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/76] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.633] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/77] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.637] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/77] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.658] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/78] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.661] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/78] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.666] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/79] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.669] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/79] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.674] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/80] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.677] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/80] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.680] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/81] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.683] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/81] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.684] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/82] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.686] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/82] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.687] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/83] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.690] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/83] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.691] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/84] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.692] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/84] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.694] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/85] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.696] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/85] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.698] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/86] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.700] [ServerTest-akka.actor.default-dispatcher-8] [akka://ServerTest/system/IO-TCP/selectors/$a/86] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.700] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/87] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.703] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/87] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.706] [ServerTest-akka.actor.default-dispatcher-15] [akka://ServerTest/system/IO-TCP/selectors/$a/88] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.707] [ServerTest-akka.actor.default-dispatcher-15] [akka://ServerTest/system/IO-TCP/selectors/$a/88] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.708] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/89] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.710] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/89] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.711] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/90] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.713] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/90] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.715] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/91] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.718] [ServerTest-akka.actor.default-dispatcher-9] [akka://ServerTest/system/IO-TCP/selectors/$a/91] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.719] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/92] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.723] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/92] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.724] [ServerTest-akka.actor.default-dispatcher-2] [akka://ServerTest/system/IO-TCP/selectors/$a/93] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.728] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/93] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.731] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/94] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.733] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/94] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.735] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/95] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.738] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/95] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.740] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/96] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.744] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/96] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.749] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/97] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.751] [ServerTest-akka.actor.default-dispatcher-10] [akka://ServerTest/system/IO-TCP/selectors/$a/97] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.751] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/98] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.755] [ServerTest-akka.actor.default-dispatcher-18] [akka://ServerTest/system/IO-TCP/selectors/$a/98] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| [DEBUG] [11/20/2015 12:33:29.757] [ServerTest-akka.actor.default-dispatcher-21] [akka://ServerTest/system/IO-TCP/selectors/$a/99] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 12:33:29.758] [ServerTest-akka.actor.default-dispatcher-24] [akka://ServerTest/system/IO-TCP/selectors/$a/99] Could not establish connection to [/127.0.0.1:1234] due to java.net.ConnectException: Connection refused | |
| ===================== | |
| -> / LocalActorRefProvider$$anon$1 class akka.actor.LocalActorRefProvider$Guardian status=0 2 children | |
| ⌊-> system LocalActorRef class akka.actor.LocalActorRefProvider$SystemGuardian status=0 3 children | |
| | ⌊-> IO-TCP RepointableActorRef class akka.io.TcpManager status=0 1 children | |
| | | ⌊-> selectors RoutedActorRef class akka.routing.RouterPoolActor status=0 1 children | |
| | | ⌊-> $a LocalActorRef class akka.io.SelectionHandler status=0 no children | |
| | ⌊-> IO-TCP-STREAM RepointableActorRef class akka.stream.impl.io.StreamTcpManager status=0 no children | |
| | ⌊-> log1-TestEventListener RepointableActorRef class akka.testkit.TestEventListener status=0 no children | |
| ⌊-> user LocalActorRef class akka.actor.LocalActorRefProvider$Guardian status=0 1 children | |
| ⌊-> StreamSupervisor-0 RepointableActorRef class akka.stream.impl.StreamSupervisor status=0 no children | |
| ======================== |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
This is on https://github.com/ktoso/akka/tree/wip-leakin-ktoso