Skip to content

Instantly share code, notes, and snippets.

View whiter4bbit's full-sized avatar

Pavel Zalunin whiter4bbit

17 followers · 6 following
View GitHub Profile
@whiter4bbit
whiter4bbit / gist:5930718
Created July 4, 2013 23:02
[info] Running info.whiter4bbit.akkaplayground.TestClient 2552
[DEBUG] [07/05/2013 01:56:59.555] [run-main] [EventStream(akka://ClusterSystem)] logger log1-Logging$DefaultLogger started
[DEBUG] [07/05/2013 01:56:59.556] [run-main] [EventStream(akka://ClusterSystem)] Default Loggers started
[DEBUG] [07/05/2013 01:56:59.567] [ClusterSystem-akka.actor.default-dispatcher-3] [akka://ClusterSystem/system] now supervising Actor[akka://ClusterSystem/system/remoting-terminator#-430478231]
[DEBUG] [07/05/2013 01:56:59.594] [ClusterSystem-akka.actor.default-dispatcher-4] [akka://ClusterSystem/system/remoting-terminator] started (akka.remote.RemoteActorRefProvider$RemotingTerminator@273e5037)
[DEBUG] [07/05/2013 01:56:59.641] [ClusterSystem-akka.actor.default-dispatcher-2] [akka://ClusterSystem/system] now supervising Actor[akka://ClusterSystem/system/transports#-1289927136]
[DEBUG] [07/05/2013 01:56:59.642] [ClusterSystem-akka.actor.default-dispatcher-4] [akka://ClusterSystem/system/transports] started (akka.remote.Remo
@whiter4bbit
whiter4bbit / QDigest.java
Last active December 20, 2015 06:49
package com.clearspring.analytics.stream.quantile;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
@whiter4bbit
whiter4bbit / gist:7147403
Created October 25, 2013 00:15
whiter4bbit@katrin jdk-bug-repr % touch resource
whiter4bbit@katrin jdk-bug-repr % jar cf jar-1.jar resource
whiter4bbit@katrin jdk-bug-repr % jar cf jar-2.jar resource
whiter4bbit@katrin jdk-bug-repr % jar cf jar-3.jar resource
whiter4bbit@katrin jdk-bug-repr % jar cf jar-4.jar resource
whiter4bbit@katrin jdk-bug-repr % jar i jar-1.jar jar-2.jar jar-3.jar jar-4.jar
whiter4bbit@katrin jdk-bug-repr % vim Bug.java
import java.net.URLClassLoader;
import java.net.URL;
import java.util.Enumeration;
@whiter4bbit
whiter4bbit / QDigestBenchmark.java
Last active January 3, 2016 20:58
package bench;
import com.clearspring.analytics.stream.quantile.QDigest;
public class QDigestBenchmark {
public static void main(String[] args) throws Exception {
QDigest q = new QDigest(1000);
for (int k : Utils.readNumbers(args[0])) {
q.offer(k);
}
@whiter4bbit
whiter4bbit / gist:9393603
Created March 6, 2014 16:31
import akka.actor._
object TCPFrontend {
case class Event(id: String)
}
trait StorageComponent {
val storage: Storage
trait Storage {
@whiter4bbit
whiter4bbit / gist:9411873
Created March 7, 2014 13:53
import akka.actor._
import com.typesafe.config._
object Storage {
case class Store(id: String)
}
trait StorageActorProvider {
val storageActor: Props
@whiter4bbit
whiter4bbit / akka-persistence-v.2.3.0-digitalocean-micro
Created March 17, 2014 22:44
# sbt -Dakka.persistence.performance.cycles.load=200000 -Dakka.persistence.performance.cycles.warmup=10000 "project akka-persistence-experimental" "test-only akka.persistence.PerformanceSpec"
Loading /usr/share/sbt/bin/sbt-launch-lib.bash
[info] Loading project definition from /root/akka/project
[info] Set current project to akka (in build file:/root/akka/)
[info] Set current project to akka-persistence-experimental (in build file:/root/akka/)
[info] PerformanceSpec:
Coroner Thread Count starts at 12 in akka.persistence.PerformanceSpec
[info] A command sourced processor
..................................................................................................................................................................................................................
throughput = 23691.30 persistent commands per second
@whiter4bbit
whiter4bbit / ec2-m1-medium-akka-persistence-v2.3.0
Created March 17, 2014 23:25
Loading /usr/share/sbt/bin/sbt-launch-lib.bash
[info] Loading project definition from /home/ec2-user/akka/project
[info] Set current project to akka (in build file:/home/ec2-user/akka/)
[info] Set current project to akka-persistence-experimental (in build file:/home/ec2-user/akka/)
[info] PerformanceSpec:
[info] A command sourced processor
..................................................................................................................................................................................................................
throughput = 9702,99 persistent commands per second
[info] - should have some reasonable throughput
..............................[ERROR] [03/17/2014 23:18:56.778] [PerformanceSpec-akka.actor.default-dispatcher-2] [akka://PerformanceSpec/user/$b] boom (akka.persistence.TestException)
@whiter4bbit
whiter4bbit / JournalActor.scala
Last active August 29, 2015 14:03
package persistence
import akka.actor._
import akka.event.Logging
import akka.persistence._
import AtLeastOnceDelivery.{UnconfirmedDelivery, UnconfirmedWarning}
import scala.annotation.tailrec
import scala.collection.immutable.ListMap
import java.util.UUID
@whiter4bbit
whiter4bbit / SimpleJournalActor.scala
Last active August 29, 2015 14:04
package persistence
import akka.actor._
import akka.persistence._
import akka.event.Logging
import com.typesafe.config.ConfigFactory
import AtLeastOnceDelivery.{UnconfirmedDelivery, UnconfirmedWarning, AtLeastOnceDeliverySnapshot}
object SimpleJournalActor {
case class Command(cmd: Any, id: Long)