@@ -56,24 +56,25 @@ func readSymbolValue(ef *pfelf.File, name libpf.SymbolName) ([]byte, error) {
56
56
log .Infof ("read symbol value %s: %s" , sym .Name , memory )
57
57
return memory , nil
58
58
}
59
+
59
60
func readReleaseVersion (ef * pfelf.File ) (uint32 , []byte , error ) {
60
- otp_release , err := readSymbolValue (ef , "etp_otp_release" )
61
+ otpRelease , err := readSymbolValue (ef , "etp_otp_release" )
61
62
if err != nil {
62
63
return 0 , nil , fmt .Errorf ("failed to read OTP release: %v" , err )
63
64
}
64
65
65
66
// Slice off the null termination before converting
66
- otp_major , err := strconv .Atoi (string (otp_release [:len (otp_release )- 1 ]))
67
+ otpMajor , err := strconv .Atoi (string (otpRelease [:len (otpRelease )- 1 ]))
67
68
if err != nil {
68
69
return 0 , nil , fmt .Errorf ("failed to parse OTP version: %v" , err )
69
70
}
70
71
71
- erts_version , err := readSymbolValue (ef , "etp_erts_version" )
72
+ ertsVersion , err := readSymbolValue (ef , "etp_erts_version" )
72
73
if err != nil {
73
74
return 0 , nil , fmt .Errorf ("failed to read erts version: %v" , err )
74
75
}
75
76
76
- return uint32 (otp_major ), erts_version , nil
77
+ return uint32 (otpMajor ), ertsVersion , nil
77
78
}
78
79
79
80
func Loader (ebpf interpreter.EbpfHandler , info * interpreter.LoaderInfo ) (interpreter.Data , error ) {
@@ -88,7 +89,7 @@ func Loader(ebpf interpreter.EbpfHandler, info *interpreter.LoaderInfo) (interpr
88
89
return nil , err
89
90
}
90
91
91
- otp_version , _ , err := readReleaseVersion (ef )
92
+ otpVersion , _ , err := readReleaseVersion (ef )
92
93
if err != nil {
93
94
return nil , err
94
95
}
@@ -104,11 +105,10 @@ func Loader(ebpf interpreter.EbpfHandler, info *interpreter.LoaderInfo) (interpr
104
105
}
105
106
106
107
d := & beamData {
107
- version : otp_version ,
108
+ version : otpVersion ,
108
109
}
109
110
110
- log .Infof ("BEAM loaded, otp_version: %d, interpRanges: %v" , otp_version , interpRanges )
111
- //d.loadIntrospectionData()
111
+ log .Infof ("BEAM loaded, otpVersion: %d, interpRanges: %v" , otpVersion , interpRanges )
112
112
113
113
return d , nil
114
114
}
@@ -121,11 +121,12 @@ func (d *beamData) Attach(ebpf interpreter.EbpfHandler, pid libpf.PID, bias libp
121
121
}, nil
122
122
}
123
123
124
- func (r * beamInstance ) Detach (ebpf interpreter.EbpfHandler , pid libpf.PID ) error {
124
+ func (i * beamInstance ) Detach (interpreter.EbpfHandler , libpf.PID ) error {
125
+ log .Infof ("BEAM interpreter detaching" )
125
126
return nil
126
127
}
127
128
128
- func (r * beamInstance ) Symbolize (symbolReporter reporter.SymbolReporter , frame * host.Frame , trace * libpf.Trace ) error {
129
+ func (i * beamInstance ) Symbolize (symbolReporter reporter.SymbolReporter , frame * host.Frame , trace * libpf.Trace ) error {
129
130
if ! frame .Type .IsInterpType (libpf .BEAM ) {
130
131
log .Warnf ("BEAM failed to symbolize" )
131
132
return interpreter .ErrMismatchInterpreterType
0 commit comments