Skip to content

Instantly share code, notes, and snippets.

View ktoso's full-sized avatar
🗻
Life is Study!

Konrad `ktoso` Malawski ktoso

🗻
Life is Study!
1.6k followers · 175 following
View GitHub Profile
@ktoso
ktoso / gist:864bad51269c73346abe
Created January 18, 2016 09:31
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
ktoso / gist:5e734431a4c5c9c8ddff
Last active January 11, 2016 19:50
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
ktoso / how to run the things.scala
Created December 2, 2015 13:43
// 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
ktoso / content
Created November 27, 2015 14:03
[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
ktoso / gist:9dcaee62db08641eba0e
Created November 24, 2015 14:03
'''''''''''''''''''''''''''''''''''''''''''''''''''''+''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''''
'++++++++++++++++++++++'++'+'+'++++++++++++++++++++++++++'++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
++++++++++++++++++++++++++'++++'++++++++++++++++++++++'+++++++++++++++++++++++++++++++++++++++++'+++++++++++++'+++++++++++++++++++++++
++++++++++++++++'++++++++++++++++'++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
+++++++++++++++++++@@@@@#@@@@@#+++@@@@@@@@@@@#++++@@@@@@@@@++++@@@@@@@#++@@@@@@+#@@@@@@@#+++#@@@@@@@++#@@@@@#@@@@@++++++++++++++++++++
++++++++++++++++++++ .@@ `@+'+@ @ `@+++++ #@+#@: .@#+@ @#@` `@#+#@` ;@+@` @@; @++++++++++++++++++++
+++++++++++++++++++@ @: ##+++@ @ `@+++#+ :@@. @+@ @@ @+@ :@@` :@; @++++++++++++++++++++
+++++++++++++++++++@ @ @++++@ @ `@+++#+ @@ . @#@ @
@ktoso
ktoso / leak.log
Created November 20, 2015 12:10
$ 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
ktoso / tcp
Created November 20, 2015 11:40
$ 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
@ktoso
ktoso / content
Created October 14, 2015 09:03
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
@ktoso
ktoso / echos.scala
Last active November 10, 2015 15:29
package example
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.HttpEntity.Chunked
import akka.http.scaladsl.model.{ ContentTypes, HttpRequest, HttpResponse }
import akka.http.scaladsl.server.Directives
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{ Flow, Tcp }
import akka.util.ByteString
@ktoso
ktoso / manuel.scala
Last active August 29, 2015 14:27
/*
* Copyright (C) 2009-2015 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.stream.scaladsl
import akka.actor._
import akka.stream.Supervision._
import akka.stream.impl._
import akka.stream.impl.fusing.ActorInterpreter
import akka.stream.stage.Stage