1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184

[arthas@78]$ jad com.navercorp.pinpoint.profiler.context.DefaultDigiwinHttpBodyDataHolder

ClassLoader:                                                                                                                                      
+-ParallelClassLoader@2093176254{name='pinpoint.agent'}                                                                                           

Location:                                                                                                                                         
/agent_pinpoint/lib/pinpoint-profiler-2.5.1-p1.jar                                                                                                

        /*
         * Decompiled with CFR.
         * 
         * Could not load the following classes:
         *  com.navercorp.pinpoint.bootstrap.config.ProfilerConfig
         *  com.navercorp.pinpoint.bootstrap.context.Trace
         *  com.navercorp.pinpoint.bootstrap.context.TraceId
         *  com.navercorp.pinpoint.bootstrap.logging.PLogger
         *  com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory
         *  com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyDataHolder
         *  com.navercorp.pinpoint.common.util.StringUtils
         *  com.navercorp.pinpoint.profiler.context.Binder
         *  com.navercorp.pinpoint.profiler.context.DigiwinHttpBody
         *  com.navercorp.pinpoint.profiler.context.DigiwinRequestHttpBody
         *  com.navercorp.pinpoint.profiler.context.DigiwinRequestHttpBody$RequestTypEnum
         *  com.navercorp.pinpoint.profiler.context.DigiwinResponseHttpBody
         *  com.navercorp.pinpoint.profiler.context.Reference
         *  com.navercorp.pinpoint.profiler.context.digiwin.dto.DigiwinBusinessExceptionDto
         *  com.navercorp.pinpoint.profiler.context.module.DigiwinHttpBodyDataSender
         *  com.navercorp.pinpoint.profiler.sender.DataSender
         */
        package com.navercorp.pinpoint.profiler.context;
        
        import com.google.gson.Gson;
        import com.google.inject.Inject;
        import com.navercorp.pinpoint.bootstrap.config.ProfilerConfig;
        import com.navercorp.pinpoint.bootstrap.context.Trace;
        import com.navercorp.pinpoint.bootstrap.context.TraceId;
        import com.navercorp.pinpoint.bootstrap.logging.PLogger;
        import com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory;
        import com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyDataHolder;
        import com.navercorp.pinpoint.common.util.StringUtils;
        import com.navercorp.pinpoint.profiler.context.Binder;
        import com.navercorp.pinpoint.profiler.context.DigiwinHttpBody;
        import com.navercorp.pinpoint.profiler.context.DigiwinRequestHttpBody;
        import com.navercorp.pinpoint.profiler.context.DigiwinResponseHttpBody;
        import com.navercorp.pinpoint.profiler.context.Reference;
        import com.navercorp.pinpoint.profiler.context.digiwin.dto.DigiwinBusinessExceptionDto;
        import com.navercorp.pinpoint.profiler.context.module.DigiwinHttpBodyDataSender;
        import com.navercorp.pinpoint.profiler.sender.DataSender;
        import java.util.HashMap;
        import java.util.Map;
        import javax.inject.Named;
        
        public class DefaultDigiwinHttpBodyDataHolder
        implements DigiwinHttpBodyDataHolder {
            private final PLogger logger = PLoggerFactory.getLogger(this.getClass());
            private DataSender digiwinHttpBodyGrpcDataSender;
            private Binder<String> digiwinRequestPathThreadBinder;
            ThreadLocal<Long> digiwinResponseBodySizeThradLocal = new ThreadLocal();
            private final ProfilerConfig profilerConfig;
            Binder<Trace> traceBinder;
            private final String applicationName;
            private Binder<Integer> diwinRequestTypeThreadBinder;
            private Binder<Long> diwinRequestBodySizeThreadBinder;
            private final Binder<Boolean> digiwinEaiExceptionThreadBinder;
            private final Map<String, Binder> binderMap = new HashMap<String, Binder>();
            private final Binder<byte[]> bodyValueBinder;
            private final int MAX_LEGTH;
            private final Gson GSON = new Gson();
        
            public void logRequestPath(String path) {
/* 86*/         Reference pathReference = this.digiwinRequestPathThreadBinder.get();
/* 87*/         pathReference.set((Object)path);
            }
        
            public boolean logDigiwinHttpRequestBody(TraceId traceId, String applicationName) {
                String binderPath = (String)this.digiwinRequestPathThreadBinder.get().get();
                String realPath = StringUtils.isEmpty((String)binderPath) ? "" : binderPath;
                DigiwinRequestHttpBody digiwinHttpRequestBody = new DigiwinRequestHttpBody(traceId, traceId.getSpanId(), ((Long)this.diwinRequestBodySizeThreadBinder.get().get()).longValue(), applicationName, realPath, DigiwinRequestHttpBody.RequestTypEnum.valueToEnum((int)((Integer)this.diwinRequestTypeThreadBinder.get().get())));
/*101*/         return this.digiwinHttpBodyGrpcDataSender.send((Object)digiwinHttpRequestBody);
            }
        
            public boolean logDigiwinHttpResponseBody(TraceId traceId, long bodySize, String applicationName) {
                String binderPath = (String)this.digiwinRequestPathThreadBinder.get().get();
                String realPath = StringUtils.isEmpty((String)binderPath) ? "" : binderPath;
                DigiwinHttpBody digiwinHttpResponseBody = new DigiwinHttpBody(traceId, traceId.getSpanId(), bodySize, applicationName, realPath);
/*112*/         return this.digiwinHttpBodyGrpcDataSender.send((Object)digiwinHttpResponseBody);
            }
        
            public boolean logResponseSize(long size) {
                Long oldSize = this.digiwinResponseBodySizeThradLocal.get();
/*119*/         oldSize = null == oldSize ? Long.valueOf(0L + size) : Long.valueOf(oldSize + size);
/*124*/         this.digiwinResponseBodySizeThradLocal.set(oldSize);
/*125*/         return true;
            }
        
            public void logRequestType(Integer type) {
/*130*/         this.diwinRequestTypeThreadBinder.get().set((Object)type);
            }
        
            public void logRequestBodySize(Long requestBodySize) {
/*135*/         this.diwinRequestBodySizeThreadBinder.get().set((Object)requestBodySize);
            }
        
            public void logResponseValue(byte[] b, int off, int len) {
                Long currentSize;
                byte[] bytes = (byte[])this.bodyValueBinder.get().get();
/*141*/         if (bytes == null) {
/*142*/             bytes = new byte[this.MAX_LEGTH];
/*144*/             this.bodyValueBinder.get().set((Object)bytes);
                }
/*147*/         if ((currentSize = this.digiwinResponseBodySizeThradLocal.get()) == null) {
/*150*/             currentSize = 0L;
/*151*/             this.digiwinResponseBodySizeThradLocal.set(currentSize);
                }
/*154*/         if (currentSize < (long)this.MAX_LEGTH || currentSize + (long)len < (long)this.MAX_LEGTH) {
/*155*/             System.arraycopy(b, off, bytes, Math.toIntExact(currentSize), len);
                }
            }
        
            public void setFiled(String filedName, Object value) {
                Binder binder = this.binderMap.get(filedName);
/*200*/         if (null != binder) {
/*201*/             binder.get().set(value);
                }
            }
        
            public <T> T getFiled(String filedName, Class<T> type) {
                Binder binder = this.binderMap.get(filedName);
/*209*/         if (null != binder) {
/*210*/             return (T)binder.get().get();
                }
/*213*/         return null;
            }
        
            @Inject
            public DefaultDigiwinHttpBodyDataHolder(@DigiwinHttpBodyDataSender DataSender digiwinHttpBodyGrpcDataSender, @Named(value="digiwinRequestPathThreadBinder") Binder<String> digiwinRequestPathThreadBinder, Binder<Trace> traceBinder, ProfilerConfig profilerConfig, @Named(value="diwinRequestTypeThreadBinder") Binder<Integer> diwinRequestTypeThreadBinder, @Named(value="diwinRequestBodySizeThreadBinder") Binder<Long> diwinRequestBodySizeThreadBinder, @Named(value="digiwinEaiExceptionThreadBinder") Binder<Boolean> digiwinEaiExceptionThreadBinder, @Named(value="diwinResponseBodyValueThreadBinder") Binder<byte[]> bodyValueBinder) {
/* 60*/         this.digiwinHttpBodyGrpcDataSender = digiwinHttpBodyGrpcDataSender;
/* 61*/         this.digiwinRequestPathThreadBinder = digiwinRequestPathThreadBinder;
/* 62*/         this.diwinRequestTypeThreadBinder = diwinRequestTypeThreadBinder;
/* 63*/         this.diwinRequestBodySizeThreadBinder = diwinRequestBodySizeThreadBinder;
/* 64*/         this.traceBinder = traceBinder;
/* 65*/         this.profilerConfig = profilerConfig;
/* 66*/         this.digiwinEaiExceptionThreadBinder = digiwinEaiExceptionThreadBinder;
/* 67*/         this.applicationName = profilerConfig.readString("pinpoint.applicationName", "unknown_applicationName");
/* 68*/         this.bodyValueBinder = bodyValueBinder;
/* 71*/         this.MAX_LEGTH = profilerConfig.readInt("digiwin.profiler.error.response.max.length", 5120);
/* 74*/         this.binderMap.put("digiwinRequestPathThreadBinder", digiwinRequestPathThreadBinder);
/* 75*/         this.binderMap.put("diwinRequestTypeThreadBinder", diwinRequestTypeThreadBinder);
/* 77*/         this.binderMap.put("diwinRequestBodySizeThreadBinder", diwinRequestBodySizeThreadBinder);
/* 78*/         this.binderMap.put("digiwinEaiExceptionThreadBinder", digiwinEaiExceptionThreadBinder);
/* 79*/         this.binderMap.put("diwinResponseBodyValueThreadBinder", bodyValueBinder);
            }
        
            public void close(int statusCode) {
                String binderPath = (String)this.digiwinRequestPathThreadBinder.get().get();
                String realPath = StringUtils.isEmpty((String)binderPath) ? "" : binderPath;
/*164*/         Long bodySize = this.digiwinResponseBodySizeThradLocal.get();
                Trace trace = (Trace)this.traceBinder.get().get();
/*167*/         if (null == trace) {
/*168*/             return;
                }
/*172*/         byte[] bytes = (byte[])this.bodyValueBinder.get().get();
/*173*/         String errApp = null;
/*174*/         if (bytes != null) {
                    try {
                        String body = new String(bytes, 0, Math.toIntExact(bodySize));
/*177*/                 DigiwinBusinessExceptionDto digiwinBusinessExceptionDto = this.GSON.fromJson(body, DigiwinBusinessExceptionDto.class);
/*179*/                 if (statusCode != 200 && statusCode != 404 && digiwinBusinessExceptionDto.vailed()) {
/*180*/                     errApp = digiwinBusinessExceptionDto.extractErrorAppCode();
                        }
                    }
                    catch (Throwable e) {
/*183*/                 this.logger.error("exact  body error code  exception:", e);
                    }
                }
/*187*/         TraceId traceId = trace.getTraceId();
/*188*/         this.logDigiwinHttpRequestBody(traceId, this.applicationName);
                DigiwinResponseHttpBody digiwinHttpResponseBody = new DigiwinResponseHttpBody(traceId, traceId.getSpanId(), null == bodySize ? 0L : bodySize, this.applicationName, realPath, statusCode, System.currentTimeMillis() - trace.getStartTime(), errApp);
/*191*/         this.digiwinHttpBodyGrpcDataSender.send((Object)digiwinHttpResponseBody);
/*192*/         this.digiwinResponseBodySizeThradLocal.remove();
/*193*/         this.digiwinRequestPathThreadBinder.get().clear();
/*194*/         this.digiwinEaiExceptionThreadBinder.get().clear();
            }
        }

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76

