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
| akka-docs-dev > last akka-docs-dev/sphinx:generatePdf | |
| [info] Generating Sphinx latex documentation... | |
| [debug] Command: sphinx-build -a -E -b latex -d /Users/ktoso/code/akka/akka-docs-dev/target/sphinx/doctrees/latex -Dversion=1.0-SNAPSHOT -Drelease=1.0-SNAPSHOT /Users/ktoso/code/akka/akka-docs-dev/rst_preprocessed /Users/ktoso/code/akka/akka-docs-dev/target/sphinx/latex | |
| [debug] Environment: Map(PYTHONPATH -> /Users/ktoso/code/akka/akka-docs-dev/target/sphinx/packages/pygments) | |
| [debug] Making output directory... | |
| [debug] Running Sphinx v1.2.3 | |
| [debug] building [latex]: all source files | |
| [debug] updating environment: 256 added, 0 changed, 0 removed | |
| [debug] reading sources... [ 0%] index | |
| [debug] reading sources... [ 0%] java |
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[Acto |
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
| $ cat leak.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 13:08:24.935] [run-main-0] [EventStream(akka://ServerTest)] logger log1-TestEventListener started | |
| [DEBUG] [11/20/2015 13:08:24.940] [run-main-0] [EventStream(akka://ServerTest)] Default Loggers started | |
| [DEBUG] [11/20/2015 13:08:26.306] [ServerTest-akka.actor.default-dispatcher-11] [akka://ServerTest/system/IO-TCP/selectors/$a/6] Attempting connection to [/127.0.0.1:1234] | |
| [DEBUG] [11/20/2015 13:08:26.306] [ServerTest-akka.actor.default-dispatcher-23] [akka://ServerTest/system/IO-TCP/selectors/$a/12] Attempting connection to [/127.0.0.1:1234] |
ktoso
/ gist:9dcaee62db08641eba0e
Created
November 24, 2015 14:03
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
| '''''''''''''''''''''''''''''''''''''''''''''''''''''+'''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''' | |
| '++++++++++++++++++++++'++'+'+'++++++++++++++++++++++++++'++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ | |
| ++++++++++++++++++++++++++'++++'++++++++++++++++++++++'+++++++++++++++++++++++++++++++++++++++++'+++++++++++++'+++++++++++++++++++++++ | |
| ++++++++++++++++'++++++++++++++++'++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ | |
| +++++++++++++++++++@@@@@#@@@@@#+++@@@@@@@@@@@#++++@@@@@@@@@++++@@@@@@@#++@@@@@@+#@@@@@@@#+++#@@@@@@@++#@@@@@#@@@@@++++++++++++++++++++ | |
| ++++++++++++++++++++ .@@ `@+'+@ @ `@+++++ #@+#@: .@#+@ @#@` `@#+#@` ;@+@` @@; @++++++++++++++++++++ | |
| +++++++++++++++++++@ @: ##+++@ @ `@+++#+ :@@. @+@ @@ @+@ :@@` :@; @++++++++++++++++++++ | |
| +++++++++++++++++++@ @ @++++@ @ `@+++#+ @@ . @#@ @ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [DEBUG] [11/27/2015 15:00:23.927] [pool-608-thread-3-ScalaTest-running-TcpSpec] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$StopChildren$] | |
| [DEBUG] [11/27/2015 15:00:23.939] [TcpSpec-akka.test.stream-dispatcher-6] [akka.serialization.Serialization(akka://TcpSpec)] Using serializer[akka.serialization.JavaSerializer] for message [akka.stream.impl.StreamSupervisor$StoppedChildren$] | |
| [DEBUG] [11/27/2015 15:00:24.161] [TcpSpec-akka.actor.default-dispatcher-4] [akka://TcpSpec/system/IO-TCP/selectors/$a/0] Successfully bound to /127.0.0.1:61378 | |
| ob = Outbound(Actor[akka://TcpSpec/system/IO-TCP#-1374379735],Connect(localhost/127.0.0.1:61378,None,List(),None,true),scala.concurrent.impl.Promise$DefaultPromise@3854aa8c,true) | |
| ob = Outbound(Actor[akka://TcpSpec/system/IO-TCP#-1374379735],Connect(localhost/127.0.0.1:61378,None,List(),None,true),scala.concurrent.impl.Promise$DefaultPromise@7d5623e2,true) | |
| [DEBUG] [11/27/201 |
ktoso
/ how to run the things.scala
Created
December 2, 2015 13:43
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
| // Attributes: | |
| $ wrk -R 100 -d 30s http://127.0.0.1:8080 | |
| Running 30s test @ http://127.0.0.1:8080 | |
| 2 threads and 10 connections | |
| Thread calibration: mean lat.: 21.138ms, rate sampling interval: 70ms | |
| Thread calibration: mean lat.: 21.291ms, rate sampling interval: 71ms | |
| Thread Stats Avg Stdev Max +/- Stdev | |
| Latency 11.21ms 8.74ms 82.05ms 89.22% | |
| Req/Sec 49.74 21.64 114.00 82.85% | |
| 3002 requests in 30.01s, 1.45MB read |
ktoso
/ gist:5e734431a4c5c9c8ddff
Last active
January 11, 2016 19:50
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
| master-of-the-streams!akka-second $> diff --stat ce691b48eeaa5adbbec42015605d33f9ebc6ce1b | |
| akka-docs-dev/_sphinx/exts/includecode.py | 145 ++ | |
| akka-docs-dev/_sphinx/exts/includecode2.py | 109 ++ | |
| akka-docs-dev/_sphinx/pygments/setup.py | 19 + | |
| akka-docs-dev/_sphinx/pygments/styles/__init__.py | 0 | |
| akka-docs-dev/_sphinx/pygments/styles/simple.py | 58 + | |
| akka-docs-dev/_sphinx/static/akka-intellij-code-style.jar | Bin 0 -> 8587 bytes | |
| akka-docs-dev/_sphinx/static/akka.png |
ktoso
/ gist:864bad51269c73346abe
Created
January 18, 2016 09:31
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
| CONTRIBUTING.md | 2 +- | |
| LICENSE | 2 +- | |
| akka-actor-tests/src/test/java/akka/actor/ActorCreationTest.java | 2 +- | |
| akka-actor-tests/src/test/java/akka/actor/InboxJavaAPITest.java | 2 +- | |
| akka-actor-tests/src/test/java/akka/actor/JavaAPI.java | 2 +- | |
| akka-actor-tests/src/test/java/akka/actor/JavaExtension.java | 2 +- | |
| akka-actor-tests/src/test/java/akka/actor/NonPublicClass.java | 2 +- | |
| akka-actor-tests/src/test/java/akka/japi/MatchBuilderTest.java | 2 +- | |
| akka-actor-tests/src/te |
ktoso
/ forceTextStrict.scala
Created
March 20, 2016 01:14
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
| implicit class flowTweaks[M](val wsInput: Source[Message, M]) { | |
| def forceTextStrict: Source[Strict, M] = wsInput | |
| .collect { | |
| case TextMessage.Strict(text) ⇒ Future.successful(text) | |
| case TextMessage.Streamed(textStream) ⇒ textStream.runFold("")(_ + _) | |
| case BinaryMessage.Strict(binary) ⇒ Skip | |
| case BinaryMessage.Streamed(binaryStream) ⇒ binaryStream.runWith(Sink.ignore); Skip | |
| } | |
| .filterNot(_ == Skip) | |
| .mapAsync(1)(ConstantFun.scalaIdentityFunction) |
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
| 127 rst/additional/books.rst | |
| 1162 rst/additional/faq.rst | |
| 12 rst/additional/index.rst | |
| 22 rst/additional/language-bindings.rst | |
| 1208 rst/additional/osgi.rst | |
| 974 rst/common/binary-compatibility-rules.rst | |
| 606 rst/common/circuitbreaker.rst | |
| 2530 rst/common/cluster.rst | |
| 283 rst/common/duration.rst | |
| 646 rst/dev/building-akka.rst |