Skip to content

fix: resolve IP-based destinations to FQDN via HTTP headers#215

Merged
mayankpande88 merged 2 commits into
mainfrom
fix/ip-to-fqdn-resolution
Mar 7, 2026
Merged

fix: resolve IP-based destinations to FQDN via HTTP headers#215
mayankpande88 merged 2 commits into
mainfrom
fix/ip-to-fqdn-resolution

Conversation

@mayankpande88

Copy link
Copy Markdown
Contributor

Summary

  • HTTP Host header resolution: When DNS capture fails (Go goroutine migration breaks pid-based eBPF tracking), use HTTP/1.1 Host header and HTTP/2 :authority pseudo-header to resolve IP-based DestinationKeys to FQDNs. Migrates both the key and connectionStats map entries, and populates ip_to_fqdn for future connections.
  • eBPF dport extraction: Extract destination port from connect() sockaddr arguments so non-TCP connections (UDP DNS on port 53) get proper dport in active_connections, enabling DNS protocol detection.
  • HTTP/2 :authority capture: Add Authority field to Http2Request struct and capture :authority pseudo-header during HPACK decoding.

Root Cause

61% of HTTP traffic had unresolved destination IPs because:

  1. Go goroutines migrate between OS threads between connect() and write()/read(), breaking pid-based eBPF tracking of DNS requests
  2. UDP DNS sockets had dport=0 in active_connections because sys_exit_connect didn't extract port from sockaddr
  3. Only 2 out of 76 containers produced DNS metrics (C-based programs like nginx that don't exhibit goroutine migration)

Changed Files

File Change
common/net.go Add WithResolvedDomain() to create FQDN-based DestinationKey
containers/container.go Add migrateConnectionKeyToFQDN(), resolve via Host/:authority headers
ebpftracer/ebpf/tcp/state.c Extract dport from connect() sockaddr, add dport to struct connection
ebpftracer/l7/http2.go Capture :authority pseudo-header in HTTP/2 parser
ebpftracer/ebpf.go Regenerated eBPF bytecode (all 10 kernel/arch variants)

Test plan

  • Deploy to staging cluster and verify ip_to_fqdn metric populates for previously unresolved IPs
  • Verify destination_workload_name in HTTP/TCP metrics shows FQDNs instead of raw IPs for external destinations
  • Verify DNS metrics appear for Go-based services (not just C-based ones)
  • Verify no regression in existing connection tracking

@gemini-code-assist

Copy link
Copy Markdown

Summary of Changes

Hello, I'm Gemini Code Assist1! I'm currently reviewing this pull request and will post my feedback shortly. In the meantime, here's a summary to help you and other reviewers quickly get up to speed!

This pull request significantly improves the accuracy of network traffic visibility by addressing challenges in resolving IP-based destinations to FQDNs. It introduces robust mechanisms to leverage HTTP headers for FQDN identification when DNS-based tracking is insufficient, and refines eBPF data collection to ensure correct destination port information for various protocols. These changes aim to provide a more complete and accurate picture of network connections, particularly for Go-based services that previously suffered from unresolved destination IPs.

Highlights

  • HTTP Host Header Resolution: Implemented logic to resolve IP-based DestinationKeys to Fully Qualified Domain Names (FQDNs) using HTTP/1.1 Host headers and HTTP/2 :authority pseudo-headers, especially when traditional DNS capture fails. This includes migrating connection keys and associated statistics.
  • eBPF Destination Port Extraction: Enhanced eBPF tracing to correctly extract the destination port from connect() sockaddr arguments for non-TCP connections (e.g., UDP DNS), ensuring accurate dport population in active_connections and enabling proper DNS protocol detection.
  • HTTP/2 :authority Header Capture: Added functionality to capture the :authority pseudo-header during HTTP/2 HPACK decoding and included it in the Http2Request struct, facilitating FQDN resolution for HTTP/2 traffic.

🧠 New Feature in Public Preview: You can now enable Memory to help Gemini Code Assist learn from your team's feedback. This makes future code reviews more consistent and personalized to your project's style. Click here to enable Memory in your admin console.

Changelog
  • common/net.go
    • Added a new WithResolvedDomain() method to the DestinationKey struct to facilitate creating FQDN-based keys.
  • containers/container.go
    • Imported the net package.
    • Added helper functions isIPAddress() and stripPort() for network address manipulation.
    • Introduced migrateConnectionKeyToFQDN() to update connection keys and migrate associated statistics when an FQDN is resolved.
    • Modified onL7Request() to incorporate FQDN resolution from the DNS cache and to use HTTP Host and HTTP/2 :authority headers for resolving IP-based DestinationKeys.
  • ebpftracer/Dockerfile
    • Duplicated the FROM alpine:3.14 instruction.
  • ebpftracer/ebpf/l7/http.c
    • Replaced bpf_probe_read_str with bpf_probe_read for HTTP request and response detection.
    • Implemented is_http_response_partial() to handle and detect incomplete HTTP responses.
  • ebpftracer/ebpf/l7/http2.c
    • Defined a bpf_read macro for simplified eBPF probe reads.
    • Added is_http2_response_partial() to manage and identify partial HTTP/2 responses.
  • ebpftracer/ebpf/l7/l7.c
    • Modified the COPY_PAYLOAD macro to include a size check before reading.
    • Introduced init_l7_event() to optimize the initialization of L7 event structures.
    • Refactored trace_enter_write() to include a fast path for common protocols and ensure protocol detection only occurs if the protocol is PROTOCOL_UNKNOWN.
    • Updated trace_exit_read() to use init_l7_event() and to handle partial HTTP and HTTP/2 responses by integrating the new partial response detection functions.
  • ebpftracer/ebpf/tcp/state.c
    • Added protocol and dport fields to the struct connection.
    • Defined struct connect_args and connect_args_by_pid_tgid map to temporarily store connection arguments.
    • Modified sys_enter_connect() to extract the destination port from the sockaddr argument and store it.
    • Updated sys_exit_connect() to retrieve the stored destination port and populate it for non-TCP connections.
  • ebpftracer/l7/http2.go
    • Added an Authority field to the Http2Request struct.
    • Modified the Parse method to capture the :authority pseudo-header during HTTP/2 frame processing.
  • ebpftracer/tracer.go
    • Reduced the l7_events perf map buffer size and adjusted WakeupEvents for improved performance.
    • Added isValidHTTPData() and isResponseTruncated() functions for validating HTTP payload and response data.
    • Implemented payload size validation and sanity checks for indices within runEventsReader().
    • Integrated isValidHTTPData() for HTTP payloads and isResponseTruncated() for HTTP/HTTP2 responses to filter out garbage or incomplete data.
Using Gemini Code Assist

The full guide for Gemini Code Assist can be found on our documentation page, here are some quick tips.

Invoking Gemini

You can request assistance from Gemini at any point by creating a comment using either /gemini <command> or @gemini-code-assist <command>. Below is a summary of the supported commands on the current page.

Feature Command Description
Code Review /gemini review Performs a code review for the current pull request in its current state.
Pull Request Summary /gemini summary Provides a summary of the current pull request in its current state.
Comment @gemini-code-assist Responds in comments when explicitly tagged, both in pull request comments and review comments.
Help /gemini help Displays a list of available commands.

Customization

To customize Gemini Code Assist for GitHub experience, repository maintainers can create a configuration file and/or provide a custom code review style guide (such as PEP-8 for Python) by creating and adding files to a .gemini/ folder in the base of the repository. Detailed instructions can be found here.

Limitations & Feedback

Gemini Code Assist may make mistakes. Please leave feedback on any instances where its feedback is incorrect or counter productive. You can react with 👍 and 👎 on @gemini-code-assist comments. If you're interested in giving your feedback about your experience with Gemini Code Assist for Github and other Google products, sign up here.

You can also get AI-powered code generation, chat, as well as code reviews directly in the IDE at no cost with the Gemini Code Assist IDE Extension.

Footnotes

  1. Review the Privacy Notices, Generative AI Prohibited Use Policy, Terms of Service, and learn how to configure Gemini Code Assist in GitHub here. Gemini can make mistakes, so double check it and use code with caution.

@gemini-code-assist gemini-code-assist Bot left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Code Review

This pull request introduces a mechanism to resolve IP-based destinations to FQDNs using HTTP Host and :authority headers, serving as a fallback when DNS capture fails, and includes eBPF optimizations for non-TCP connections. However, it introduces a high-severity Denial of Service (DoS) vulnerability due to cardinality explosion from using attacker-controlled HTTP headers for metric labels. Additionally, there's a critical bug in how DestinationKey is updated, leading to data loss, and the FQDN resolution for HTTP/2 traffic doesn't update the global cache. Further concerns include eBPF performance issues, potential verifier failures from large unrolled loops, and a medium-severity information leak in eBPF event buffers. A minor Dockerfile issue and a suggestion for code clarity were also noted.

Comment thread common/net.go Outdated
Comment thread containers/container.go
Comment thread containers/container.go Outdated
Comment thread ebpftracer/ebpf/l7/http.c Outdated
Comment thread ebpftracer/ebpf/l7/l7.c Outdated
Comment thread containers/container.go
Comment thread ebpftracer/Dockerfile Outdated
…dport extraction

Two complementary fixes for the ip_to_fqdn resolution gap where external
destinations show raw IPs instead of FQDNs in metrics:

1. Go: Use HTTP Host header and HTTP/2 :authority pseudo-header to resolve
   IP-based DestinationKeys to FQDNs when DNS capture fails (due to Go
   goroutine migration breaking pid-based eBPF tracking). Extracts
   migrateConnectionKeyToFQDN helper from migrateConnectionKeyIfNeeded.

2. eBPF: Extract destination port from connect() sockaddr arguments so
   non-TCP connections (UDP DNS) get proper dport in active_connections.
   Previously sys_exit_connect created entries with dport=0 for UDP,
   preventing DNS protocol detection for port 53.
@mayankpande88 mayankpande88 force-pushed the fix/ip-to-fqdn-resolution branch from be419c9 to 97964f9 Compare March 7, 2026 12:59
@mayankpande88 mayankpande88 merged commit d38d1d4 into main Mar 7, 2026
1 check passed
@mayankpande88 mayankpande88 deleted the fix/ip-to-fqdn-resolution branch March 7, 2026 13:05
mayankpande88 added a commit that referenced this pull request Mar 8, 2026
* fix: reduce memory usage, fix race conditions, and prevent corrupted eBPF spans (#206)

* fix: add missing patternsPerLevelLimit param to logparser.NewParser calls

* fix: update logparser dep, sanitize log paths, replace test credential

* fix: update logparser dep to fix sensitive pattern loading

The previous version had a corrupted sensitive_patterns.json that caused
"cannot unmarshal object into Go value of type []SensitivePattern" errors,
breaking sensitive data detection in log parsing.

* fix: reduce memory usage, fix race conditions, and fd leaks

Memory optimizations:
- Auto-tune GOMEMLIMIT to 90% of cgroup memory limit
- Reduce connectionStats LRU cache from 8192 to 4096
- Reduce event channel buffer from 10000 to 2000
- Cap ip2fqdn map at 10000 entries
- Reduce label interner max from 10000 to 5000
- Reduce LLM stream limits (maxActiveStreams 1000->200, buffer 1MB->64KB)
- Cache stripped Go binary paths to avoid repeated uprobe attach attempts
- Reduce GC interval from 10min to 5min
- Clean up HTTP/2 HPACK parsers for dead connections in gc()

Race condition fixes in Container.Collect():
- Snapshot connectionStats LRU under RLock (not concurrent-safe)
- Call getListens/getProxiedListens under RLock
- Protect logSamples map reads/writes with lock
- Read restarts/oomKills under RLock
- Read c.processes under RLock in onConnectionOpen before lock scope

File descriptor leak fixes in logs/tail_reader.go:
- Close file on Stat/Seek failure in NewTailReader
- Close old file before setting nil in moved()
- Cap partial line buffer at 64KB to prevent unbounded growth
- Fix prefix accumulation bug (was replacing instead of appending)

* fix: validate eBPF durations to prevent corrupted spans causing OTel OOM

eBPF kernel probes occasionally produce garbage duration values where the
uint64 has the high bit set. Casting to time.Duration (int64) produces
negative durations, creating spans where end_time < start_time. These
poison spans cause ClickHouse batch rejections, OTel collector retry
accumulation, and eventual OOMKill (165 restarts observed).

Source-level fix (eBPF event parsing):
- Add safeDuration() that returns 0 for values >= 1 hour or == 0
- Replace all uint64->time.Duration casts in perf/ringbuf readers

HTTP/2 parser fix:
- Add safeKernelDuration() for kernel timestamp subtraction
- Prevents unsigned underflow when events arrive out of order

Defense-in-depth (span creation):
- createSpan: drop spans with duration <= 0 or > 1 hour
- LLMRequest: drop spans with zero/invalid timestamps or > 1 hour

* fix: address review comments

- Use double-checked locking for logSamples to avoid redundant writes
- Use strconv.ParseInt instead of fmt.Sscanf for stricter cgroup parsing

* fix: gofmt alignment in llm_stream.go

* fix: use debug.SetMemoryLimit instead of runtime.SetMemoryLimit

* chore(deps): bump go.opentelemetry.io/otel/sdk from 1.37.0 to 1.40.0 (#205)

Bumps [go.opentelemetry.io/otel/sdk](https://github.com/open-telemetry/opentelemetry-go) from 1.37.0 to 1.40.0.
- [Release notes](https://github.com/open-telemetry/opentelemetry-go/releases)
- [Changelog](https://github.com/open-telemetry/opentelemetry-go/blob/main/CHANGELOG.md)
- [Commits](open-telemetry/opentelemetry-go@v1.37.0...v1.40.0)

---
updated-dependencies:
- dependency-name: go.opentelemetry.io/otel/sdk
  dependency-version: 1.40.0
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>

* fix: resolve IP-based destinations to FQDN via HTTP headers (#215)

* fix: resolve IP-based destinations to FQDN via HTTP headers and eBPF dport extraction

Two complementary fixes for the ip_to_fqdn resolution gap where external
destinations show raw IPs instead of FQDNs in metrics:

1. Go: Use HTTP Host header and HTTP/2 :authority pseudo-header to resolve
   IP-based DestinationKeys to FQDNs when DNS capture fails (due to Go
   goroutine migration breaking pid-based eBPF tracking). Extracts
   migrateConnectionKeyToFQDN helper from migrateConnectionKeyIfNeeded.

2. eBPF: Extract destination port from connect() sockaddr arguments so
   non-TCP connections (UDP DNS) get proper dport in active_connections.
   Previously sys_exit_connect created entries with dport=0 for UDP,
   preventing DNS protocol detection for port 53.

* fix: address review feedback - return ip2fqdn for HTTP/2 and add early return guard

* fix: reduce memory footprint by removing unused labels and shrinking eBPF maps (#217)

* fix: reduce memory footprint by removing unused labels and shrinking eBPF maps

- Remove 7 unused labels from TCP/L7 metrics (src_region, src_az,
  destination_workload_region, destination_workload_az,
  actual_destination_region, actual_destination_az,
  actual_destination_instance). These are derivable server-side via
  container_info joins.
- Reduce MAX_CONNECTIONS from 1M to 100K (saves ~100MB kernel memory)
- Reduce MAX_PAYLOAD_SIZE from 8192 to 4096
- Reduce active_l7_requests max_entries from 8192 to 4096
- Reduce connectionStatsCacheSize from 4096 to 2048

* fix: sync MaxPayloadSize Go constant with eBPF MAX_PAYLOAD_SIZE (4096)

Without this, the Go agent reads L7 response data at the wrong offset,
breaking all L7 protocol monitoring.

* fix: prevent OOMKills by lowering GOMEMLIMIT and reducing memory allocations (#218)

- Lower GOMEMLIMIT from 90% to 60% of cgroup limit. The cgroup OOM
  killer counts kernel memory (~80MB for eBPF maps) and page cache
  (~200MB from /proc reads) which GOMEMLIMIT doesn't control.
- Fix Event struct Payload/Response arrays: use MaxPayloadSize (4096)
  instead of hardcoded 8192. Saves ~16MB in the 2000-entry event
  channel buffer.
- Reduce l7_events ring buffer from 16MB to 8MB. With 4KB payloads,
  8MB still holds ~2000 events.

* fix: detect Go applications on listen events for container_application_type (#216)

attachTlsUprobes (which detects Go binaries via buildinfo) was only
called on outbound connection events. Go servers that only listen for
incoming connections were never detected as golang apps. Add the same
call on ListenOpen events so server-only Go processes are properly
identified.

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

* fix: eliminate scrape deadlock, Prometheus wrapping allocs, and K8s informer memory (#219)

* fix: eliminate WrapRegistererWith allocation storm on Prometheus scrapes

Removes the 3-layer WrapRegistererWith wrapping chain for container
metrics that caused ~200MB of transient allocations per scrape on busy
nodes. Container metrics now embed const labels directly, and L7
CounterVec/HistogramVec use ConstLabels on their opts for zero
per-scrape overhead. ip2fqdn and LLM metrics retain minimal wrapping.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: use NodeConstLabels struct instead of magic indices, fix variable shadowing

Addresses PR review: replaces []string with named struct fields for
node-level const labels. Also fixes variable shadowing where loop
variable `c` in GetSensitiveCounters range shadowed the Container
receiver, causing a compile error.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: reduce K8s informer memory by stripping cached objects and removing redundant API calls

- Add SetTransform functions to all 9 informers to strip unneeded fields
  (ManagedFields, Annotations, Spec.Containers, Status.Conditions, etc.)
  before objects enter the informer cache, reducing memory by ~80%.
- Remove getFullClusterSnapshot() which did redundant List() API calls
  for all resource types at startup (informers already do their own
  initial List). Replace with factory.WaitForCacheSync() + updateIpMapping()
  to eliminate the double-fetch memory spike.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: push-model metrics to eliminate c.lock deadlock on scrapes

Root cause: Collect() held c.lock.RLock() for extended periods while
reading connectionStats, failedConnectionAttempts, activeConnections,
and logSamples. Event handlers (onConnectionOpen, onL7Request, etc.)
need c.lock.Lock() — creating a deadlock when a pending writer blocks
recursive readers. Additionally, Registry.Collect() sent to
trafficStatsUpdateCh (consumed by the event handler goroutine), so if
the event handler was blocked on c.lock.Lock(), Registry.Collect()
blocked too → Gather() never returns → zombie goroutines accumulate.

Changes:
- New TCPMetrics struct (CounterVec/GaugeVec) updated by event handlers
  at event time, not scrape time. Collect() calls tcpMetrics.collect(ch)
  without any c.lock — same pattern as existing L7Stats.
- Remove connectionStats LRU cache (no longer needed for accumulation)
- Remove failedConnectionAttempts map (push directly to CounterVec)
- onConnectionOpen/onRetransmission push metrics before acquiring c.lock
- updateConnectionTrafficStats pushes byte deltas to TCPMetrics
- Active connections gauge refreshed periodically by event handler
- Move updateStatsFromEbpfMapsIfNecessary() from Registry.Collect()
  into event handler ticker — eliminates trafficStatsUpdateCh deadlock
- Remove trafficStatsUpdateCh/nodejsStatsUpdateCh/pythonStatsUpdateCh
  channels — event handler calls container methods directly
- logSamples changed from map[string]string to sync.Map for lock-free
  LoadOrStore (eliminates c.lock.Lock() in Collect for log samples)
- Restarts/OOMKills pushed to TCPMetrics counter at event time

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

* fix: use single containerCollector instead of per-container registration

prometheus.Registry.Unregister does not work for unchecked collectors
(empty Describe). It only searches collectorsByID, never the
uncheckedCollectors slice. This meant every container replacement
(process restart within same pod) leaked the old Container object in
the registry — Gather() collected duplicate metrics and returned
HTTP 500.

Register a single containerCollector on the raw registry that iterates
containersById under RLock. Individual container Register/Unregister
calls removed entirely.

---------

Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>

---------

Signed-off-by: dependabot[bot] <support@github.com>
Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Co-authored-by: Raman Kumar <raman.kharche@nudgebee.com>
Co-authored-by: Claude Opus 4.6 <noreply@anthropic.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants