INNER CODE UNIT · Go

closers

deepflowio/deepflow · server/cmd/server/main.go:115

	closers := ingester.Start(*configPath, shared)

	common.NewMonitor(cfg.MonitorPaths)

	// TODO: loghandle提取出来，并增加log
	// setup system signal
	signalChannel := make(chan os.Signal, 1)
	signal.Notify(signalChannel, syscall.SIGINT, syscall.SIGTERM)
	<-signalChannel

	wg := sync.WaitGroup{}
	wg.Add(len(closers))
	for _, closer := range closers {
		go func(c io.Closer) {
			c.Close()
			wg.Done()
		}(closer)
	}

View source record →