diff --git a/pkg/agent/packets_agent.go b/pkg/agent/packets_agent.go index 1157901c3364aca3643a4f7d6d698ade2a17d5fa..5c76bc9ed284dbb4d9b52d04a97f4e75fb75ba7e 100644 --- a/pkg/agent/packets_agent.go +++ b/pkg/agent/packets_agent.go @@ -78,27 +78,25 @@ func PacketsAgent(cfg *Config) (*Packets, error) { debug = true } filterRules := make([]*tracer.FilterConfig, 0) - if cfg.EnableFlowFilter { - var flowFilters []*FlowFilter - if err := json.Unmarshal([]byte(cfg.FlowFilterRules), &flowFilters); err != nil { - return nil, err - } + var flowFilters []*FlowFilter + if err := json.Unmarshal([]byte(cfg.FlowFilterRules), &flowFilters); err != nil { + return nil, err + } - for _, r := range flowFilters { - filterRules = append(filterRules, &tracer.FilterConfig{ - FilterAction: r.FilterAction, - FilterDirection: r.FilterDirection, - FilterIPCIDR: r.FilterIPCIDR, - FilterProtocol: r.FilterProtocol, - FilterPeerIP: r.FilterPeerIP, - FilterDestinationPort: tracer.ConvertFilterPortsToInstr(r.FilterDestinationPort, r.FilterDestinationPortRange, r.FilterDestinationPorts), - FilterSourcePort: tracer.ConvertFilterPortsToInstr(r.FilterSourcePort, r.FilterSourcePortRange, r.FilterSourcePorts), - FilterPort: tracer.ConvertFilterPortsToInstr(r.FilterPort, r.FilterPortRange, r.FilterPorts), - FilterTCPFlags: r.FilterTCPFlags, - FilterDrops: r.FilterDrops, - FilterSample: r.FilterSample, - }) - } + for _, r := range flowFilters { + filterRules = append(filterRules, &tracer.FilterConfig{ + FilterAction: r.FilterAction, + FilterDirection: r.FilterDirection, + FilterIPCIDR: r.FilterIPCIDR, + FilterProtocol: r.FilterProtocol, + FilterPeerIP: r.FilterPeerIP, + FilterDestinationPort: tracer.ConvertFilterPortsToInstr(r.FilterDestinationPort, r.FilterDestinationPortRange, r.FilterDestinationPorts), + FilterSourcePort: tracer.ConvertFilterPortsToInstr(r.FilterSourcePort, r.FilterSourcePortRange, r.FilterSourcePorts), + FilterPort: tracer.ConvertFilterPortsToInstr(r.FilterPort, r.FilterPortRange, r.FilterPorts), + FilterTCPFlags: r.FilterTCPFlags, + FilterDrops: r.FilterDrops, + FilterSample: r.FilterSample, + }) } ebpfConfig := &tracer.FlowFetcherConfig{ EnableIngress: ingress,