Method Close

internal/etw/source.go:301–334

Close shutdowns all tracing sessions orderly. Firstly, the buffers are flushed. Then, the trace is closed to signal the event callback to stop consuming more events. Finally, the trace is stopped along with all event consumers.

()

// signal the event callback to stop consuming more events.
// Finally, the trace is stopped along with all event consumers.
func (e *EventSource) Close() error {
	if e.isClosed {
		return nil
	}

	for _, consumer := range e.consumers {
		if err := consumer.Close(); err != nil {
			log.Warnf("couldn't close consumer: %v", err)
		}
	}

	for _, trace := range e.traces {
		if !trace.IsStarted() {
			continue
		}
		if err := trace.Flush(); err != nil {
			log.Warnf("couldn't flush trace session for [%s]: %v", trace.Name, err)
		}
		time.Sleep(time.Millisecond * 150)
		if err := trace.Close(); err != nil {
			log.Warnf("couldn't close trace session for [%s]: %v", trace.Name, err)
		}
		time.Sleep(time.Millisecond * 250)
		if err := trace.Stop(); err != nil {
			log.Warnf("couldn't stop trace session for [%s]: %v", trace.Name, err)
		}
	}

	close(e.stop)

	e.isClosed = true

	return e.sequencer.Shutdown()
}

// Errors returns the channel where errors are published.
func (e *EventSource) Errors() <-chan error {