Method Read

pkg/cap/reader_windows.go:106–154

(ctx context.Context)

func (r *reader) SetFilter(f filter.Filter) { r.filter = f }

func (r *reader) Read(ctx context.Context) (chan *event.Event, chan error) {
	errsc := make(chan error, 100)
	eventsc := make(chan *event.Event, 2000)
	go func() {
		r.mu.Lock()
		defer r.mu.Unlock()
		for {
			select {
			case <-ctx.Done():
				return
			default:
			}

			var sec section.Section
			if _, err := io.ReadFull(r.zr, sec[:]); err != nil {
				if err != io.EOF {
					errsc <- err
					continue
				}
				break
			}

			l := sec.Size()
			buf := make([]byte, l)
			if _, err := io.ReadFull(r.zr, buf); err != nil {
				if err != io.EOF {
					errsc <- err
					continue
				}
				break
			}
			evt, err := event.NewFromCapture(buf, sec.Version())
			if err != nil {
				errsc <- fmt.Errorf("fail to unmarshal event: %v", err)
				capEventUnmarshalErrors.Add(1)
				continue
			}
			capReadBytes.Add(int64(len(buf)))
			// update the state of the ps/handle snapshotters
			if err := r.updateSnapshotters(evt); err != nil {
				log.Warn(err)
			}
			// push the event to the chanel
			r.read(evt, eventsc)
		}
	}()

	return eventsc, errsc
}

func (r *reader) Close() error {
	r.mu.Lock()