aboutsummaryrefslogtreecommitdiff
path: root/kamon-core/src/main/scala/test
diff options
context:
space:
mode:
authorDiego Parra <diegolparra@gmail.com>2013-10-03 13:23:31 -0300
committerDiego Parra <diegolparra@gmail.com>2013-10-03 13:24:39 -0300
commite71903ae4fbcc08a0d674fb652792b38b0749cea (patch)
tree035c7b9e8fec0ee2f5008e832a810675da3cb0d3 /kamon-core/src/main/scala/test
parent0b62687fd294de343ae90824f4d570e4273586c1 (diff)
downloadKamon-e71903ae4fbcc08a0d674fb652792b38b0749cea.tar.gz
Kamon-e71903ae4fbcc08a0d674fb652792b38b0749cea.tar.bz2
Kamon-e71903ae4fbcc08a0d674fb652792b38b0749cea.zip
cleanup cleanup cleanup
Diffstat (limited to 'kamon-core/src/main/scala/test')
-rw-r--r--kamon-core/src/main/scala/test/SimpleRequestProcessor.scala (renamed from kamon-core/src/main/scala/test/PingPong.scala)46
1 files changed, 0 insertions, 46 deletions
diff --git a/kamon-core/src/main/scala/test/PingPong.scala b/kamon-core/src/main/scala/test/SimpleRequestProcessor.scala
index 8808e4bf..5b216b39 100644
--- a/kamon-core/src/main/scala/test/PingPong.scala
+++ b/kamon-core/src/main/scala/test/SimpleRequestProcessor.scala
@@ -1,57 +1,12 @@
package test
import akka.actor._
-import java.util.concurrent.atomic.AtomicLong
import kamon.Tracer
import spray.routing.SimpleRoutingApp
import akka.util.Timeout
import spray.httpx.RequestBuilding
import scala.concurrent.{Await, Future}
-object PingPong extends App {
- import scala.concurrent.duration._
- val counter = new AtomicLong
-
- val as = ActorSystem("ping-pong")
- import as.dispatcher
-
- Tracer.start
-
- for(i <- 1 to 64) {
- val pinger = as.actorOf(Props[Pinger])
- val ponger = as.actorOf(Props[Ponger])
-
- for(_ <- 1 to 256) {
- pinger.tell(Pong, ponger)
- }
- }
-
- as.scheduler.schedule(1 second, 1 second) {
- println("Processed: " + counter.getAndSet(0))
- }
-}
-
-case object Ping
-case object Pong
-
-class Pinger extends Actor {
- def receive = {
- case Pong => {
- sender ! Ping
- PingPong.counter.incrementAndGet()
- }
- }
-}
-
-class Ponger extends Actor {
- def receive = {
- case Ping => {
- sender ! Pong; PingPong.counter.incrementAndGet()
- }
- }
-}
-
-
object SimpleRequestProcessor extends App with SimpleRoutingApp with RequestBuilding {
import scala.concurrent.duration._
import spray.client.pipelining._
@@ -98,7 +53,6 @@ object Verifier extends App {
def go: Unit = {
import scala.concurrent.duration._
import spray.client.pipelining._
- import akka.pattern.ask
implicit val system = ActorSystem("test")
import system.dispatcher