Method Write

pkg/cap/writer_windows.go:186–216

(evtsc <-chan *event.Event, errs <-chan error)

}

func (w *writer) Write(evtsc <-chan *event.Event, errs <-chan error) chan error {
	errsc := make(chan error, 100)
	go func() {
		for {
			select {
			case evt := <-evtsc:
				b := evt.MarshalRaw()
				l := len(b)
				if l == 0 {
					continue
				}
				// write event buffer
				err := w.write(b)
				if err != nil {
					errsc <- err
					continue
				}
				// update stats
				w.stats.incKevts(evt)
				w.stats.incBytes(uint64(l))
				w.stats.incProcs(evt)
			case err := <-errs:
				errsc <- err
				eventSourceErrors.Add(1)
			case <-w.stop:
				return
			}
		}
	}()
	return errsc
}

func (w *writer) write(b []byte) error {
	w.mu.Lock()