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

log discarded messages in read-only endpoint #25127

Browse source
This commit is contained in:
Patrik Nordwall 2018-05-29 12:47:09 +02:00 • committed by Johan Andrén
parent 7c3a8a8ed5
commit 73284fd897
1 changed files with 13 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

15
akka-remote/src/main/scala/akka/remote/Endpoint.scala
View file

@ -1033,10 +1033,21 @@ private[remote] class EndpointReader(
case StopReading(writer, replyTo) ⇒
replyTo ! StoppedReading(writer)
case InboundPayload(p) ⇒
val (ackOption, _) = tryDecodeMessageAndAck(p)
case InboundPayload(p) if p.size <= transport.maximumPayloadBytes ⇒
val (ackOption, msgOption) = tryDecodeMessageAndAck(p)
for (ack ← ackOption; reliableDelivery ← reliableDeliverySupervisor) reliableDelivery ! ack
if (log.isWarningEnabled)
log.warning("Discarding inbound message to [{}] in read-only association to [{}]. " +
"If this happens often you may consider using akka.remote.use-passive-connections=off " +
"or use Artery TCP.", msgOption.map(_.recipient).getOrElse("unknown"), remoteAddress)
case InboundPayload(oversized) ⇒
log.error(
new OversizedPayloadException(s"Discarding oversized payload received in read-only association: " +
s"max allowed size [${transport.maximumPayloadBytes}] bytes, actual size [${oversized.size}] bytes."),
"Transient error while reading from association (association remains live)")
case _ ⇒
}