From 74a241b702a595b86cabc5350bb5bf7c52d8e27b Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Fri, 22 May 2026 09:14:45 +0300 Subject: yb reject aggregate rows for pid tid filters --- internal/eventloop_runtime.go | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) (limited to 'internal/eventloop_runtime.go') diff --git a/internal/eventloop_runtime.go b/internal/eventloop_runtime.go index d9d9c4c..e8971d4 100644 --- a/internal/eventloop_runtime.go +++ b/internal/eventloop_runtime.go @@ -116,23 +116,15 @@ func aggregateIngestAllowedForFilter(filter globalfilter.Filter) bool { if filter.FD != nil || filter.LatencyNs != nil || filter.GapNs != nil || filter.Bytes != nil || filter.RetVal != nil { return false } - if !isKernelFilterNumericEq(filter.PID) { + if filter.PID != nil { return false } - if !isKernelFilterNumericEq(filter.TID) { + if filter.TID != nil { return false } return true } -func isKernelFilterNumericEq(filter *globalfilter.NumericFilter) bool { - if filter == nil { - return true - } - _, ok := filter.EqValue() - return ok -} - func hasPattern(filter *globalfilter.StringFilter) bool { return filter != nil && strings.TrimSpace(filter.Pattern) != "" } -- cgit v1.2.3