From 7e924a8c75fcf043067f3c2eabfffea993f23934 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Tue, 15 Mar 2016 13:29:33 +0100 Subject: [PATCH] =rem #19322 reset bufferWasInUse --- akka-remote/src/main/scala/akka/remote/Endpoint.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/akka-remote/src/main/scala/akka/remote/Endpoint.scala b/akka-remote/src/main/scala/akka/remote/Endpoint.scala index 58510e17ea..fbcf16a2c1 100644 --- a/akka-remote/src/main/scala/akka/remote/Endpoint.scala +++ b/akka-remote/src/main/scala/akka/remote/Endpoint.scala @@ -227,8 +227,9 @@ private[remote] class ReliableDeliverySupervisor( var resendBuffer: AckedSendBuffer[Send] = _ var seqCounter: Long = _ - def reset() { + def reset(): Unit = { resendBuffer = new AckedSendBuffer[Send](settings.SysMsgBufferSize) + bufferWasInUse = false seqCounter = 0L bailoutAt = None }