diff --git a/pkg/tracer/tracer.go b/pkg/tracer/tracer.go index b8b2be6d8248c6f96eb28682cf33836ebf2d1959..75912c83a757062f4de4f2ce25f0be218ee25814 100644 --- a/pkg/tracer/tracer.go +++ b/pkg/tracer/tracer.go @@ -132,11 +132,8 @@ func NewFlowFetcher(cfg *FlowFetcherConfig) (*FlowFetcher, error) { // Resize maps according to user-provided configuration spec.Maps[aggregatedFlowsMap].MaxEntries = uint32(cfg.CacheMaxSize) - if isEBPFFeaturesEnabled(cfg) { - spec.Maps[additionalFlowMetrics].MaxEntries = uint32(cfg.CacheMaxSize) - } else { - spec.Maps[additionalFlowMetrics].MaxEntries = 1 - } + spec.Maps[additionalFlowMetrics].MaxEntries = uint32(cfg.CacheMaxSize) + // remove pinning from all maps maps2Name := []string{"aggregated_flows", "additional_flow_metrics", "direct_flows", "dns_flows", "filter_map", "global_counters", "packet_record"} for _, m := range maps2Name { @@ -368,13 +365,6 @@ func NewFlowFetcher(cfg *FlowFetcherConfig) (*FlowFetcher, error) { }, nil } -func isEBPFFeaturesEnabled(cfg *FlowFetcherConfig) bool { - if cfg.EnableNetworkEventsMonitoring || cfg.EnableRTT || cfg.EnablePktDrops || cfg.EnableDNSTracker || cfg.EnablePktTranslation { - return true - } - return false -} - func (m *FlowFetcher) AttachTCX(iface ifaces.Interface) error { ilog := log.WithField("iface", iface) if iface.NetNS != netns.None() {