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

refactor SslTlsActor and stop it reliably

Browse source 
- this also discovered two omissions in the Transfer infrastructure:

  - inputsAvailableFor should be completed when the input is cancelled
  - demandAvailableFor should be completed when the output is errored

also switch off tracing for SslTls—we don’t want this on in production
This commit is contained in:
Roland Kuhn 2015-04-24 09:18:09 +02:00
parent 0ac7900e9e
commit 4132e026ec
5 changed files with 125 additions and 83 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/impl/ActorFlowMaterializerImpl.scala
View file

@ -92,7 +92,7 @@ private[akka] case class ActorFlowMaterializerImpl(
case tls: TlsModule ⇒
val es = effectiveSettings(effectiveAttributes)
val props = SslTlsCipherActor.props(es, tls.sslContext, tls.firstSession, tracing = true, tls.role, tls.closing)
val props = SslTlsCipherActor.props(es, tls.sslContext, tls.firstSession, tracing = false, tls.role, tls.closing)
val impl = actorOf(props, stageName(effectiveAttributes), es.dispatcher)
def factory(id: Int) = new ActorPublisher[Any](impl) {
override val wakeUpMsg = FanOut.SubstreamSubscribePending(id)