Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -177,4 +177,4 @@ require (
sigs.k8s.io/yaml v1.4.0 // indirect
)

replace go.opentelemetry.io/ebpf-profiler => github.com/parca-dev/opentelemetry-ebpf-profiler v0.0.0-20260115180451-d79ff27bb66a
replace go.opentelemetry.io/ebpf-profiler => github.com/parca-dev/opentelemetry-ebpf-profiler v0.0.0-20260120173907-dbdd569b8667
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -299,8 +299,8 @@ github.com/opencontainers/selinux v1.13.0/go.mod h1:XxWTed+A/s5NNq4GmYScVy+9jzXh
github.com/orisano/pixelmatch v0.0.0-20220722002657-fb0b55479cde/go.mod h1:nZgzbfBr3hhjoZnS66nKrHmduYNpc34ny7RK4z5/HM0=
github.com/parca-dev/oomprof v0.1.6 h1:potfd09aphNKqsIF54ZsiddTvksVMjQiaKnczFOsVGM=
github.com/parca-dev/oomprof v0.1.6/go.mod h1:iqI6XrmiNWOa8m2vEIKo+GtQrqbWCMLFpBWuk8RuAPs=
github.com/parca-dev/opentelemetry-ebpf-profiler v0.0.0-20260115180451-d79ff27bb66a h1:sHdTnHKnIgO/BHpzP61h78oAPZV0/uwZTloM0pZi2yU=
github.com/parca-dev/opentelemetry-ebpf-profiler v0.0.0-20260115180451-d79ff27bb66a/go.mod h1:yVpeERcH/++ahci/FAPA8l4TL+y0JY3T6z4xu/r3+HM=
github.com/parca-dev/opentelemetry-ebpf-profiler v0.0.0-20260120173907-dbdd569b8667 h1:x7EC4K8Zl4WF1f71shBoGPFut1iTLj526I+yfeOWDlo=
github.com/parca-dev/opentelemetry-ebpf-profiler v0.0.0-20260120173907-dbdd569b8667/go.mod h1:yVpeERcH/++ahci/FAPA8l4TL+y0JY3T6z4xu/r3+HM=
github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 h1:onHthvaw9LFnH4t2DcNVpwGmV9E1BkGknEliJkfwQj0=
github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58/go.mod h1:DXv8WO4yhMYhSNPKjeNKa5WY9YCIEBRbNzFFPJbWO6Y=
github.com/pierrec/lz4/v4 v4.1.22 h1:cKFw6uJDK+/gfw5BcDL0JL5aBsAFdsIT18eRtLj7VIU=
Expand Down
34 changes: 20 additions & 14 deletions main.go
Original file line number Diff line number Diff line change
Expand Up @@ -429,21 +429,27 @@ func mainWithExitCode() flags.ExitCode {
}

// Load the eBPF code and map definitions
traceBufferMultiplier := 1
if f.InstrumentCudaLaunch {
// GPU profiling generates high trace volume, increase buffer
traceBufferMultiplier = 50
}
trc, err := tracer.NewTracer(mainCtx, &tracer.Config{
VerboseMode: f.BPF.VerboseLogging,
Reporter: rep,
Intervals: intervals,
IncludeTracers: includeTracers,
SamplesPerSecond: f.Profiling.CPUSamplingFrequency,
MapScaleFactor: f.BPF.MapScaleFactor,
FilterErrorFrames: !f.Profiling.EnableErrorFrames,
KernelVersionCheck: !f.Hidden.IgnoreUnsafeKernelVersion,
BPFVerifierLogLevel: f.BPF.VerifierLogLevel,
ProbabilisticInterval: f.Profiling.ProbabilisticInterval,
ProbabilisticThreshold: f.Profiling.ProbabilisticThreshold,
OffCPUThreshold: uint32(f.OffCPUThreshold * math.MaxUint32),
IncludeEnvVars: includeEnvVars,
InstrumentCudaLaunch: f.InstrumentCudaLaunch,
VerboseMode: f.BPF.VerboseLogging,
Reporter: rep,
Intervals: intervals,
IncludeTracers: includeTracers,
SamplesPerSecond: f.Profiling.CPUSamplingFrequency,
MapScaleFactor: f.BPF.MapScaleFactor,
FilterErrorFrames: !f.Profiling.EnableErrorFrames,
KernelVersionCheck: !f.Hidden.IgnoreUnsafeKernelVersion,
BPFVerifierLogLevel: f.BPF.VerifierLogLevel,
ProbabilisticInterval: f.Profiling.ProbabilisticInterval,
ProbabilisticThreshold: f.Profiling.ProbabilisticThreshold,
OffCPUThreshold: uint32(f.OffCPUThreshold * math.MaxUint32),
IncludeEnvVars: includeEnvVars,
InstrumentCudaLaunch: f.InstrumentCudaLaunch,
TraceBufferSizeMultiplier: traceBufferMultiplier,
})
metrics.SetReporter(parcaReporter)
if err != nil {
Expand Down
2 changes: 2 additions & 0 deletions reporter/parca_reporter.go
Original file line number Diff line number Diff line change
Expand Up @@ -1067,6 +1067,8 @@ func (r *ParcaReporter) reportDataToBackend(ctx context.Context, buf *bytes.Buff
return err
}

log.Infof("[reporter] sending %d samples (%d bytes) to server", record.NumRows(), buf.Len())

client, err := r.client.Write(ctx)
if err != nil {
return err
Expand Down