[arthas@78]$ jad com.navercorp.pinpoint.profiler.context.DefaultDigiwinHttpBodyContext


ClassLoader:                                                                                                                                      
+-ParallelClassLoader@2093176254{name='pinpoint.agent'}                                                                                           

Location:                                                                                                                                         
/agent_pinpoint/lib/pinpoint-profiler-2.5.1-p1.jar                                                                                                

       /*
        * Decompiled with CFR.
        * 
        * Could not load the following classes:
        *  com.navercorp.pinpoint.bootstrap.logging.PLogger
        *  com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory
        *  com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyContext
        *  com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyDataHolder
        */
       package com.navercorp.pinpoint.profiler.context;
       
       import com.google.inject.Inject;
       import com.navercorp.pinpoint.bootstrap.logging.PLogger;
       import com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory;
       import com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyContext;
       import com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyDataHolder;
       
       public class DefaultDigiwinHttpBodyContext
       implements DigiwinHttpBodyContext {
           private final PLogger logger = PLoggerFactory.getLogger(this.getClass());
           DigiwinHttpBodyDataHolder digiwinHttpBodyDataHolder;
       
           public void logRequestType(Integer type) {
/*32*/         this.digiwinHttpBodyDataHolder.logRequestType(type);
           }
       
           public void logRequestBodySize(Long requestBodySize) {
/*37*/         this.digiwinHttpBodyDataHolder.logRequestBodySize(requestBodySize);
           }
       
           public void logResponseValue(byte[] b, int off, int len) {
/*66*/         this.digiwinHttpBodyDataHolder.logResponseValue(b, off, len);
           }
       
           public void setFiled(String filedName, Object value) {
/*56*/         this.digiwinHttpBodyDataHolder.setFiled(filedName, value);
           }
       
           public <T> T getFiled(String filedName, Class<T> type) {
/*61*/         return (T)this.digiwinHttpBodyDataHolder.getFiled(filedName, type);
           }
       
           public DigiwinHttpBodyDataHolder getDigiwinHttpBodyDataHolder() {
/*22*/         return this.digiwinHttpBodyDataHolder;
           }
       
           public void logResponseBodySize(long size) {
/*42*/         this.digiwinHttpBodyDataHolder.logResponseSize(size);
           }
       
           @Inject
           public DefaultDigiwinHttpBodyContext(DigiwinHttpBodyDataHolder digiwinHttpBodyDataHolder) {
/*17*/         this.digiwinHttpBodyDataHolder = digiwinHttpBodyDataHolder;
           }
       
           public void init() {
           }
       
           public void close(int statusCode) {
               try {
/*48*/             this.digiwinHttpBodyDataHolder.close(statusCode);
               }
               catch (Throwable e) {
/*50*/             this.logger.error("DefaultDigiwinHttpBodyContext  close error", e);
               }
           }
       }

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

