fix migration state (#520)

This commit is contained in:
cnderrauber
2022-03-16 17:58:25 +08:00
committed by GitHub
parent f3368a567b
commit 82192f524e

View File

@@ -571,6 +571,8 @@ func (p *ParticipantImpl) SetMigrateState(s types.MigrateState) {
}
pendingOffer = p.pendingOffer
p.pendingOffer = nil
// in case of migration, subscriber data channel will not fire OnOpen callback
p.activeCounter.CAS(0, 2)
}
p.lock.Unlock()
if s == types.MigrateStateComplete {