Function moduleMain

maddy.go:412–459

(configPath string)

}

func moduleMain(configPath string) error {
	log.DefaultLogger.Msg("loading configuration...")

	// Make path absolute to make sure we can still read it if current directory changes (in moduleConfigure).
	configPath, err := filepath.Abs(configPath)
	if err != nil {
		return err
	}

	c, err := moduleConfigure(configPath)
	if err != nil {
		return err
	}

	c.DefaultLogger.Msg("configuration loaded")

	if err := moduleStart(c); err != nil {
		return err
	}
	c.DefaultLogger.Msg("server started", "version", Version)

	systemdStatus(SDReady, "Configuration running.")
	asyncStopWg := sync.WaitGroup{} // Some containers might still be waiting on moduleStop
	for handleSignals() {
		hooks.RunHooks(hooks.EventReload)

		c = moduleReload(c, configPath, &asyncStopWg)
	}

	c.DefaultLogger.Msg("server stopping...")

	systemdStatus(SDStopping, "Waiting for old configuration to stop...")
	asyncStopWg.Wait()

	systemdStatus(SDStopping, "Waiting for current configuration to stop...")
	if err := moduleStop(c, true); err != nil {
		c.DefaultLogger.Msg("moduleStop failed", err)
	}
	c.DefaultLogger.Msg("server stopped")

	if c.DefaultLogger.Out != nil {
		if err := c.DefaultLogger.Close(); err != nil {
			log.DefaultLogger.Error("failed to close output logger", err)
		}
	}

	return nil
}

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