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

=str #15349 Sanitize error logging

Browse source
This commit is contained in:
Patrik Nordwall 2015-01-23 16:12:38 +01:00
parent 84a5505ca9
commit 03abd197fc
9 changed files with 19 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-stream/src/main/scala/akka/stream/impl/io/TcpConnectionStream.scala
View file

@ -15,6 +15,7 @@ import akka.stream.StreamTcpException
import org.reactivestreams.Processor
import akka.actor.Stash
import akka.stream.impl._
import akka.actor.ActorLogging
/**
* INTERNAL API
@ -36,7 +37,8 @@ private[akka] object TcpStreamActor {
/**
* INTERNAL API
*/
private[akka] abstract class TcpStreamActor(val settings: MaterializerSettings) extends Actor with Stash {
private[akka] abstract class TcpStreamActor(val settings: MaterializerSettings) extends Actor with Stash
with ActorLogging {
import TcpStreamActor._
@ -183,6 +185,7 @@ private[akka] abstract class TcpStreamActor(val settings: MaterializerSettings)
writePump.nextPhase(writePump.running)
def fail(e: Throwable): Unit = {
log.debug("fail {} due to: {}", self, e.getMessage)
tcpInputs.cancel()
tcpOutputs.cancel(e)
primaryInputs.cancel()