INNER CODE UNIT · Go

_

daptin/daptin · main.go:627

	_ = runtimeInstance.Quiesce() // Drain reports any quiesce error below.

	delay := time.NewTimer(*shutdownReadinessDelay)
	select {
	case <-delay.C:
	case <-shutdownCtx.Done():
		delay.Stop()
	}

	serverShutdownErrors := make(chan error, len(httpServers))
	for _, httpServer := range httpServers {
		go func(srv *http.Server) { serverShutdownErrors <- srv.Shutdown(shutdownCtx) }(httpServer)
	}
	for range httpServers {
		if shutdownErr := <-serverShutdownErrors; shutdownErr != nil {
			lifecycleErr = errors.Join(lifecycleErr, shutdownErr)
		}
	}

View source record →