1
1
package com .datadog .debugger .codeorigin ;
2
2
3
- import static com .datadog .debugger .agent .ConfigurationAcceptor .Source .SPAN_DEBUG ;
3
+ import static com .datadog .debugger .agent .ConfigurationAcceptor .Source .CODE_ORIGIN ;
4
4
5
5
import com .datadog .debugger .agent .ConfigurationUpdater ;
6
6
import com .datadog .debugger .exception .Fingerprinter ;
16
16
import java .util .Collection ;
17
17
import java .util .Collections ;
18
18
import java .util .HashMap ;
19
- import java .util .List ;
20
19
import java .util .Map ;
21
20
import java .util .UUID ;
22
21
import java .util .concurrent .ConcurrentHashMap ;
23
- import java .util .stream .Collectors ;
24
22
import org .slf4j .Logger ;
25
23
import org .slf4j .LoggerFactory ;
26
24
@@ -96,7 +94,7 @@ public String createProbeForFrame(String signature) {
96
94
public String installProbe (CodeOriginProbe probe ) {
97
95
CodeOriginProbe installed = probes .putIfAbsent (probe .getId (), probe );
98
96
if (installed == null ) {
99
- taskScheduler .execute (() -> configurationUpdater .accept (SPAN_DEBUG , getProbes ()));
97
+ taskScheduler .execute (() -> configurationUpdater .accept (CODE_ORIGIN , getProbes ()));
100
98
return probe .getId ();
101
99
}
102
100
return installed .getId ();
@@ -108,14 +106,10 @@ public boolean isAlreadyInstrumented(String fingerprint) {
108
106
109
107
private StackTraceElement findPlaceInStack () {
110
108
return StackWalkerFactory .INSTANCE .walk (
111
- stream -> {
112
- List <StackTraceElement > list = stream .collect (Collectors .toList ());
113
- list =
114
- list .stream ()
115
- .filter (element -> !classNameFiltering .isExcluded (element .getClassName ()))
116
- .collect (Collectors .toList ());
117
-
118
- return list .stream ().findFirst ().orElse (null );
119
- });
109
+ stream ->
110
+ stream
111
+ .filter (element -> !classNameFiltering .isExcluded (element .getClassName ()))
112
+ .findFirst ()
113
+ .orElse (null ));
120
114
}
121
115
}
0 commit comments