yb reject aggregate rows for pid tid filters

1 files changed, 2 insertions, 10 deletions

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) != ""
 }