[arthas@78]$ jad com.navercorp.pinpoint.plugin.tomcat.digiwin.interceptor.CoyoteOutputStreamInterceptor

ClassLoader:                                                                                                                                      
+-sun.misc.Launcher$AppClassLoader@18b4aac2                                                                                                       
  +-sun.misc.Launcher$ExtClassLoader@498a612d                                                                                                     

Location:                                                                                                                                         
/agent_pinpoint/plugin/pinpoint-tomcat-plugin-2.5.1-p1.jar                                                                                        

       /*
        * Decompiled with CFR.
        * 
        * Could not load the following classes:
        *  com.navercorp.pinpoint.bootstrap.context.TraceContext
        *  com.navercorp.pinpoint.bootstrap.interceptor.AroundInterceptor
        *  com.navercorp.pinpoint.bootstrap.logging.PLogger
        *  com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory
        *  com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyContext
        */
       package com.navercorp.pinpoint.plugin.tomcat.digiwin.interceptor;
       
       import com.navercorp.pinpoint.bootstrap.context.TraceContext;
       import com.navercorp.pinpoint.bootstrap.interceptor.AroundInterceptor;
       import com.navercorp.pinpoint.bootstrap.logging.PLogger;
       import com.navercorp.pinpoint.bootstrap.logging.PLoggerFactory;
       import com.navercorp.pinpoint.bootstrap.plugin.http.digiwin.DigiwinHttpBodyContext;
       
       public class CoyoteOutputStreamInterceptor
       implements AroundInterceptor {
           private final PLogger logger = PLoggerFactory.getLogger(this.getClass());
           private final TraceContext traceContext;
       
           public CoyoteOutputStreamInterceptor(TraceContext traceContext) {
/*14*/         this.traceContext = traceContext;
           }
       
           public void before(Object target, Object[] args) {
/*20*/         int len = 0;
               try {
                   byte[] b;
/*22*/             DigiwinHttpBodyContext digiwinHttpBodyContext = this.traceContext.getDigiwinHttpBodyContext();
/*23*/             if (args.length == 1) {
                       // empty if block
                   }
/*25*/             if (args.length == 1 && args[0].getClass().isArray()) {
/*26*/                 b = (byte[])args[0];
/*27*/                 len = b.length;
/*28*/                 digiwinHttpBodyContext.logResponseValue(b, 0, len);
                   }
/*31*/             if (args.length == 3) {
/*33*/                 b = (byte[])args[0];
/*34*/                 int off = (Integer)args[1];
/*35*/                 len = (Integer)args[2];
/*38*/                 digiwinHttpBodyContext.logResponseValue(b, off, len);
                   }
/*41*/             if (null != digiwinHttpBodyContext) {
/*42*/                 digiwinHttpBodyContext.logResponseBodySize((long)len);
                   }
               }
               catch (Throwable t) {
/*46*/             this.logger.warn("before. Caused:{}", (Object)t.getMessage(), (Object)t);
               }
           }
       
           public void after(Object target, Object[] args, Object result, Throwable throwable) {
           }
       }

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187

 /*
         * Decompiled with CFR.
         * 
         * Could not load the following classes:
         *  com.navercorp.pinpoint.bootstrap.interceptor.AroundInterceptor
         *  com.navercorp.pinpoint.bootstrap.interceptor.Interceptor
         *  com.navercorp.pinpoint.bootstrap.interceptor.registry.InterceptorRegistry
         */
        package org.apache.catalina.connector;
        
        import com.navercorp.pinpoint.bootstrap.interceptor.AroundInterceptor;
        import com.navercorp.pinpoint.bootstrap.interceptor.Interceptor;
        import com.navercorp.pinpoint.bootstrap.interceptor.registry.InterceptorRegistry;
        import java.io.IOException;
        import java.nio.ByteBuffer;
        import javax.servlet.ServletOutputStream;
        import javax.servlet.WriteListener;
        import org.apache.catalina.connector.OutputBuffer;
        import org.apache.tomcat.util.res.StringManager;
        
        public class CoyoteOutputStream
        extends ServletOutputStream {
            protected static final StringManager sm = StringManager.getManager(CoyoteOutputStream.class);
            protected OutputBuffer ob;
        
            protected CoyoteOutputStream(OutputBuffer ob) {
/* 47*/         this.ob = ob;
            }
        
            protected Object clone() throws CloneNotSupportedException {
                throw new CloneNotSupportedException();
            }
        
            void clear() {
/* 70*/         this.ob = null;
            }
        
            /*
             * WARNING - void declaration
             */
            @Override
            public void write(int n) throws IOException {
                Interceptor _$PINPOINT$_interceptor = InterceptorRegistry.getInterceptor((int)2344);
                Object _$PINPOINT$_result = null;
                Throwable _$PINPOINT$_throwable2 = null;
                Object[] _$PINPOINT$_args = new Object[]{new Integer(n)};
                ((AroundInterceptor)_$PINPOINT$_interceptor).before((Object)this, _$PINPOINT$_args);
                try {
                    void i;
/* 79*/             boolean nonBlocking = this.checkNonBlockingWrite();
/* 80*/             this.ob.writeByte((int)i);
/* 81*/             if (nonBlocking) {
/* 82*/                 this.checkRegisterForWrite();
                    }
/* 84*/             _$PINPOINT$_result = null;
                    _$PINPOINT$_throwable2 = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    return;
                }
                catch (Throwable _$PINPOINT$_throwable2) {
                    _$PINPOINT$_result = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    throw _$PINPOINT$_throwable2;
                }
            }
        
            /*
             * WARNING - void declaration
             */
            @Override
            public void write(byte[] byArray) throws IOException {
                Interceptor _$PINPOINT$_interceptor = InterceptorRegistry.getInterceptor((int)2345);
                Object _$PINPOINT$_result = null;
                Throwable _$PINPOINT$_throwable2 = null;
                Object[] _$PINPOINT$_args = new Object[]{byArray};
                ((AroundInterceptor)_$PINPOINT$_interceptor).before((Object)this, _$PINPOINT$_args);
                try {
                    void b;
/* 89*/             this.write((byte[])b, 0, ((void)b).length);
/* 90*/             _$PINPOINT$_result = null;
                    _$PINPOINT$_throwable2 = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    return;
                }
                catch (Throwable _$PINPOINT$_throwable2) {
                    _$PINPOINT$_result = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    throw _$PINPOINT$_throwable2;
                }
            }
        
            /*
             * WARNING - void declaration
             */
            @Override
            public void write(byte[] byArray, int n, int n2) throws IOException {
                Interceptor _$PINPOINT$_interceptor = InterceptorRegistry.getInterceptor((int)2346);
                Object _$PINPOINT$_result = null;
                Throwable _$PINPOINT$_throwable2 = null;
                Object[] _$PINPOINT$_args = new Object[]{byArray, new Integer(n), new Integer(n2)};
                ((AroundInterceptor)_$PINPOINT$_interceptor).before((Object)this, _$PINPOINT$_args);
                try {
                    void len;
                    void off;
                    void b;
/* 95*/             boolean nonBlocking = this.checkNonBlockingWrite();
/* 96*/             this.ob.write((byte[])b, (int)off, (int)len);
/* 97*/             if (nonBlocking) {
/* 98*/                 this.checkRegisterForWrite();
                    }
/*100*/             _$PINPOINT$_result = null;
                    _$PINPOINT$_throwable2 = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    return;
                }
                catch (Throwable _$PINPOINT$_throwable2) {
                    _$PINPOINT$_result = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    throw _$PINPOINT$_throwable2;
                }
            }
        
            /*
             * WARNING - void declaration
             */
            public void write(ByteBuffer byteBuffer) throws IOException {
                Interceptor _$PINPOINT$_interceptor = InterceptorRegistry.getInterceptor((int)2347);
                Object _$PINPOINT$_result = null;
                Throwable _$PINPOINT$_throwable2 = null;
                Object[] _$PINPOINT$_args = new Object[]{byteBuffer};
                ((AroundInterceptor)_$PINPOINT$_interceptor).before((Object)this, _$PINPOINT$_args);
                try {
                    void from;
/*104*/             boolean nonBlocking = this.checkNonBlockingWrite();
/*105*/             this.ob.write((ByteBuffer)from);
/*106*/             if (nonBlocking) {
/*107*/                 this.checkRegisterForWrite();
                    }
/*109*/             _$PINPOINT$_result = null;
                    _$PINPOINT$_throwable2 = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    return;
                }
                catch (Throwable _$PINPOINT$_throwable2) {
                    _$PINPOINT$_result = null;
                    ((AroundInterceptor)_$PINPOINT$_interceptor).after((Object)this, _$PINPOINT$_args, _$PINPOINT$_result, _$PINPOINT$_throwable2);
                    throw _$PINPOINT$_throwable2;
                }
            }
        
            @Override
            public void flush() throws IOException {
/*117*/         boolean nonBlocking = this.checkNonBlockingWrite();
/*118*/         this.ob.flush();
/*119*/         if (nonBlocking) {
/*120*/             this.checkRegisterForWrite();
                }
            }
        
            private boolean checkNonBlockingWrite() {
                boolean nonBlocking;
/*134*/         boolean bl = nonBlocking = !this.ob.isBlocking();
/*135*/         if (nonBlocking && !this.ob.isReady()) {
                    throw new IllegalStateException(sm.getString("coyoteOutputStream.nbNotready"));
                }
/*138*/         return nonBlocking;
            }
        
            private void checkRegisterForWrite() {
/*151*/         this.ob.checkRegisterForWrite();
            }
        
            @Override
            public void close() throws IOException {
/*157*/         this.ob.close();
            }
        
            @Override
            public boolean isReady() {
/*162*/         return this.ob.isReady();
            }
        
            @Override
            public void setWriteListener(WriteListener listener) {
/*168*/         this.ob.setWriteListener(listener);
            }
        }

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19

