Function moduleReload

maddy.go:461–528

(oldContainer *container.C, configPath string, asyncStopWg *sync.WaitGroup)

}

func moduleReload(oldContainer *container.C, configPath string, asyncStopWg *sync.WaitGroup) *container.C {
	oldContainer.DefaultLogger.Msg("reloading server...")
	systemdStatus(SDReloading, "Reloading server...")

	rollbackReload := func() {
		// Restore DefaultLogger config that might be set by moduleConfig
		log.DefaultLogger.Out = oldContainer.DefaultLogger.Out
	}

	oldContainer.DefaultLogger.Msg("loading new configuration...")
	newContainer, err := moduleConfigure(configPath)
	if err != nil {
		rollbackReload()
		oldContainer.DefaultLogger.Error("failed to load new configuration", err)

		return oldContainer
	}

	oldContainer.DefaultLogger.Msg("configuration loaded")
	rollbackReload = func() {
		// Restore DefaultLogger config that might be set by moduleConfig
		log.DefaultLogger.Out = oldContainer.DefaultLogger.Out
		container.Global = oldContainer
	}

	if err := oldContainer.Lifetime.EarlyStopAll(); err != nil {
		rollbackReload()
		oldContainer.DefaultLogger.Error("failed to early-stop old server", err)

		return oldContainer
	}

	netresource.ResetListenersUsage()
	oldContainer.DefaultLogger.Msg("starting new server")
	if err := moduleStart(newContainer); err != nil {
		rollbackReload()
		oldContainer.DefaultLogger.Error("failed to start new server", err)

		return oldContainer
	}

	newContainer.DefaultLogger.Msg("new server started", "version", Version)

	systemdStatus(SDReloading, "New configuration running. Waiting for old connections and transactions to finish...")

	asyncStopWg.Add(1)
	go func() {
		defer asyncStopWg.Done()
		defer func() {
			if err := netresource.CloseUnusedListeners(); err != nil {
				oldContainer.DefaultLogger.Error("CloseUnusedListeners failed", err)
			}
		}()

		oldContainer.DefaultLogger.Msg("stopping old server")
		if err := moduleStop(oldContainer, false); err != nil {
			oldContainer.DefaultLogger.Error("moduleStop failed", err)
		}