Permalink
Browse files

These are public for TFE

  • Loading branch information...
1 parent d3bafe3 commit b8ff9698a7a0797b92882d6f30800baf220222fa Nick Kallen committed Mar 21, 2011
@@ -23,7 +23,7 @@ private[finagle] object OneHundredContinueResponse
HttpVersion.HTTP_1_1,
HttpResponseStatus.CONTINUE)
-private[finagle] class HttpFailure(ctx: ChannelHandlerContext, status: HttpResponseStatus)
+class HttpFailure(ctx: ChannelHandlerContext, status: HttpResponseStatus)
extends LeftFoldUpstreamHandler
{
{
@@ -37,7 +37,7 @@ private[finagle] class HttpFailure(ctx: ChannelHandlerContext, status: HttpRespo
this // (swallow the message)
}
-private[finagle] case class AggregateHttpChunks(
+case class AggregateHttpChunks(
whenDone: LeftFoldUpstreamHandler,
request: HttpRequest,
bufferBudget: Int,
@@ -79,7 +79,7 @@ private[finagle] case class AggregateHttpChunks(
}
}
-private[finagle] class AggregateHttpRequest(maxBufferSize: Int)
+class AggregateHttpRequest(maxBufferSize: Int)
extends LeftFoldUpstreamHandler
{
override def messageReceived(ctx: ChannelHandlerContext, e: MessageEvent) =
@@ -8,7 +8,7 @@ package com.twitter.finagle.http
import org.jboss.netty.handler.codec.http._
-private[finagle] class ConnectionManager {
+class ConnectionManager {
private[this] var isKeepAlive = false
private[this] var isIdle = true
@@ -18,7 +18,7 @@ import com.twitter.finagle.util.Conversions._
// the Connection header, that request becomes the last one for the
// connection."
-private[finagle] class ServerConnectionManager extends SimpleChannelHandler {
+class ServerConnectionManager extends SimpleChannelHandler {
private[this] val manager = new ConnectionManager
override def messageReceived(ctx: ChannelHandlerContext, e: MessageEvent) {
@@ -1,25 +0,0 @@
-package com.twitter.finagle.util
-
-import java.io.{
- ByteArrayOutputStream, ByteArrayInputStream,
- DataOutputStream, DataInputStream}
-
-object TracingHeader {
- def encode(txid: Long, body: Array[Byte]) = {
- val bos = new ByteArrayOutputStream(8)
- val dos = new DataOutputStream(bos)
-
- dos.writeLong(txid)
- dos.flush()
-
- bos.toByteArray ++ body
- }
-
- def decode(bytes: Array[Byte]) = {
- val bis = new ByteArrayInputStream(bytes)
- val dis = new DataInputStream(bis)
- val txid = dis.readLong()
-
- (bytes drop 8, txid)
- }
-}

0 comments on commit b8ff969

Please sign in to comment.