Method push

pkg/event/queue.go:128–151

(e *Event)

}

func (q *Queue) push(e *Event) error {
	var enqueue bool
	if q.enqueueAlways {
		enqueue = true
	}
	for _, listener := range q.listeners {
		enq, err := listener.ProcessEvent(e)
		if err != nil {
			return err
		}
		if listener.CanEnqueue() && enq {
			enqueue = true
		}
	}
	if q.stackEnrichment && e.IsTerminateThread() {
		id := uint64(e.Params.MustGetPid() + e.Params.MustGetTid())
		q.decorator.RemoveBucket(id)
	}
	if enqueue || len(q.listeners) == 0 {
		q.q <- e
		eventsEnqueued.Add(1)
	}
	return nil
}