raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fixing ticket 89

Browse source
This commit is contained in:
Viktor Klang 2009-12-29 20:12:46 +01:00
parent 90f7e0ea4e
commit feb1d4bdc8
1 changed files with 18 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

34
akka-core/src/main/scala/remote/RemoteServer.scala
View file

@ -131,6 +131,8 @@ class RemoteServer extends Logging {
}
}
case class Codec(encoder : ChannelHandler,decoder : ChannelHandler)
/**
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/
@ -141,23 +143,23 @@ class RemoteServerPipelineFactory(
import RemoteServer._
def getPipeline: ChannelPipeline = {
val pipeline = Channels.pipeline()
RemoteServer.COMPRESSION_SCHEME match {
case "zlib" => pipeline.addLast("zlibDecoder", new ZlibDecoder)
//case "lzf" => pipeline.addLast("lzfDecoder", new LzfDecoder)
case _ => {} // no compression
val lenDec = new LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4)
val lenPrep = new LengthFieldPrepender(4)
val protobufDec = new ProtobufDecoder(RemoteRequest.getDefaultInstance)
val protobufEnc = new ProtobufEncoder
val remoteServer = new RemoteServerHandler(name, openChannels, loader)
val zipcodec = RemoteServer.COMPRESSION_SCHEME match {
case "zlib" => Some(Codec(new ZlibEncoder(RemoteServer.ZLIB_COMPRESSION_LEVEL),new ZlibDecoder))
//case "lzf" => Some(Codec(new LzfEncoder, new LzfDecoder))
case _ => None
}
pipeline.addLast("frameDecoder", new LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4))
pipeline.addLast("protobufDecoder", new ProtobufDecoder(RemoteRequest.getDefaultInstance))
RemoteServer.COMPRESSION_SCHEME match {
case "zlib" => pipeline.addLast("zlibEncoder", new ZlibEncoder(RemoteServer.ZLIB_COMPRESSION_LEVEL))
//case "lzf" => pipeline.addLast("lzfEncoder", new LzfEncoder)
case _ => {} // no compression
}
pipeline.addLast("frameEncoder", new LengthFieldPrepender(4))
pipeline.addLast("protobufEncoder", new ProtobufEncoder)
pipeline.addLast("handler", new RemoteServerHandler(name, openChannels, loader))
pipeline
val stages : Array[ChannelHandler] = zipcodec.map( z => Array(z.decoder,lenDec,protobufDec,z.encoder,lenPrep,protobufEnc,remoteServer) )
.getOrElse(Array(lenDec,protobufDec,lenPrep,protobufEnc,remoteServer))
new StaticChannelPipeline(stages:_*)
}
}