Skip to content

Instantly share code, notes, and snippets.

@flazz

flazz/Service.scala

Last active August 29, 2015 14:08
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save flazz/ffe3112b97fd13ee5998 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save flazz/ffe3112b97fd13ee5998 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Service.scala
package spike.tracing
import com.twitter.finagle.builder._
import com.twitter.finagle.http._
import com.twitter.finagle.{SimpleFilter,Service}
import com.twitter.finagle.stats._
import com.twitter.finagle.tracing._
import com.twitter.finagle.zipkin.thrift._
import com.twitter.util.Future
import java.net.InetSocketAddress
import java.nio.charset.Charset
import org.jboss.netty.buffer.ChannelBuffers
import org.jboss.netty.handler.codec.http._
trait Spike {
val port: Int
val name: String
val connectTo: String
def tracer =
ConsoleTracer
//ZipkinTracer.mk(host = "192.168.56.101", port = 9410, sampleRate = 1)
//def receiver = JavaLoggerStatsReceiver()
val utf = Charset.forName("UTF-8")
lazy val client =
ClientBuilder()
.hosts(connectTo)
.name(s"clt-$name")
.codec(Http().enableTracing(true))
//.codec(Http())
.hostConnectionLimit(50)
//.tracer(tracer)
.build()
def buildServer =
ServerBuilder()
.codec(Http().enableTracing(true))
.bindTo(new InetSocketAddress(port))
.name(s"srv-$name")
.tracer(tracer)
//.reportTo(receiver)
.build(Service mk service)
val uriRpcFilter = new SimpleFilter[HttpRequest, HttpResponse] {
def apply(req: HttpRequest, srv: Service[HttpRequest,HttpResponse]): Future[HttpResponse] = {
println("setting rpc clt")
Trace.recordRpc(req.getUri)
srv(req)
}
}
val service: HttpRequest => Future[HttpResponse] = { request =>
println("setting rpc srv")
Trace.recordRpc(request.getUri)
val body = request.getContent.toString(utf)
val paths = body.split(",").toList
paths match {
case List("") => baseCase
case p :: ps => recursiveCase(p, ps)
}
}
val ok = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK)
def baseCase: Future[HttpResponse] =
Future.value(ok)
def recursiveCase(p: String, ps: List[String]): Future[HttpResponse] = {
val req = new DefaultHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.POST, s"/$p")
val buffer = ChannelBuffers.copiedBuffer(ps.mkString(","), utf)
req.setContent(buffer)
req.headers.set(HttpHeaders.Names.CONTENT_LENGTH, buffer.readableBytes.toString)
(uriRpcFilter andThen client)(req) map { _ => ok }
}
}
object service1 extends App with Spike {
val port = 1111
val name = "1"
val connectTo = "localhost:1112"
buildServer
}
object service2 extends App with Spike {
val port = 1112
val name = "2"
val connectTo = "localhost:1111"
buildServer
}
Raw
term1 output
1025 14:30:56.573 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.581 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] ServiceName(srv-1)
1025 14:30:56.582 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] ServiceName(srv-1)
1025 14:30:56.583 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] Rpc(POST)
1025 14:30:56.583 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] BinaryAnnotation(http.uri,/)
1025 14:30:56.584 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] ServerRecv()
1025 14:30:56.621 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] LocalAddr(/127.0.0.1:1111)
1025 14:30:56.621 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] ServerAddr(/127.0.0.1:1111)
1025 14:30:56.622 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] ClientAddr(/127.0.0.1:49648)
setting rpc srv
1025 14:30:56.622 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] Rpc(/)
setting rpc clt
1025 14:30:56.712 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] Rpc(/a)
1025 14:30:56.733 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.734 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServiceName(clt-1)
1025 14:30:56.736 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServiceName(clt-1)
1025 14:30:56.737 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] Rpc(POST)
1025 14:30:56.737 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] BinaryAnnotation(http.uri,/a)
1025 14:30:56.737 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ClientSend()
1025 14:30:56.740 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServerAddr(localhost/127.0.0.1:1112)
1025 14:30:56.740 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ClientAddr(/127.0.0.1:49649)
1025 14:30:56.984 a30d8cf96ad9dd85.a30d8cf96ad9dd85<:a30d8cf96ad9dd85] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.984 a30d8cf96ad9dd85.a30d8cf96ad9dd85<:a30d8cf96ad9dd85] ServiceName(srv-1)
1025 14:30:56.987 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServiceName(srv-1)
1025 14:30:56.987 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] Rpc(POST)
1025 14:30:56.987 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] BinaryAnnotation(http.uri,/b)
1025 14:30:56.987 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServerRecv()
1025 14:30:56.988 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] LocalAddr(/127.0.0.1:1111)
1025 14:30:56.988 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServerAddr(/127.0.0.1:1111)
1025 14:30:56.988 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ClientAddr(/127.0.0.1:49650)
setting rpc srv
1025 14:30:56.988 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] Rpc(/b)
setting rpc clt
1025 14:30:56.988 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] Rpc(/c)
1025 14:30:56.993 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.993 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServiceName(clt-1)
1025 14:30:56.993 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServiceName(clt-1)
1025 14:30:56.993 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] Rpc(POST)
1025 14:30:56.993 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] BinaryAnnotation(http.uri,/c)
1025 14:30:56.994 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ClientSend()
1025 14:30:56.994 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServerAddr(localhost/127.0.0.1:1112)
1025 14:30:56.994 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ClientAddr(/127.0.0.1:49651)
1025 14:30:57.004 65efe3b638ccb951.65efe3b638ccb951<:65efe3b638ccb951] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.005 65efe3b638ccb951.65efe3b638ccb951<:65efe3b638ccb951] ServiceName(srv-1)
1025 14:30:57.005 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServiceName(srv-1)
1025 14:30:57.005 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] Rpc(POST)
1025 14:30:57.005 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] BinaryAnnotation(http.uri,/d)
1025 14:30:57.006 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServerRecv()
1025 14:30:57.006 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] LocalAddr(/127.0.0.1:1111)
1025 14:30:57.006 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServerAddr(/127.0.0.1:1111)
1025 14:30:57.006 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ClientAddr(/127.0.0.1:49652)
setting rpc srv
1025 14:30:57.006 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] Rpc(/d)
setting rpc clt
1025 14:30:57.006 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] Rpc(/e)
1025 14:30:57.008 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.008 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServiceName(clt-1)
1025 14:30:57.009 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServiceName(clt-1)
1025 14:30:57.009 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] Rpc(POST)
1025 14:30:57.009 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] BinaryAnnotation(http.uri,/e)
1025 14:30:57.009 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ClientSend()
1025 14:30:57.009 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServerAddr(localhost/127.0.0.1:1112)
1025 14:30:57.009 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ClientAddr(/127.0.0.1:49653)
1025 14:30:57.017 dbb8afa239c092c6.dbb8afa239c092c6<:dbb8afa239c092c6] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.017 dbb8afa239c092c6.dbb8afa239c092c6<:dbb8afa239c092c6] ServiceName(srv-1)
1025 14:30:57.017 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServiceName(srv-1)
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] Rpc(POST)
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] BinaryAnnotation(http.uri,/f)
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServerRecv()
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] LocalAddr(/127.0.0.1:1111)
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServerAddr(/127.0.0.1:1111)
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ClientAddr(/127.0.0.1:49654)
setting rpc srv
1025 14:30:57.018 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] Rpc(/f)
setting rpc clt
1025 14:30:57.019 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] Rpc(/g)
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServiceName(clt-1)
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServiceName(clt-1)
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] Rpc(POST)
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] BinaryAnnotation(http.uri,/g)
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ClientSend()
1025 14:30:57.021 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServerAddr(localhost/127.0.0.1:1112)
1025 14:30:57.022 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ClientAddr(/127.0.0.1:49655)
1025 14:30:57.031 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ClientRecv()
1025 14:30:57.033 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServerSend()
1025 14:30:57.040 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ClientRecv()
1025 14:30:57.040 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServerSend()
1025 14:30:57.043 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ClientRecv()
1025 14:30:57.043 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServerSend()
1025 14:30:57.045 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ClientRecv()
1025 14:30:57.046 a38e742f5c5ce8cb.a38e742f5c5ce8cb<:a38e742f5c5ce8cb] ServerSend()
Raw
term2 output
1025 14:30:56.814 7a6f3f7aa819312b.7a6f3f7aa819312b<:7a6f3f7aa819312b] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.822 7a6f3f7aa819312b.7a6f3f7aa819312b<:7a6f3f7aa819312b] ServiceName(srv-2)
1025 14:30:56.828 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServiceName(srv-2)
1025 14:30:56.828 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] Rpc(POST)
1025 14:30:56.829 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] BinaryAnnotation(http.uri,/a)
1025 14:30:56.829 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServerRecv()
1025 14:30:56.864 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] LocalAddr(/127.0.0.1:1112)
1025 14:30:56.865 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServerAddr(/127.0.0.1:1112)
1025 14:30:56.866 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ClientAddr(/127.0.0.1:49649)
setting rpc srv
1025 14:30:56.866 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] Rpc(/a)
setting rpc clt
1025 14:30:56.953 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] Rpc(/b)
1025 14:30:56.973 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.974 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServiceName(clt-2)
1025 14:30:56.975 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServiceName(clt-2)
1025 14:30:56.976 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] Rpc(POST)
1025 14:30:56.976 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] BinaryAnnotation(http.uri,/b)
1025 14:30:56.976 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ClientSend()
1025 14:30:56.978 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ServerAddr(localhost/127.0.0.1:1111)
1025 14:30:56.979 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ClientAddr(/127.0.0.1:49650)
1025 14:30:56.995 120a1be5161164b8.120a1be5161164b8<:120a1be5161164b8] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:56.995 120a1be5161164b8.120a1be5161164b8<:120a1be5161164b8] ServiceName(srv-2)
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServiceName(srv-2)
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] Rpc(POST)
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] BinaryAnnotation(http.uri,/c)
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServerRecv()
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] LocalAddr(/127.0.0.1:1112)
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServerAddr(/127.0.0.1:1112)
1025 14:30:56.996 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ClientAddr(/127.0.0.1:49651)
setting rpc srv
1025 14:30:56.997 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] Rpc(/c)
setting rpc clt
1025 14:30:56.997 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] Rpc(/d)
1025 14:30:57.002 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.002 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServiceName(clt-2)
1025 14:30:57.002 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServiceName(clt-2)
1025 14:30:57.003 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] Rpc(POST)
1025 14:30:57.003 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] BinaryAnnotation(http.uri,/d)
1025 14:30:57.003 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ClientSend()
1025 14:30:57.003 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ServerAddr(localhost/127.0.0.1:1111)
1025 14:30:57.003 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ClientAddr(/127.0.0.1:49652)
1025 14:30:57.010 0bc8b2c3f49e71ce.0bc8b2c3f49e71ce<:0bc8b2c3f49e71ce] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.011 0bc8b2c3f49e71ce.0bc8b2c3f49e71ce<:0bc8b2c3f49e71ce] ServiceName(srv-2)
1025 14:30:57.011 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServiceName(srv-2)
1025 14:30:57.012 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] Rpc(POST)
1025 14:30:57.012 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] BinaryAnnotation(http.uri,/e)
1025 14:30:57.012 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServerRecv()
1025 14:30:57.012 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] LocalAddr(/127.0.0.1:1112)
1025 14:30:57.012 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServerAddr(/127.0.0.1:1112)
1025 14:30:57.013 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ClientAddr(/127.0.0.1:49653)
setting rpc srv
1025 14:30:57.013 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] Rpc(/e)
setting rpc clt
1025 14:30:57.013 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] Rpc(/f)
1025 14:30:57.015 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.015 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServiceName(clt-2)
1025 14:30:57.015 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServiceName(clt-2)
1025 14:30:57.015 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] Rpc(POST)
1025 14:30:57.016 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] BinaryAnnotation(http.uri,/f)
1025 14:30:57.016 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ClientSend()
1025 14:30:57.016 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ServerAddr(localhost/127.0.0.1:1111)
1025 14:30:57.016 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ClientAddr(/127.0.0.1:49654)
1025 14:30:57.023 c4c6d080e6fcc5ec.c4c6d080e6fcc5ec<:c4c6d080e6fcc5ec] BinaryAnnotation(finagle.version,6.20.0)
1025 14:30:57.023 c4c6d080e6fcc5ec.c4c6d080e6fcc5ec<:c4c6d080e6fcc5ec] ServiceName(srv-2)
1025 14:30:57.024 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServiceName(srv-2)
1025 14:30:57.024 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] Rpc(POST)
1025 14:30:57.024 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] BinaryAnnotation(http.uri,/g)
1025 14:30:57.024 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServerRecv()
1025 14:30:57.025 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] LocalAddr(/127.0.0.1:1112)
1025 14:30:57.025 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServerAddr(/127.0.0.1:1112)
1025 14:30:57.025 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ClientAddr(/127.0.0.1:49655)
setting rpc srv
1025 14:30:57.025 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] Rpc(/g)
1025 14:30:57.026 a38e742f5c5ce8cb.d87d71092c703e2c<:429e32c6b70e5006] ServerSend()
1025 14:30:57.038 a38e742f5c5ce8cb.429e32c6b70e5006<:70c1c48a3aacfd7b] ClientRecv()
1025 14:30:57.039 a38e742f5c5ce8cb.70c1c48a3aacfd7b<:01d4ea5673615d29] ServerSend()
1025 14:30:57.041 a38e742f5c5ce8cb.01d4ea5673615d29<:0f29df867b7b575e] ClientRecv()
1025 14:30:57.042 a38e742f5c5ce8cb.0f29df867b7b575e<:e65fa477dba19cd1] ServerSend()
1025 14:30:57.044 a38e742f5c5ce8cb.e65fa477dba19cd1<:c84e314c164da3b0] ClientRecv()
1025 14:30:57.044 a38e742f5c5ce8cb.c84e314c164da3b0<:a38e742f5c5ce8cb] ServerSend()
@flazz

flazz commented Oct 25, 2014

Copy link
Copy Markdown
Author

In 3 terminals:

term-1% ./sbt "runMain spike.tracing.service1"
term-2% ./sbt "runMain spike.tracing.service2"
term-3% curl localhost:1111/ -d "a,b,c,e,f,g"

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment