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

Added lazy initalization of SSL engine to avoid interference

Browse source
This commit is contained in:
Viktor Klang 2010-08-20 11:54:57 +02:00
parent ea2f7bb3b6
commit 9c6e8333b7
2 changed files with 12 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -365,9 +365,12 @@ class RemoteServerPipelineFactory(
def getPipeline: ChannelPipeline = {
def join(ch: ChannelHandler*) = Array[ChannelHandler](ch:_*)
val engine = RemoteServerSslContext.server.createSSLEngine()
engine.setEnabledCipherSuites(engine.getSupportedCipherSuites) //TODO is this sensible?
engine.setUseClientMode(false)
lazy val engine = {
val e = RemoteServerSslContext.server.createSSLEngine()
e.setEnabledCipherSuites(e.getSupportedCipherSuites) //TODO is this sensible?
e.setUseClientMode(false)
e
}
val ssl = if(RemoteServer.SECURE) join(new SslHandler(engine)) else join()
val lenDec = new LengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4)