Method _disconnect

db/active_replicator_common.go:370–400

_disconnect aborts any replicator processes used during a connected/running replication (checkpointing, blip contexts, etc.)

()

// _disconnect aborts any replicator processes used during a connected/running replication (checkpointing, blip contexts, etc.)
func (arc *activeReplicatorCommon) _disconnect() error {
	if arc == nil {
		// noop
		return nil
	}

	if arc.checkpointerCtx != nil {
		base.TracefCtx(arc.ctx, base.KeyReplicate, "cancelling checkpointer context inside _disconnect")
		arc.checkpointerCtxCancel()
		_ = arc.forEachCollection(func(c *activeReplicatorCollection) error {
			c.Checkpointer.closeWg.Wait()
			c.Checkpointer.CheckpointNow()
			return nil
		})
	}
	arc.checkpointerCtx = nil

	if arc.blipSender != nil {
		base.TracefCtx(arc.ctx, base.KeyReplicate, "closing blip sender")
		arc.blipSender.Close()
		arc.blipSender = nil
	}

	if arc.blipSyncContext != nil {
		base.TracefCtx(arc.ctx, base.KeyReplicate, "closing blip sync context")
		arc.blipSyncContext.Close()
		arc.blipSyncContext = nil
	}

	return nil
}

// _stop aborts any replicator processes that run outside of a running replication connection (e.g: async reconnect handling, statsreporter)
func (arc *activeReplicatorCommon) _stop() {