=rem #3930 part 2: track UID of associated systems

for proper clean-up of the old association (including the writer) when
the restarted system connects before the old association has been torn
down
This commit is contained in:
Roland Kuhn 2014-03-21 20:22:16 +01:00
parent cada750240
commit b97a257f9a
5 changed files with 225 additions and 46 deletions

View file

@ -306,7 +306,8 @@ private[remote] class ReliableDeliverySupervisor(
if (resendBuffer.nonAcked.nonEmpty || resendBuffer.nacked.nonEmpty)
context.system.scheduler.scheduleOnce(settings.SysResendTimeout, self, AttemptSysMsgRedelivery)
context.become(idle)
case GotUid(receivedUid)
case g @ GotUid(receivedUid)
context.parent ! g
// New system that has the same address as the old - need to start from fresh state
uidConfirmed = true
if (uid.exists(_ != receivedUid)) reset()