[arthas@78]$ watch com.navercorp.pinpoint.profiler.context.DefaultDigiwinHttpBodyDataHolder logResponseValue "{params}" -e -x 2
Press Q or Ctrl+C to abort.
Affect(class count: 1 , method count: 1) cost in 234 ms, listenerId: 4
method=com.navercorp.pinpoint.profiler.context.DefaultDigiwinHttpBodyDataHolder.logResponseValue location=AtExceptionExit
ts=2024-09-29 10:11:17.615; [cost=0.155178ms] result=@ArrayList[
    @Object[][
        @byte[][isEmpty=false;size=8192],
        @Integer[0],
        @Integer[6131],
    ],
]
method=com.navercorp.pinpoint.profiler.context.DefaultDigiwinHttpBodyDataHolder.logResponseValue location=AtExceptionExit
ts=2024-09-29 10:11:18.614; [cost=0.056122ms] result=@ArrayList[
    @Object[][
        @byte[][isEmpty=false;size=8192],
        @Integer[0],
        @Integer[6159],
    ],
]

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

public void close(int statusCode) {
                String binderPath = (String)this.digiwinRequestPathThreadBinder.get().get();
                String realPath = StringUtils.isEmpty((String)binderPath) ? "" : binderPath;
/*164*/         Long bodySize = this.digiwinResponseBodySizeThradLocal.get();
                Trace trace = (Trace)this.traceBinder.get().get();
/*167*/         if (null == trace) {
/*168*/             return;
                }
/*172*/         byte[] bytes = (byte[])this.bodyValueBinder.get().get();
/*173*/         String errApp = null;
/*174*/         if (bytes != null) {
                    try {
                        String body = new String(bytes, 0, Math.toIntExact(bodySize));
/*177*/                 DigiwinBusinessExceptionDto digiwinBusinessExceptionDto = this.GSON.fromJson(body, DigiwinBusinessExceptionDto.class);
/*179*/                 if (statusCode != 200 && statusCode != 404 && digiwinBusinessExceptionDto.vailed()) {
/*180*/                     errApp = digiwinBusinessExceptionDto.extractErrorAppCode();
                        }
                    }
                    catch (Throwable e) {
/*183*/                 this.logger.error("exact  body error code  exception:", e);
                    }
                }
/*187*/         TraceId traceId = trace.getTraceId();
/*188*/         this.logDigiwinHttpRequestBody(traceId, this.applicationName);
                DigiwinResponseHttpBody digiwinHttpResponseBody = new DigiwinResponseHttpBody(traceId, traceId.getSpanId(), null == bodySize ? 0L : bodySize, this.applicationName, realPath, statusCode, System.currentTimeMillis() - trace.getStartTime(), errApp);
/*191*/         this.digiwinHttpBodyGrpcDataSender.send((Object)digiwinHttpResponseBody);
/*192*/         this.digiwinResponseBodySizeThradLocal.remove();
/*193*/         this.digiwinRequestPathThreadBinder.get().clear();
/*194*/         this.digiwinEaiExceptionThreadBinder.get().clear();
            }
        }